apache/flink issues and pull requests

#24048 - [hotfix] Remove redundant lazy initialization of LazyInitializedCoordinatorContext.

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

#24047 - fix: missing serialVersionUID of serializable classes

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

#24046 - [FLINK-34030][changelog] Introduce periodic-materialize.enabled to enable/disable periodic materialization

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

#24045 - [FLINK-34013][runtime] Remove duplicated stopProfiling() in `ProfilingService`

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

#24044 - [FLINK-33896] Implement restore tests for Correlate node

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

#24043 - [FLINK-34012][python] Fix mypy error

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

#24042 - [FLINK-33988][configuration] Fix the invalid configuration when using initialized root logger level on yarn deployment mode

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

#24041 - [FLINK-33434][runtime-web] Support invoke async-profiler on TaskManager via REST API

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

#24040 - [FLINK-33738][Scheduler] Make exponential-delay restart-strategy the default restart strategy

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

#24039 - [FLINK-34001][docs][table] Fix ambiguous document description towards the default value for configuring operator-level state TTL

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

#24038 - [hotfix][docs] fix typo in ddl data type

Pull Request - State: open - Opened by imkew 11 months ago - 1 comment

#24037 - [hotfix][docs] fix typo in classloading option in Debugging Classloading

Pull Request - State: closed - Opened by slankka 11 months ago - 2 comments

#24036 - [hotfix][docs] Fix SQL statement is incomplete

Pull Request - State: closed - Opened by imkew 11 months ago - 1 comment

#24035 - [FLINK-33817][flink-protobuf] Set ReadDefaultValues=False by default in proto3 for performance improvement

Pull Request - State: open - Opened by sharath1709 11 months ago - 4 comments

#24034 - [FLINK-34005] Implement restore tests for MiniBatchAssigner node

Pull Request - State: closed - Opened by bvarghese1 11 months ago - 2 comments

#24033 - [FLINK-33996][table-planner]: Avoid merging projects if leads to redundant computation

Pull Request - State: open - Opened by jeyhunkarimov 11 months ago - 2 comments

#24032 - [FLINK-34004] Harden TestingCheckpointIDCounter

Pull Request - State: open - Opened by zentol 11 months ago - 1 comment

#24031 - [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery (rebased)

Pull Request - State: open - Opened by StefanRRichter 11 months ago - 3 comments

#24030 - [FLINK-20281][table] support consuming cdc stream about window tvf aggregate

Pull Request - State: closed - Opened by xuyangzhong 11 months ago - 2 comments

#24029 - [FLINK-33759] [flink-parquet] Add support for nested array with row type

Pull Request - State: open - Opened by ukby1234 11 months ago - 2 comments

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

Pull Request - State: closed - Opened by bvarghese1 11 months ago - 1 comment

#24027 - [FLINK-33009][release] Disable binary compatibility check in master branch and only enable it in the release branch

Pull Request - State: open - Opened by WencongLiu 11 months ago - 2 comments

#24026 - [FLINK-33982][core] Introduce new config options for Batch Job Recovery

Pull Request - State: open - Opened by JunRuiLee 11 months ago - 2 comments

#24025 - [FLINK-33980][core] Reorganize job configuration

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

#24024 - [FLINK-33979] Implement restore tests for TableSink node

Pull Request - State: closed - Opened by bvarghese1 11 months ago - 2 comments

#24023 - [FLINK-33697][state][metrics] Trace RocksDBIncremental remote files download time

Pull Request - State: closed - Opened by pnowojski 11 months ago - 4 comments

#24022 - [FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API

Pull Request - State: closed - Opened by pvary 11 months ago - 8 comments

#24022 - [FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API

Pull Request - State: open - Opened by pvary 11 months ago - 3 comments

#24021 - [FLINK-33976] AdaptiveScheduler cooldown period should be taken from JobManager's configuration

Pull Request - State: closed - Opened by dmvk 11 months ago - 4 comments

#24020 - [FLINK-33969] Implement restore tests for TableSourceScan node

Pull Request - State: closed - Opened by bvarghese1 11 months ago - 3 comments

#24019 - [FLINK-33968][runtime] Advance the calculation of num of subpartitions to the time of initializing execution job vertex

Pull Request - State: closed - Opened by wanglijie95 11 months ago - 2 comments

#24018 - [hotfix] Update copyright NOTICE year to 2024

Pull Request - State: closed - Opened by caicancai 11 months ago - 2 comments

