flinkbot edited a comment on pull request #17933:
URL: https://github.com/apache/flink/pull/17933#issuecomment-980508183
## CI report:
* cbbf8dd39e5c41c070424a55f42f49f943f5f3c4 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18955:
URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485
## CI report:
* 17927dc443ad1920cb4cfdc515416bcc32de87a9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502122#comment-17502122
]
Martijn Visser commented on FLINK-26360:
[~luoyuxia] I'm sure we can support the
twalthr closed pull request #18971:
URL: https://github.com/apache/flink/pull/18971
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubsc
shizhengchao commented on pull request #18863:
URL: https://github.com/apache/flink/pull/18863#issuecomment-1060309279
@PatrickRen Thank you for reviewing it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
flinkbot edited a comment on pull request #18863:
URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200
## CI report:
* e86f5a931a835728e5d839498022329f4a8bbd39 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25969.
Fix Version/s: 1.15.0
Assignee: Timo Walther (was: Francesco Guardiani)
Resolution
Gyula Fora created FLINK-26507:
--
Summary: Last state upgrade mode should allow reconciliation
regardless of job and deployment status
Key: FLINK-26507
URL: https://issues.apache.org/jira/browse/FLINK-26507
LadyForest commented on a change in pull request #28:
URL: https://github.com/apache/flink-table-store/pull/28#discussion_r820471104
##
File path:
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/AbstractCommitterOperator.java
##
@@
flinkbot edited a comment on pull request #18863:
URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200
## CI report:
* e86f5a931a835728e5d839498022329f4a8bbd39 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Gyula Fora created FLINK-26508:
--
Summary: Webhook should only validate on /validate endpoint end
log errors for others
Key: FLINK-26508
URL: https://issues.apache.org/jira/browse/FLINK-26508
Project: Fli
yangjunhan opened a new pull request #18992:
URL: https://github.com/apache/flink/pull/18992
## What is the purpose of the change
https://issues.apache.org/jira/browse/FLINK-26245
## Brief change log
Add missing detectChanges after setting planVisible to true
LadyForest commented on a change in pull request #28:
URL: https://github.com/apache/flink-table-store/pull/28#discussion_r820473874
##
File path:
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/AbstractCommitterOperator.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-23825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502128#comment-17502128
]
Shengkai Fang commented on FLINK-23825:
---
Hi, all. I think it has been tested and w
[
https://issues.apache.org/jira/browse/FLINK-26245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26245:
---
Labels: pull-request-available (was: )
> flink-runtime-web submit showPlan not working
> --
[
https://issues.apache.org/jira/browse/FLINK-23825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-23825.
-
Resolution: Fixed
> Test SQL Client manually
>
>
> Key:
fapaul merged pull request #18825:
URL: https://github.com/apache/flink/pull/18825
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul resolved FLINK-26126.
-
Resolution: Fixed
> Sink V2 will cause error numRecordsOut metric
>
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502129#comment-17502129
]
Fabian Paul commented on FLINK-26126:
-
Merged in master: 9725933fc0a09274801d2acb52a
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul closed FLINK-26126.
---
> Sink V2 will cause error numRecordsOut metric
> -
>
>
Gyula Fora created FLINK-26509:
--
Summary: Improve Kubernetes Operator documentation
Key: FLINK-26509
URL: https://issues.apache.org/jira/browse/FLINK-26509
Project: Flink
Issue Type: Improvement
PatrickRen commented on a change in pull request #18863:
URL: https://github.com/apache/flink/pull/18863#discussion_r820473799
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkRoundRobinPartitionerTest.java
##
Gyula Fora created FLINK-26510:
--
Summary: Document FlinkDeployment CRD
Key: FLINK-26510
URL: https://issues.apache.org/jira/browse/FLINK-26510
Project: Flink
Issue Type: Sub-task
Compo
flinkbot commented on pull request #18992:
URL: https://github.com/apache/flink/pull/18992#issuecomment-1060327091
## CI report:
* 73e68ace1cbeb6cfaa1fc74e523cf13d09fc470f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
Gyula Fora created FLINK-26511:
--
Summary: Document FlinkDeployment lifecycle
Key: FLINK-26511
URL: https://issues.apache.org/jira/browse/FLINK-26511
Project: Flink
Issue Type: Sub-task
flinkbot edited a comment on pull request #18992:
URL: https://github.com/apache/flink/pull/18992#issuecomment-1060327091
## CI report:
* 73e68ace1cbeb6cfaa1fc74e523cf13d09fc470f Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26270:
---
Fix Version/s: (was: 1.12.4)
> Flink SQL write data to kafka by CSV format , decimal typ
Gyula Fora created FLINK-26512:
--
Summary: Document debugging and manual error handling
Key: FLINK-26512
URL: https://issues.apache.org/jira/browse/FLINK-26512
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-25243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502132#comment-17502132
]
Yun Gao commented on FLINK-25243:
-
I'll first close this issue since it does not reprodu
[
https://issues.apache.org/jira/browse/FLINK-25243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-25243.
---
Resolution: Fixed
> Fabric8FlinkKubeClientITCase.testCheckAndUpdateConfigMapConcurrently
> -
[
https://issues.apache.org/jira/browse/FLINK-26407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-26407:
-
Issue Type: Technical Debt (was: Bug)
> MetricsAvailabilityITCase.testReporter failed o
[
https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26497:
---
Fix Version/s: (was: 1.14.4)
> Cast Exception when use split agg with multiple filters
>
[
https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26497:
---
Affects Version/s: 1.14.4
> Cast Exception when use split agg with multiple filters
> --
[
https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26497:
---
Affects Version/s: 1.15.0
> Cast Exception when use split agg with multiple filters
> --
[
https://issues.apache.org/jira/browse/FLINK-26446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502138#comment-17502138
]
Chesnay Schepler commented on FLINK-26446:
--
Not sure about removing the connect
LadyForest commented on a change in pull request #28:
URL: https://github.com/apache/flink-table-store/pull/28#discussion_r820485512
##
File path:
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/LocalCommitterOperator.java
##
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-26352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-26352:
-
Fix Version/s: 1.14.5
> Missing license header in WebUI source files
> -
[
https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502108#comment-17502108
]
Yao Zhang edited comment on FLINK-26498 at 3/7/22, 8:45 AM:
[
https://issues.apache.org/jira/browse/FLINK-26370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26370:
---
Labels: pull-request-available (was: )
> Make Flink cluster communication asynchronous
> --
[
https://issues.apache.org/jira/browse/FLINK-26352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-26352:
--
Also affects 1.14.x
> Missing license header in WebUI source files
>
Gyula Fora created FLINK-26513:
--
Summary: Document operator helm chart
Key: FLINK-26513
URL: https://issues.apache.org/jira/browse/FLINK-26513
Project: Flink
Issue Type: Sub-task
Compo
LadyForest commented on a change in pull request #28:
URL: https://github.com/apache/flink-table-store/pull/28#discussion_r820487023
##
File path:
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/LocalCommitterOperator.java
##
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-26352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-26352:
-
Affects Version/s: 1.14.3
1.15.0
> Missing license header in WebU
zentol merged pull request #18834:
URL: https://github.com/apache/flink/pull/18834
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-26229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-26229.
Resolution: Fixed
master: 0546cb0326e14fd0bce8e45a1c6bd0d0abd56606
> [JUnit5 Migration] M
zentol merged pull request #18835:
URL: https://github.com/apache/flink/pull/18835
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
LadyForest commented on a change in pull request #28:
URL: https://github.com/apache/flink-table-store/pull/28#discussion_r820487023
##
File path:
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/LocalCommitterOperator.java
##
@@ -0,
flinkbot edited a comment on pull request #18881:
URL: https://github.com/apache/flink/pull/18881#issuecomment-1047890065
## CI report:
* 0675ae6bcdfe59530e80da1e22ae9cc3df69fc03 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-26230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-26230.
Resolution: Fixed
master: ecf67c67dbcf633c4533f8cb719f32512c19d0ce
> [JUnit5 Migration] M
flinkbot edited a comment on pull request #18882:
URL: https://github.com/apache/flink/pull/18882#issuecomment-1047890260
## CI report:
* 319c71335cd8a940e39c12a3633d14280e836c64 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-26514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26514:
Labels: test-stability (was: )
> YARNSessionFIFOITCase.testDetachedMode failed on azure
> ---
Yun Gao created FLINK-26514:
---
Summary: YARNSessionFIFOITCase.testDetachedMode failed on azure
Key: FLINK-26514
URL: https://issues.apache.org/jira/browse/FLINK-26514
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26501:
Priority: Critical (was: Major)
> Quickstarts Scala nightly end-to-end test failed on azure due to checkp
[
https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502149#comment-17502149
]
Yun Gao commented on FLINK-26501:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
[
https://issues.apache.org/jira/browse/FLINK-26352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502150#comment-17502150
]
Joe Moser commented on FLINK-26352:
---
but is it done for 1.15?
so we could remove it fr
[
https://issues.apache.org/jira/browse/FLINK-26456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502151#comment-17502151
]
Yun Gao commented on FLINK-26456:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
curcur commented on a change in pull request #18964:
URL: https://github.com/apache/flink/pull/18964#discussion_r820493182
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@@ -
flinkbot edited a comment on pull request #18881:
URL: https://github.com/apache/flink/pull/18881#issuecomment-1047890065
## CI report:
* 0675ae6bcdfe59530e80da1e22ae9cc3df69fc03 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Yun Gao created FLINK-26515:
---
Summary: RetryingExecutorTest.testTimeout failed on azure
Key: FLINK-26515
URL: https://issues.apache.org/jira/browse/FLINK-26515
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #18882:
URL: https://github.com/apache/flink/pull/18882#issuecomment-1047890260
## CI report:
* 319c71335cd8a940e39c12a3633d14280e836c64 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
zoucao commented on a change in pull request #18966:
URL: https://github.com/apache/flink/pull/18966#discussion_r820493792
##
File path: docs/content.zh/docs/dev/table/data_stream_api.md
##
@@ -596,13 +596,13 @@ pipeline or a statement set:
```java
// execute with explicit
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18356:
-
Priority: Critical (was: Blocker)
> flink-table-planner Exit code 137 returned from pro
echauchot commented on pull request #18610:
URL: https://github.com/apache/flink/pull/18610#issuecomment-1060353150
@XComp thanks for your review. I addressed your comments and squashed as
requested. PTAL
--
This is an automated message from the Apache Git Service.
To respond to the
echauchot commented on pull request #18610:
URL: https://github.com/apache/flink/pull/18610#issuecomment-1060354906
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specif
curcur commented on a change in pull request #18964:
URL: https://github.com/apache/flink/pull/18964#discussion_r820496629
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@@ -
[
https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502156#comment-17502156
]
Yun Tang commented on FLINK-26490:
--
I am still thinking of whther there are places left
[
https://issues.apache.org/jira/browse/FLINK-22710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502155#comment-17502155
]
Yun Gao commented on FLINK-22710:
-
[https://dev.azure.com/apache-flink/apache-flink/_bui
flinkbot edited a comment on pull request #18610:
URL: https://github.com/apache/flink/pull/18610#issuecomment-1028011200
## CI report:
* Unknown: [CANCELED](TBD)
* 02d9bec4d251c09a1e75eb4d5c6edb751293c54e UNKNOWN
Bot commands
The @flinkbot bot supports the fo
fapaul commented on pull request #18928:
URL: https://github.com/apache/flink/pull/18928#issuecomment-1060363802
@zentol do you have time to look at this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above
twalthr commented on a change in pull request #18980:
URL: https://github.com/apache/flink/pull/18980#discussion_r820476699
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java
##
@@ -185,6 +184,7 @@ private JobExecutionResult
[
https://issues.apache.org/jira/browse/FLINK-25971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francesco Guardiani closed FLINK-25971.
---
Resolution: Not A Problem
> org.apache.flink.table.planner.plan.nodes.exec.serde.Jso
rkhachatryan commented on a change in pull request #18964:
URL: https://github.com/apache/flink/pull/18964#discussion_r820504848
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
#
LadyForest commented on a change in pull request #28:
URL: https://github.com/apache/flink-table-store/pull/28#discussion_r820505949
##
File path:
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/LocalCommitterOperator.java
##
@@ -0,
flinkbot edited a comment on pull request #18956:
URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247
## CI report:
* 293cf5fb5b0da4b4be5a44e9b506c2f24c42b1ec Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
twalthr closed pull request #18372:
URL: https://github.com/apache/flink/pull/18372
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubsc
[
https://issues.apache.org/jira/browse/FLINK-25659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25659.
Fix Version/s: 1.15.0
Resolution: Fixed
Fixed in master: dc63e1247765c45d1d2dcf6cc419c4aaf9
leonardBang commented on a change in pull request #18966:
URL: https://github.com/apache/flink/pull/18966#discussion_r820509438
##
File path: docs/content.zh/docs/dev/table/data_stream_api.md
##
@@ -596,13 +596,13 @@ pipeline or a statement set:
```java
// execute with expl
[
https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-26018:
--
Assignee: (was: Qingsheng Ren)
> Unnecessary late events when using the new Kafka
Fabian Paul created FLINK-26516:
---
Summary: Sink V2 is not state compatible with Sink V1
Key: FLINK-26516
URL: https://issues.apache.org/jira/browse/FLINK-26516
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502163#comment-17502163
]
Piotr Nowojski commented on FLINK-26018:
After an offline discussion we agreed f
[
https://issues.apache.org/jira/browse/FLINK-26516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-26516:
---
Assignee: Fabian Paul
> Sink V2 is not state compatible with Sink V1
>
zoucao commented on pull request #18966:
URL: https://github.com/apache/flink/pull/18966#issuecomment-1060376299
Well, I will append one commit to fix it in this pr as far as possible.
2022年3月7日 下午5:15，Leonard Xu ***@***.**@***.***>> 写道：
@leonardBang commented on th
flinkbot edited a comment on pull request #18986:
URL: https://github.com/apache/flink/pull/18986#issuecomment-1059778170
## CI report:
* f203c72488547005c4a1620e2d519273702c3510 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
zoucao removed a comment on pull request #18966:
URL: https://github.com/apache/flink/pull/18966#issuecomment-1060376299
Well, I will append one commit to fix it in this pr as far as possible.
2022年3月7日 下午5:15，Leonard Xu ***@***.**@***.***>> 写道：
@leonardBang comment
zoucao commented on a change in pull request #18966:
URL: https://github.com/apache/flink/pull/18966#discussion_r820513195
##
File path: docs/content.zh/docs/dev/table/data_stream_api.md
##
@@ -596,13 +596,13 @@ pipeline or a statement set:
```java
// execute with explicit
zoucao commented on a change in pull request #18966:
URL: https://github.com/apache/flink/pull/18966#discussion_r820513195
##
File path: docs/content.zh/docs/dev/table/data_stream_api.md
##
@@ -596,13 +596,13 @@ pipeline or a statement set:
```java
// execute with explicit
[
https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502164#comment-17502164
]
hehuiyuan commented on FLINK-26498:
---
[~jark] ,
Hi [~paul8263] I can fix by my
[
https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26505:
-
Summary: Support non equality condition for left semi join in Hive dialect
(was: Support non equality c
pnowojski commented on a change in pull request #18989:
URL: https://github.com/apache/flink/pull/18989#discussion_r820521747
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@
pnowojski commented on a change in pull request #18989:
URL: https://github.com/apache/flink/pull/18989#discussion_r820521747
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@
Lijie Wang created FLINK-26517:
--
Summary: Normalize the decided parallelism to power of 2 when
using adaptive batch scheduler
Key: FLINK-26517
URL: https://issues.apache.org/jira/browse/FLINK-26517
Proje
[
https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-26517:
---
Description: As describe in FLINK-26330, in order to make the number of
subpartitoins evenly consume
[
https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-26517:
---
Priority: Blocker (was: Major)
> Normalize the decided parallelism to power of 2 when using adaptiv
twalthr commented on a change in pull request #18878:
URL: https://github.com/apache/flink/pull/18878#discussion_r820526572
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/IntervalJoinSpecJsonSerdeTest.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26505:
-
Description:
It'll throw exception "java.lang.IndexOutOfBoundsException: Index: 0, Size: 0"
with the fo
hehuiyuan opened a new pull request #18993:
URL: https://github.com/apache/flink/pull/18993
## What is the purpose of the change
When a record arrived and the window is not exist, it will emit the
window result immediately.
`if (triggerTime(window) <= ctx.getC
flinkbot edited a comment on pull request #18610:
URL: https://github.com/apache/flink/pull/18610#issuecomment-1028011200
## CI report:
* Unknown: [CANCELED](TBD)
* 02d9bec4d251c09a1e75eb4d5c6edb751293c54e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462
flinkbot edited a comment on pull request #18990:
URL: https://github.com/apache/flink/pull/18990#issuecomment-1060259607
## CI report:
* f8c839ffc97863294ca44f34ab6801c219ecbb97 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
luoyuxia opened a new pull request #18994:
URL: https://github.com/apache/flink/pull/18994
… in Hive dialect.
## What is the purpose of the change
The pr is try to fix the IndexOutOfBoundsException that when there's only `1
= 1` in semi join cluster like `select * from a l
alpreu closed pull request #18953:
URL: https://github.com/apache/flink/pull/18953
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
1 - 100 of 582 matches
Mail list logo
