apache/flink issues and pull requests

#24195 - [FLINK-34117][bugfix][table] Fix CompactCoordinator data loss upon termination

Pull Request - State: closed - Opened by afedulov 10 months ago - 1 comment

#24194 - [FLINK-34232][dist] Fix unsupported env.java.home in configuration file.

Pull Request - State: closed - Opened by JunRuiLee 10 months ago - 2 comments

#24193 - [FLINK-34122][core] Deprecate old serialization config methods and options

Pull Request - State: closed - Opened by X-czh 10 months ago - 3 comments

#24192 - [FLINK-34231][doc] fix typo in doc

Pull Request - State: closed - Opened by gyang94 10 months ago - 1 comment

#24191 - [FLINK-34228] Add long UTF serializer/deserializer

Pull Request - State: open - Opened by pvary 10 months ago - 5 comments

#24190 - [FLINK-34230][doc] Add -Pskip-webui-build to the config doc generation command

Pull Request - State: closed - Opened by X-czh 10 months ago - 1 comment

#24189 - [DRAFT] new implementation of FLIP-403

Pull Request - State: open - Opened by KarmaGYZ 10 months ago - 1 comment

#24188 - [FLINK-32684][rpc] Introduces RpcOptions and deprecates AkkaOptions

Pull Request - State: closed - Opened by XComp 10 months ago - 4 comments

#24187 - [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig and TypeInformation to SerializerConfig

Pull Request - State: closed - Opened by reswqa 10 months ago - 3 comments

#24186 - [FLINK-34145][connector/filesystem] support dynamic source parallelism inference in batch jobs

Pull Request - State: closed - Opened by SinBex 10 months ago - 7 comments

#24185 - [FLINK-34223][dist] Introduce a migration tool to transfer legacy config file to new config file.

Pull Request - State: closed - Opened by JunRuiLee 10 months ago - 5 comments

#24184 - [FLINK-34144][docs] Update the documentation about dynamic source parallelism inference

Pull Request - State: closed - Opened by SinBex 10 months ago - 2 comments

#24183 - [FLINK-34058][table] Support optional parameters for named parameters

Pull Request - State: closed - Opened by hackergin 10 months ago - 2 comments

#24182 - [FLINK-34120][core] Introduce unified serialization config option for all Kryo, POJO and customized serializers

Pull Request - State: closed - Opened by X-czh 10 months ago - 4 comments

#24181 - [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption

Pull Request - State: open - Opened by Zakelly 10 months ago - 3 comments

#24180 - [FLINK-34209] Migrate FileSink to the new SinkV2 API

Pull Request - State: closed - Opened by pvary 10 months ago - 3 comments

#24179 - [FLINK-34053][table-planner] Support state ttl hint for group aggregate

Pull Request - State: closed - Opened by xuyangzhong 10 months ago - 3 comments

#24178 - [FLINK-34115][table-planner] Fix unstable TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate

Pull Request - State: closed - Opened by LadyForest 10 months ago - 2 comments

#24177 - [FLINK-33577][dist] Change the default config file to config.yaml in flink-dist.

Pull Request - State: closed - Opened by JunRuiLee 10 months ago - 4 comments

#24176 - [hotfix] Apply spotless

Pull Request - State: closed - Opened by snuyanzin 10 months ago - 2 comments

#24175 - [FLINK-31472] Disable Intermittently failing throttling test

Pull Request - State: open - Opened by vahmed-hamdy 10 months ago - 4 comments

#24174 - [FLINK-34208] Migrate SinkV1Adapter to the new SinkV2 API

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

#24173 - [FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled

Pull Request - State: open - Opened by mayuehappy 10 months ago - 14 comments

#24172 - [FLINK-34115][table-planner] Fix unstable TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate

Pull Request - State: closed - Opened by LadyForest 10 months ago - 1 comment

#24171 - [FLINK-34196][Connectors][FLIP-389] Annotate SingleThreadFetcherManager as PublicEvolving.

Pull Request - State: closed - Opened by loserwang1024 10 months ago - 4 comments

#24170 - [FLINK-34143] Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism`

Pull Request - State: closed - Opened by SinBex 10 months ago - 2 comments

#24169 - [FLINK-34190][FLIP-416][checkpoint] Deprecate RestoreMode#LEGACY

Pull Request - State: closed - Opened by Zakelly 10 months ago - 5 comments

#24168 - [FLINK-34199] Add tracing for durations of rescaling/restoring RocksDB incremental checkpoints from downloaded and local state

Pull Request - State: open - Opened by StefanRRichter 10 months ago - 5 comments

#24167 - [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 10 months ago - 1 comment

#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 10 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 10 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 10 months ago - 1 comment

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

Pull Request - State: open - Opened by zhougit86 10 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 10 months ago - 1 comment

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Pull Request - State: closed - Opened by pvary 10 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 10 months ago - 1 comment

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

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

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

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

#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 10 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: open - Opened by yunfan123 10 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 10 months ago - 2 comments

#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 10 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 10 months ago - 1 comment

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

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

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

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

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

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