#24018 - [hotfix] Update copyright NOTICE year to 2024

Pull Request - State: closed - Opened by caicancai 11 months ago - 2 comments

#24017 - [hotfix] Update copyright NOTICE year to 2024

Pull Request - State: closed - Opened by caicancai 11 months ago - 3 comments

#24017 - [hotfix] Update copyright NOTICE year to 2024

Pull Request - State: closed - Opened by caicancai 11 months ago - 3 comments

#24016 - [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain

Pull Request - State: open - Opened by Jiabao-Sun 11 months ago - 1 comment

#24016 - [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain

Pull Request - State: open - Opened by Jiabao-Sun 11 months ago - 1 comment

#24015 - [FLINK-33951][table] Use aggCallNeedRetractions instead of needRetrac…

Pull Request - State: open - Opened by liuyongvs 11 months ago - 3 comments

#24014 - [FLINK-27756] Refactor Async Sink send gauge test

Pull Request - State: closed - Opened by vahmed-hamdy 11 months ago - 1 comment

#24013 - [hotfix] [docs, RestartStrategyOptions]: update the default value of "restart-strategy.fixed-delay.attempts" to 1 in docs

Pull Request - State: open - Opened by niliushall 11 months ago - 2 comments

#24013 - [hotfix] [docs, RestartStrategyOptions]: update the default value of "restart-strategy.fixed-delay.attempts" to 1 in docs

Pull Request - State: open - Opened by niliushall 11 months ago - 2 comments

#24012 - [FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks

Pull Request - State: open - Opened by 1996fanrui 11 months ago - 5 comments

#24012 - [FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 5 comments

#24011 - [FLINK-33947][configuration] Fix bugs about prefix attribute in the DelegatingConfiguration class.

Pull Request - State: closed - Opened by RocMarshal 11 months ago - 2 comments

#24010 - [FLINK-33947][configuration] Fix bugs about prefix attribute in the DelegatingConfiguration class.

Pull Request - State: closed - Opened by RocMarshal 11 months ago - 1 comment

#24010 - [FLINK-33947][configuration] Fix bugs about prefix attribute in the DelegatingConfiguration class.

Pull Request - State: closed - Opened by RocMarshal 11 months ago - 1 comment

#24009 - [FLINK-33958] Implement restore tests for IntervalJoin node

Pull Request - State: open - Opened by bvarghese1 11 months ago - 3 comments

#24008 - [BP-1.18] [FLINK-33863][checkpoint] Fix restoring compressed operator state

Pull Request - State: closed - Opened by ruibinx 11 months ago - 1 comment

#24007 - [FLINK-33882] UT/IT for checkpointing statistics

Pull Request - State: open - Opened by zhutong6688 11 months ago - 1 comment

#24007 - [FLINK-33882] UT/IT for checkpointing statistics

Pull Request - State: open - Opened by zhutong6688 11 months ago - 1 comment

#24006 - [FLINK-32175] [docs-zh] translate doc(datagen.md) into chinese

Pull Request - State: open - Opened by niliushall 11 months ago - 2 comments

#24005 - [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 2 comments

#24005 - [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 2 comments

#24004 - [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 1 comment

#24004 - [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 1 comment

#24003 - [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 9 comments

#24003 - [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging

Pull Request - State: open - Opened by 1996fanrui 11 months ago - 4 comments

#24002 - [FLINK-33518] Implement restore tests for WatermarkAssigner node

Pull Request - State: closed - Opened by bvarghese1 11 months ago - 1 comment

#24001 - [FLINK-33947][configuration] Fix bugs about the prefix attribute in the DelegatingConfiguration class.

Pull Request - State: closed - Opened by RocMarshal 11 months ago - 1 comment

#24001 - [FLINK-33947][configuration] Fix bugs about the prefix attribute in the DelegatingConfiguration class.

Pull Request - State: closed - Opened by RocMarshal 11 months ago - 1 comment

#24000 - [FLINK-33950][table] Update max aggregate functions to new type system

Pull Request - State: open - Opened by liuyongvs 11 months ago - 1 comment

#24000 - [FLINK-33950][table] Update max aggregate functions to new type system

Pull Request - State: open - Opened by liuyongvs 11 months ago - 1 comment

#23999 - [FLINK-33938][runtime-web] Correct implicit coercions in relational operators to adopt typescript 5.0

Pull Request - State: closed - Opened by Laffery 11 months ago - 2 comments

