apache/flink issues and pull requests

#24166 - [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty

Pull Request - State: closed - Opened by lincoln-lil 8 months ago - 1 comment

#24165 - [FLINK-34194][ci] Updates test CI container to be based on Ubuntu 22.04

Pull Request - State: open - Opened by XComp 8 months ago - 2 comments

#24164 - [hotfix][table] Avoid KeyedLookupJoinWrapper sending duplicate delete record for left join when state expired

Pull Request - State: closed - Opened by lincoln-lil 8 months ago - 1 comment

#24163 - [FLINK-33728] Do not rewatch when KubernetesResourceManagerDriver wat…

Pull Request - State: open - Opened by zhougit86 8 months ago - 4 comments

#24162 - [FLINK-34100][table] Support session window table function without pulling up with window agg

Pull Request - State: closed - Opened by xuyangzhong 8 months ago - 1 comment

#24161 - [FLINK-34222][table-planner] Supports mini-batch for streaming regular join

Pull Request - State: closed - Opened by xishuaidelin 8 months ago - 9 comments

#24160 - [FLINK-34221][table-runtime] Introduce MiniBatchStreamingJoinOperator

Pull Request - State: closed - Opened by xishuaidelin 8 months ago - 1 comment

#24159 - [FLINK-34220][table-runtime] Introduce BufferBundle for minibatch join

Pull Request - State: closed - Opened by xishuaidelin 8 months ago - 6 comments

#24158 - [FLINK-34174][runtime] Remove SlotMatchingStrategy related logic

Pull Request - State: closed - Opened by RocMarshal 8 months ago - 3 comments

#24157 - [Draft] Change the default conf file to standard yaml file.

Pull Request - State: closed - Opened by JunRuiLee 8 months ago - 1 comment

#24156 - [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function

Pull Request - State: open - Opened by jeyhunkarimov 8 months ago - 7 comments

#24155 - [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause

Pull Request - State: open - Opened by jnh5y 8 months ago - 4 comments

#24154 - [FLINK-34000] Implement restore tests for IncrementalGroupAgg node

Pull Request - State: open - Opened by bvarghese1 8 months ago - 1 comment

#24154 - [FLINK-34000] Implement restore tests for IncrementalGroupAgg node

Pull Request - State: open - Opened by bvarghese1 8 months ago - 1 comment

#24153 - [FLINK-33975] Tests for the new Sink V2 transformations

Pull Request - State: open - Opened by pvary 8 months ago - 1 comment

#24153 - [FLINK-33975] Tests for the new Sink V2 transformations

Pull Request - State: closed - Opened by pvary 8 months ago - 1 comment

#24152 - [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty

Pull Request - State: closed - Opened by lincoln-lil 8 months ago - 1 comment

#24151 - [FLINK-34225][runtime] Fix bugs in input channel multiplexing logic

Pull Request - State: closed - Opened by yunfengzhou-hub 8 months ago - 3 comments

#24151 - [hotfix][runtime] Fix race conditions in UnionResultSubpartitionView

Pull Request - State: open - Opened by yunfengzhou-hub 8 months ago - 1 comment

#24150 - [FLINK-34048][table] Support session window agg in table runtime instead of using legacy group window agg op

Pull Request - State: closed - Opened by xuyangzhong 8 months ago - 1 comment

#24149 - [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect, back port to 1.18

Pull Request - State: closed - Opened by yunfan123 8 months ago - 2 comments

#24149 - [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect, back port to 1.18

Pull Request - State: open - Opened by yunfan123 8 months ago - 1 comment

#24148 - [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect, back port to 1.17

Pull Request - State: closed - Opened by yunfan123 8 months ago - 1 comment

#24148 - [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect, back port to 1.17

Pull Request - State: open - Opened by yunfan123 8 months ago - 1 comment

#24147 - [hotfix] peekNextBufferSubpartitionId shouldn't throw UnsupportedDataTypeException

Pull Request - State: closed - Opened by reswqa 8 months ago - 2 comments

#24147 - [hotfix] peekNextBufferSubpartitionId shouldn't throw UnsupportedDataTypeException

Pull Request - State: closed - Opened by reswqa 8 months ago - 2 comments

#24146 - [FLINK-34149][Runtime/Checkpointing] Fix SplitEnumeratorContext compatibility issue

Pull Request - State: closed - Opened by yunfengzhou-hub 8 months ago - 3 comments