Ecosyste.ms: Issues
An open API service for providing issue and pull request metadata for open source projects.
GitHub / apache/flink issues and pull requests
#25261 - [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time
Pull Request -
State: open - Opened by XComp about 1 month ago
- 2 comments
Labels: component=Runtime/Coordination, component=Runtime/Configuration, component=API/DataStream
#25260 - [FLINK-36168] [runtime] AdaptiveSchedulerTest doesn't follow the production lifecycle
Pull Request -
State: closed - Opened by ztison about 1 month ago
- 2 comments
Labels: component=<none>
#25260 - [FLINK-36168] [runtime] AdaptiveSchedulerTest doesn't follow the production lifecycle
Pull Request -
State: closed - Opened by ztison about 1 month ago
- 2 comments
Labels: component=<none>
#25259 - [FLINK-35177] Fix DataGen Connector documentation
Pull Request -
State: closed - Opened by morozov about 1 month ago
- 1 comment
Labels: component=Documentation
#25259 - [FLINK-35177] Fix DataGen Connector documentation
Pull Request -
State: closed - Opened by morozov about 1 month ago
- 1 comment
Labels: component=Documentation
#25258 - [FLINK-36160] Support hive advanced configuration
Pull Request -
State: open - Opened by zhuanshenbsj1 about 1 month ago
- 2 comments
Labels: component=Connectors/Hive
#25258 - [FLINK-36160] Support hive advanced configuration
Pull Request -
State: open - Opened by zhuanshenbsj1 about 1 month ago
- 1 comment
Labels: component=Connectors/Hive
#25257 - [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level
Pull Request -
State: closed - Opened by lexluo09 about 1 month ago
- 28 comments
Labels: component=<none>
#25257 - [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level
Pull Request -
State: closed - Opened by lexluo09 about 1 month ago
- 28 comments
Labels: component=<none>
#25256 - [FLINK-36249][streaming-java] Remove RestartStrategy-related configuration getters/setters that return/set complex Java objects.
Pull Request -
State: closed - Opened by JunRuiLee about 1 month ago
- 1 comment
Labels: component=API/Core
#25253 - [FLINK-35579] update frocksdb version to v8.10.0
Pull Request -
State: closed - Opened by mayuehappy about 1 month ago
- 8 comments
Labels: component=Runtime/StateBackends
#25253 - [FLINK-35579] update frocksdb version to v8.10.0
Pull Request -
State: closed - Opened by mayuehappy about 1 month ago
- 8 comments
Labels: component=Runtime/StateBackends
#25252 - [FLINK-26944][table] Add the built-in function ADD_MONTHS
Pull Request -
State: open - Opened by dylanhz about 1 month ago
- 1 comment
Labels: component=TableSQL/API
#25252 - [FLINK-26944][table] Add the built-in function ADD_MONTHS
Pull Request -
State: open - Opened by dylanhz about 1 month ago
- 1 comment
Labels: component=TableSQL/API
#25250 - [FLINK-14068][core] Removes deprecated org.apache.flink.api.common.time.Time
Pull Request -
State: open - Opened by XComp about 1 month ago
- 7 comments
Labels: component=Runtime/Coordination, component=Runtime/Configuration, component=API/DataStream
#25250 - [FLINK-14068][core] Removes deprecated org.apache.flink.api.common.time.Time
Pull Request -
State: closed - Opened by XComp about 1 month ago
- 10 comments
Labels: component=Runtime/Coordination, component=Runtime/Configuration, component=API/DataStream
#25249 - [FLINK-36147][runtime] Removes deprecated location field
Pull Request -
State: closed - Opened by XComp about 1 month ago
- 2 comments
Labels: component=Runtime/Coordination
#25249 - [FLINK-36147][runtime] Removes deprecated location field
Pull Request -
State: open - Opened by XComp about 1 month ago
- 1 comment
Labels: component=Runtime/Coordination
#25248 - [FLINK-32688][runtime] Removes deprecated JobExceptionsInfo.
Pull Request -
State: closed - Opened by XComp about 1 month ago
- 1 comment
Labels: component=Runtime/REST
#25248 - [FLINK-32688][runtime] Removes deprecated JobExceptionsInfo.
Pull Request -
State: open - Opened by XComp about 1 month ago
- 1 comment
Labels: component=Runtime/REST
#25245 - fixup! (1.19 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked
Pull Request -
State: closed - Opened by pnowojski about 1 month ago
- 2 comments
Labels: component=API/DataStream, component=Runtime/Task
#25245 - fixup! (1.19 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked
Pull Request -
State: closed - Opened by pnowojski about 1 month ago
- 2 comments
Labels: component=API/DataStream, component=Runtime/Task
#25244 - [FLINK-36119][state] Conditional interfaces for StateFuture
Pull Request -
State: closed - Opened by Zakelly about 1 month ago
- 1 comment
Labels: component=Runtime/StateBackends
#25244 - [FLINK-36119][state] Conditional interfaces for StateFuture
Pull Request -
State: closed - Opened by Zakelly about 1 month ago
- 1 comment
Labels: component=Runtime/StateBackends
#25243 - [FLINK-36142][table] Remove TestTableSourceWithTime and its subclasses to prepare removing TableEnvironmentInternal#registerTableSourceInternal
Pull Request -
State: closed - Opened by xuyangzhong about 1 month ago
- 5 comments
Labels: component=TableSQL/Planner, component=TableSQL/Runtime
#25236 - [FLINK-36125][checkpoint] Fix concurrent duplicate discard of logical file in cp file-merging
Pull Request -
State: closed - Opened by Zakelly about 1 month ago
- 1 comment
Labels: component=Runtime/Checkpointing
#25236 - [FLINK-36125][checkpoint] Fix concurrent duplicate discard of logical file in cp file-merging
Pull Request -
State: closed - Opened by Zakelly about 1 month ago
- 1 comment
Labels: component=Runtime/Checkpointing
#25234 - [FLINK-33677][core] Remove flink-conf.yaml from flink dist.
Pull Request -
State: closed - Opened by JunRuiLee about 1 month ago
- 5 comments
Labels: component=Runtime/Configuration
#25234 - [FLINK-33677][core] Remove flink-conf.yaml from flink dist.
Pull Request -
State: closed - Opened by JunRuiLee about 1 month ago
- 5 comments
Labels: component=Runtime/Configuration
#25233 - [FLINK-36117] Add an adaptor to convert KeyedStateBackend into AsyncKeyedStateBackend.
Pull Request -
State: closed - Opened by wqshr12345 about 1 month ago
- 2 comments
Labels: component=Runtime/StateBackends
#25233 - [FLINK-36117] Add an adaptor to convert KeyedStateBackend into AsyncKeyedStateBackend.
Pull Request -
State: closed - Opened by wqshr12345 about 1 month ago
- 2 comments
Labels: component=Runtime/StateBackends
#25231 - [FLINK-36124][filesystem][s3]Make S3RecoverableFsDataOutputStream.sync not to close the stream
Pull Request -
State: open - Opened by gaborgsomogyi about 1 month ago
- 7 comments
#25231 - [FLINK-36124][filesystem][s3]Make S3RecoverableFsDataOutputStream.sync not to close the stream
Pull Request -
State: open - Opened by gaborgsomogyi about 1 month ago
- 7 comments
#25229 - [FLINK-35827][table-planner] Correcting equality comparisons between rowType fields and constants
Pull Request -
State: closed - Opened by xuyangzhong about 1 month ago
- 4 comments
Labels: component=TableSQL/Planner
#25227 - [FLINK-36064][streaming] Refactor Collect sink to eliminate dependency on OperatorID.
Pull Request -
State: open - Opened by JunRuiLee about 1 month ago
- 1 comment
Labels: component=Runtime/Coordination
#25227 - [FLINK-36064][streaming] Refactor Collect sink to eliminate dependency on OperatorID.
Pull Request -
State: open - Opened by JunRuiLee about 1 month ago
- 1 comment
Labels: component=Runtime/Coordination
#25226 - [FLINK-36112][Connector/Filesystem].Add Support for CreateFlag.NO_LOCAL_WRITE in FLINK on YARN's File Creation to Manage Disk Space and Network Load in Labeled YARN Nodes
Pull Request -
State: closed - Opened by liangyu-1 about 1 month ago
- 6 comments
Labels: component=<none>
#25218 - [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling
Pull Request -
State: open - Opened by RocMarshal about 1 month ago
- 4 comments
#25218 - [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling
Pull Request -
State: open - Opened by RocMarshal about 1 month ago
- 4 comments
#25215 - [FLINK-36090][Runtime / State Backends] Fix bug with IngestDB restore operation for priority queue state in backend.
Pull Request -
State: open - Opened by max-509 about 1 month ago
- 2 comments
Labels: component=Runtime/StateBackends
#25215 - [FLINK-36090][Runtime / State Backends] Fix bug with IngestDB restore operation for priority queue state in backend.
Pull Request -
State: open - Opened by max-509 about 1 month ago
- 2 comments
Labels: component=Runtime/StateBackends
#25211 - [FLINK-35016] catalog changes for model resource
Pull Request -
State: open - Opened by lihaosky about 1 month ago
- 1 comment
Labels: component=<none>
#25192 - [FLINK-34510][Runtime/State]Rename RestoreMode to RecoveryClaimMode
Pull Request -
State: closed - Opened by spoon-lz about 2 months ago
- 6 comments
Labels: component=<none>
#25192 - [FLINK-34510][Runtime/State]Rename RestoreMode to RecoveryClaimMode
Pull Request -
State: closed - Opened by spoon-lz about 2 months ago
- 6 comments
Labels: component=<none>
#25159 - [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction
Pull Request -
State: closed - Opened by lexluo09 about 2 months ago
- 8 comments
Labels: component=TableSQL/Runtime
#25159 - [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction
Pull Request -
State: closed - Opened by lexluo09 about 2 months ago
- 8 comments
Labels: component=TableSQL/Runtime
#25131 - [hotfix][runtime] Optimize the naming of the slotPool attribute in DefaultDeclarativeSlotPool
Pull Request -
State: closed - Opened by RocMarshal 2 months ago
- 1 comment
#25126 - [FLINK-35389][State/ForSt] Async list state
Pull Request -
State: closed - Opened by Zakelly 2 months ago
- 2 comments
Labels: component=Runtime/StateBackends
#25126 - [FLINK-35389][State/ForSt] Async list state
Pull Request -
State: closed - Opened by Zakelly 2 months ago
- 2 comments
Labels: component=Runtime/StateBackends
#25125 - [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend
Pull Request -
State: open - Opened by jectpro7 2 months ago
- 1 comment
Labels: component=Runtime/StateBackends
#25125 - [FLINK-34975][state/forst] Implement Aggregating Async State API for ForStStateBackend
Pull Request -
State: open - Opened by jectpro7 2 months ago
- 4 comments
Labels: component=Runtime/StateBackends
#25115 - [FLINK-35822] Introduce DESCRIBE FUNCTION
Pull Request -
State: open - Opened by nateab 2 months ago
- 3 comments
Labels: component=TableSQL/Planner, component=TableSQL/API, component=TableSQL/Runtime
#25081 - [FLINK-35566] Promote TypeSerializer from PublicEvolving to Public
Pull Request -
State: open - Opened by superdiaodiao 3 months ago
- 4 comments
Labels: component=API/Core
#25055 - [FLINK-35795][datastream]Introduce ProcessFunction Attribute in DataStream API V2
Pull Request -
State: closed - Opened by WencongLiu 3 months ago
- 2 comments
Labels: component=<none>
#25055 - [FLINK-35795][datastream]Introduce ProcessFunction Attribute in DataStream API V2
Pull Request -
State: closed - Opened by WencongLiu 3 months ago
- 2 comments
Labels: component=<none>
#25035 - [FLINK-35780] Support state migration between disabling and enabling State TTL for RocksDBState
Pull Request -
State: open - Opened by xiangyuf 3 months ago
- 5 comments
Labels: component=Runtime/StateBackends
#25027 - [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed
Pull Request -
State: open - Opened by kumar-mallikarjuna 3 months ago
- 6 comments
Labels: component=Runtime/Coordination
#25027 - [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed
Pull Request -
State: open - Opened by kumar-mallikarjuna 3 months ago
- 6 comments
Labels: component=Runtime/Coordination
#25000 - [FLINK-34082][core] Remove deprecated methods of Configuration
Pull Request -
State: closed - Opened by 1996fanrui 3 months ago
- 2 comments
Labels: component=Runtime/Configuration
#24997 - [WIP] [FLINK-XXXX] Generalized watermark wip
Pull Request -
State: open - Opened by jeyhunkarimov 3 months ago
- 6 comments
#24997 - [WIP] [FLINK-XXXX] Generalized watermark wip
Pull Request -
State: open - Opened by jeyhunkarimov 3 months ago
- 6 comments
#24908 - [FLINK-35282][FLINK-35520] PyFlink Support for Apache Beam > 2.49
Pull Request -
State: open - Opened by snuyanzin 4 months ago
- 4 comments
Labels: component=BuildSystem/CI
#24879 - [FLINK-35510][statebackend] Implement basic incremental checkpoint fo…
Pull Request -
State: closed - Opened by zoltar9264 4 months ago
- 16 comments
Labels: component=Runtime/StateBackends
#24832 - [FLINK-35412][State/Runtime] Batch execution of async state request callback
Pull Request -
State: closed - Opened by Zakelly 4 months ago
- 3 comments
Labels: component=Runtime/StateBackends, component=Runtime/Task
#24812 - [FLINK-35049][state] Implement Map Async State API for ForStStateBackend
Pull Request -
State: closed - Opened by fredia 4 months ago
- 2 comments
Labels: component=Runtime/StateBackends
#24736 - [FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall…
Pull Request -
State: open - Opened by venkata91 5 months ago
- 9 comments
Labels: component=Runtime/Coordination
#24715 - FLINK-35311 Draft pr for initial review of apicurio
Pull Request -
State: closed - Opened by davidradl 5 months ago
- 2 comments
Labels: component=Connectors/Kafka
#24502 - [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java
Pull Request -
State: open - Opened by snuyanzin 7 months ago
- 1 comment
Labels: component=TableSQL/Planner
#24502 - [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java
Pull Request -
State: open - Opened by snuyanzin 7 months ago
- 1 comment
Labels: component=TableSQL/Planner
#24501 - [FLINK-34674][table] Migrate CalcSnapshotTransposeRule to java
Pull Request -
State: open - Opened by snuyanzin 7 months ago
- 1 comment
Labels: component=TableSQL/Planner
#24501 - [FLINK-34674][table] Migrate CalcSnapshotTransposeRule to java
Pull Request -
State: open - Opened by snuyanzin 7 months ago
- 1 comment
Labels: component=TableSQL/Planner
#24470 - [FLINK-34624][state/changelog] Enable local recovery in ChangelogRescalingITCase
Pull Request -
State: closed - Opened by fredia 7 months ago
- 3 comments
Labels: component=Runtime/StateBackends
#24420 - [FLINK-34555][table] Migrate JoinConditionTypeCoerceRule to java.
Pull Request -
State: open - Opened by liuyongvs 7 months ago
- 6 comments
Labels: component=TableSQL/Planner
#24292 - [FLINK-34417] Log Job ID via MDC
Pull Request -
State: closed - Opened by rkhachatryan 8 months ago
- 7 comments
Labels: component=Runtime/Coordination, component=Runtime/Checkpointing, component=Runtime/Task
#24291 - [FLINK-34410][ci] Disables the nightly trigger workflow for forks
Pull Request -
State: open - Opened by XComp 8 months ago
- 1 comment
#24290 - [FLINK-33936][table] Outputting Identical Results in Mini-Batch Aggregation with Set TTL
Pull Request -
State: open - Opened by hackergin 8 months ago
- 1 comment
#24289 - [FLINK-34060][table] Migrate UserDefinedTableAggFunctions to JavaUserDefinedTableAggFunctions
Pull Request -
State: open - Opened by xuyangzhong 8 months ago
- 1 comment
#24288 - [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 8 months ago
- 2 comments
#24287 - [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 8 months ago
- 1 comment
#24286 - [FLINK-34200][test] Fix the bug that AutoRescalingITCase.testCheckpointRescalingInKeyedState fails occasionally
Pull Request -
State: closed - Opened by 1996fanrui 8 months ago
- 3 comments
#24285 - [FLINK-34409][ci] Enables (most) tests that were disabled for the AdaptiveScheduler due to missing features
Pull Request -
State: open - Opened by XComp 8 months ago
- 4 comments
#24284 - [FLINK-21400][ci] Enables FileSink and Stateful stream job e2e test for the AdaptiveScheduler
Pull Request -
State: closed - Opened by XComp 8 months ago
- 2 comments
#24283 - [BP-1.19][FLINK-34360][ci] Adds cleanup to job_init action
Pull Request -
State: closed - Opened by XComp 8 months ago
- 2 comments
#24282 - [FLINK-34282][ci] Adds release-1.18 back to GHA nightly trigger workflow
Pull Request -
State: closed - Opened by XComp 8 months ago
- 5 comments
#24281 - [hotfix][sql-client] Improve logging using placeholders
Pull Request -
State: open - Opened by slfan1989 8 months ago
- 1 comment
#24280 - [FLINK-28693][table] Fix janino compile failed because the code generated refers the class in table-planner
Pull Request -
State: open - Opened by xuyangzhong 8 months ago
- 3 comments
#24279 - [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese
Pull Request -
State: open - Opened by lxliyou001 8 months ago
- 3 comments
#24278 - [BP-1.18][FLINK-34360][ci] Adds cleanup to job_init action
Pull Request -
State: closed - Opened by XComp 8 months ago
- 2 comments
#24277 - [FLINK-34360][ci] Adds cleanup to job_init action
Pull Request -
State: closed - Opened by XComp 8 months ago
- 1 comment
#24276 - [hotfix][web] Correct the hint of options name of rest.profiling.enabled
Pull Request -
State: closed - Opened by Myasuka 8 months ago
- 1 comment
#24275 - [FLINK-34372][table-api] Support DESCRIBE CATALOG
Pull Request -
State: open - Opened by xuyangzhong 8 months ago
- 1 comment
#24274 - [FLINK-34386][state] Add RocksDB bloom filter metrics
Pull Request -
State: open - Opened by hejufang 8 months ago
- 4 comments
#24273 - [FLINK-34383][Documentation] Modify the comment with incorrect syntax
Pull Request -
State: open - Opened by lxliyou001 8 months ago
- 4 comments
#24272 - [FLINK-34371][runtime] Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment
Pull Request -
State: open - Opened by yunfengzhou-hub 8 months ago
- 1 comment
#24271 - [FLINK-34362][docs] Add argument to skip integrate connector docs in setup_docs.sh to improve build times
Pull Request -
State: open - Opened by swuferhong 8 months ago
- 1 comment
#24270 - [FLINK-34366][table] Add support to group rows by column ordinals
Pull Request -
State: open - Opened by jeyhunkarimov 8 months ago
- 1 comment
#24269 - [BP-1.17][FLINK-34324][test] Makes all s3 related operations being declared and called in a single location
Pull Request -
State: open - Opened by XComp 8 months ago
- 1 comment
#24268 - [BP-1.18][FLINK-34324][test] Makes all s3 related operations being declared and called in a single location
Pull Request -
State: closed - Opened by XComp 8 months ago
- 2 comments
#24267 - [FLINK-34368] Update GCS filesystems to latest available version v3.0
Pull Request -
State: closed - Opened by MartijnVisser 8 months ago
- 2 comments
#24266 - [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file
Pull Request -
State: closed - Opened by 1996fanrui 8 months ago
- 1 comment