#23998 - [FLINK-33681] Reuse input/output metrics of SourceOperator/SinkWriterOperator for task

Pull Request - State: open - Opened by X-czh 11 months ago - 1 comment

#23998 - [FLINK-33681] Reuse input/output metrics of SourceOperator/SinkWriterOperator for task

Pull Request - State: open - Opened by X-czh 11 months ago - 1 comment

#23997 - [FLINK-33945][table] Cleanup usage of deprecated org.apache.flink.tab…

Pull Request - State: open - Opened by liuyongvs 11 months ago - 1 comment

#23997 - [FLINK-33945][table] Cleanup usage of deprecated org.apache.flink.tab…

Pull Request - State: open - Opened by liuyongvs 11 months ago - 1 comment

#23996 - [FLINK-33948][table] Cleanup usage of deprecated org.apache.flink.tab…

Pull Request - State: open - Opened by liuyongvs 11 months ago - 1 comment

#23995 - [hotfix] Static import removed

Pull Request - State: open - Opened by Shrey-Viradiya 11 months ago - 1 comment

#23995 - [hotfix] Static import removed

Pull Request - State: open - Opened by Shrey-Viradiya 11 months ago - 1 comment

#23994 - [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 3 comments

#23994 - [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 3 comments

#23993 - Draft

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

#23992 - [FLINK-33939][runtime-web] Remove the husky dependency to make sure the global hooks work as expected

Pull Request - State: closed - Opened by simplejason 11 months ago - 1 comment

#23991 - [FLINK-33941][table-planner] use field index instead of field name about window time column

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

#23990 - [FLINK-33784][table] Support Configuring CatalogStoreFactory via StreamExecutionEnvironment

Pull Request - State: open - Opened by hackergin 11 months ago - 1 comment

#23989 - [FLINK-33856][checkpointing] Add metrics for interaction performance with external storage system in the process of checkpoint making

Pull Request - State: open - Opened by hejufang 11 months ago - 1 comment

#23988 - [FLINK-31650][metrics][rest][BP-1.17] Remove transient metrics for subtasks in terminal state

Pull Request - State: closed - Opened by X-czh 11 months ago - 2 comments

#23987 - [FLINK-33935][checkpoint] Improve the default value logic related to `execution.checkpointing.tolerable-failed-checkpoints` and `state.backend.type`

Pull Request - State: closed - Opened by 1996fanrui 11 months ago - 1 comment

#23986 - [FLINK-33932][checkpointing] Add retry mechanism in RocksDBStateUploader

Pull Request - State: open - Opened by xiangyuf 11 months ago - 1 comment

#23985 - [FLINK-30535][Test] Customize TtlTimeProvider in state benchmarks

Pull Request - State: closed - Opened by Zakelly 11 months ago - 1 comment

#23984 - [FLINK-33792] Generate the same code for the same logic

Pull Request - State: closed - Opened by zoudan 11 months ago - 16 comments

#23983 - [FLINK-33927][table] Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS)

Pull Request - State: open - Opened by liyubin117 11 months ago - 1 comment

#23982 - [BP-1.18][FLINK-27082][ci] Adds a github-actions profile that disables certain tests that do not run in GHA

Pull Request - State: closed - Opened by XComp 11 months ago - 2 comments

#23981 - [hotfix] [docs] Update README.md to remove Maven

Pull Request - State: closed - Opened by asafm 11 months ago - 5 comments

#23980 - [FLINK-33921][table] Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

Pull Request - State: open - Opened by liyubin117 11 months ago - 3 comments

#23979 - [BP-1.18][FLINK-33902][ci] Adds -legacy to openssl command

Pull Request - State: closed - Opened by XComp 11 months ago - 2 comments

#23978 - Test

Pull Request - State: closed - Opened by WencongLiu 11 months ago - 1 comment

#23977 - [FLINK-33414] Fix the unstable test MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot

Pull Request - State: closed - Opened by jiangxin369 11 months ago - 3 comments

#23976 - [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21

Pull Request - State: closed - Opened by Jiabao-Sun 11 months ago - 4 comments

#23975 - [FLINK-34027] Introduces AsyncScalarFunction as a new UDF type

Pull Request - State: closed - Opened by AlanConfluent 11 months ago - 7 comments

#23974 - [FLINK-32850][flink-runtime][JUnit5 Migration] The io.network.partition package of flink-runtime module

Pull Request - State: closed - Opened by Jiabao-Sun 11 months ago - 4 comments