Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]

bvarghese1 commented on code in PR #26230: URL: https://github.com/apache/flink/pull/26230#discussion_r1978608886 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala: ## @@ -287,6 +287,39

Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]

bvarghese1 commented on code in PR #26230: URL: https://github.com/apache/flink/pull/26230#discussion_r1978609329 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala: ## @@ -287,6 +287,39

[jira] [Commented] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry

[ https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932145#comment-17932145 ] Yunfeng Zhou commented on FLINK-35810: -- Hi all, I reproduced the bug locally and ra

Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]

kurtostfeld commented on code in PR #25896: URL: https://github.com/apache/flink/pull/25896#discussion_r1978576867 ## flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/utils/AvroKryoSerializerUtils.java: ## @@ -106,11 +105,55 @@ public void write(Kryo kryo, Ou

[jira] [Closed] (FLINK-37034) [Release-2.0] Select executing Release Manager

[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-37034. Resolution: Done > [Release-2.0] Select executing Release Manager > -

[jira] [Updated] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry

[ https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35810: --- Priority: Critical (was: Blocker) > OOM in > AsyncWaitOperatorTest.testProcessingTimeRepeatedCompl

[jira] [Closed] (FLINK-37036) [Release-2.0] Prepare RC0 release

[ https://issues.apache.org/jira/browse/FLINK-37036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-37036. Resolution: Done > [Release-2.0] Prepare RC0 release > - > >

[jira] [Closed] (FLINK-37035) [Release-2.0] Create a release branch

[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-37035. Resolution: Done > [Release-2.0] Create a release branch > --

[jira] [Created] (FLINK-37415) [Release-2.0] Prepare RC1 release

Xintong Song created FLINK-37415: Summary: [Release-2.0] Prepare RC1 release Key: FLINK-37415 URL: https://issues.apache.org/jira/browse/FLINK-37415 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-37038) [Release-2.0] Cross team testing

[ https://issues.apache.org/jira/browse/FLINK-37038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-37038. Resolution: Done > [Release-2.0] Cross team testing > > >

[PR] [hotfix] make SplitFetcherManager honor job configuration [flink-connector-aws]

lukaszkrawiec opened a new pull request, #192: URL: https://github.com/apache/flink-connector-aws/pull/192 ## Purpose of the change SplitFetcherManager relies on correct Configuration be passed to its constructor such that it can honor flink options such as - ALLOW_UNALIGNED_SOURC

Re: [PR] [hotfix] make SplitFetcherManager honor job configuration [flink-connector-aws]

boring-cyborg[bot] commented on PR #192: URL: https://github.com/apache/flink-connector-aws/pull/192#issuecomment-2696348311 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is a

Re: [PR] [FLINK-35810] Fix AsyncWaitOperatorTest missing endInput bug [flink]

flinkbot commented on PR #26241: URL: https://github.com/apache/flink/pull/26241#issuecomment-2696127884 ## CI report: * e340d6112bf22608eefd16a4341b91f2d5683835 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36437) Hive connector failed to compile with JDK 11

[ https://issues.apache.org/jira/browse/FLINK-36437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36437: --- Priority: Critical (was: Blocker) > Hive connector failed to compile with JDK 11 >

<    1   2