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
#22533 - [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver
Pull Request -
State: open - Opened by FangYongs over 1 year ago
- 3 comments
#22533 - [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver
Pull Request -
State: open - Opened by FangYongs over 1 year ago
- 3 comments
#22532 - [FLINK-31548][jdbc-driver] Introduce FlinkDataSource
Pull Request -
State: open - Opened by FangYongs over 1 year ago
- 2 comments
#22532 - [FLINK-31548][jdbc-driver] Introduce FlinkDataSource
Pull Request -
State: open - Opened by FangYongs over 1 year ago
- 2 comments
#22531 - [FLINK-28853] Document the split level watermark alignment feature an…
Pull Request -
State: open - Opened by mas-chen over 1 year ago
- 2 comments
Labels: component=Connectors/Common, component=Runtime/Checkpointing
#22531 - [FLINK-28853] Document the split level watermark alignment feature an…
Pull Request -
State: open - Opened by mas-chen over 1 year ago
- 2 comments
Labels: component=Connectors/Common, component=Runtime/Checkpointing
#22530 - [BP-1.17][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already known
Pull Request -
State: closed - Opened by dmvk over 1 year ago
- 1 comment
Labels: component=Runtime/Coordination, component=Deployment/Kubernetes
#22530 - [BP-1.17][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already known
Pull Request -
State: closed - Opened by dmvk over 1 year ago
- 1 comment
Labels: component=Runtime/Coordination, component=Deployment/Kubernetes
#22529 - [BP-1.16][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already known
Pull Request -
State: closed - Opened by dmvk over 1 year ago
- 1 comment
Labels: component=Runtime/Coordination, component=Deployment/Kubernetes
#22529 - [BP-1.16][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already known
Pull Request -
State: closed - Opened by dmvk over 1 year ago
- 1 comment
Labels: component=Runtime/Coordination, component=Deployment/Kubernetes
#22527 - [FLINK-31749][hotfix][doc] Update Hadoop formats datastream doc
Pull Request -
State: closed - Opened by echauchot over 1 year ago
- 2 comments
Labels: component=Documentation
#22527 - [FLINK-31749][hotfix][doc] Update Hadoop formats datastream doc
Pull Request -
State: closed - Opened by echauchot over 1 year ago
- 2 comments
Labels: component=Documentation
#22525 - [FLINK-32001][table] Row-level update should support returning partial columns
Pull Request -
State: open - Opened by luoyuxia over 1 year ago
- 2 comments
Labels: component=TableSQL/Runtime
#22525 - [FLINK-32001][table] Row-level update should support returning partial columns
Pull Request -
State: open - Opened by luoyuxia over 1 year ago
- 2 comments
Labels: component=TableSQL/Runtime
#22523 - [FLINK-32006] Harden and speed up AsyncWaitOperatorTest#testProcessingTimeAlwaysTimeoutFunctionWithRetry
Pull Request -
State: open - Opened by dmvk over 1 year ago
- 2 comments
Labels: component=API/DataStream
#22522 - [BP-1.17][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective
Pull Request -
State: closed - Opened by liuml07 over 1 year ago
- 4 comments
Labels: component=Runtime/Checkpointing, component=FileSystems
#22522 - [BP-1.17][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective
Pull Request -
State: closed - Opened by liuml07 over 1 year ago
- 4 comments
Labels: component=Runtime/Checkpointing, component=FileSystems
#22520 - [FLINK-31996] Chaining operators with different max parallelism prevents rescaling
Pull Request -
State: open - Opened by dmvk over 1 year ago
- 1 comment
Labels: component=Runtime/Coordination
#22516 - [FLINK-31993][runtime] Initialize and pass down FailureEnrichers
Pull Request -
State: open - Opened by pgaref over 1 year ago
- 1 comment
Labels: component=<none>
#22515 - [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.
Pull Request -
State: open - Opened by xishuaidelin over 1 year ago
- 1 comment
Labels: component=TableSQL/Planner
#22515 - [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.
Pull Request -
State: open - Opened by xishuaidelin over 1 year ago
- 1 comment
Labels: component=TableSQL/Planner
#22511 - [FLINK-31891][runtime] Introduce JobMaster TM disconnect failure enrichment/labeling
Pull Request -
State: closed - Opened by pgaref over 1 year ago
- 1 comment
Labels: component=<none>
#22511 - [FLINK-31891][runtime] Introduce JobMaster TM disconnect failure enrichment/labeling
Pull Request -
State: open - Opened by pgaref over 1 year ago
- 1 comment
Labels: component=<none>
#22509 - [FLINK-31983] Add yarn Acls capability to Flink containers
Pull Request -
State: open - Opened by architgyl over 1 year ago
- 8 comments
Labels: component=Deployment/YARN
#22509 - [FLINK-31983] Add yarn Acls capability to Flink containers
Pull Request -
State: open - Opened by architgyl over 1 year ago
- 8 comments
Labels: component=Deployment/YARN
#22508 - trivial word dedup
Pull Request -
State: open - Opened by rbowen over 1 year ago
- 2 comments
#22508 - trivial word dedup
Pull Request -
State: open - Opened by rbowen over 1 year ago
- 2 comments
#22506 - [FLINK-31890][runtime] Introduce DefaultScheduler failure enrichment/labeling
Pull Request -
State: open - Opened by pgaref over 1 year ago
- 4 comments
Labels: component=<none>
#22506 - [FLINK-31890][runtime] Introduce DefaultScheduler failure enrichment/labeling
Pull Request -
State: open - Opened by pgaref over 1 year ago
- 4 comments
Labels: component=<none>
#22504 - [FLINK-31971][tests] Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest
Pull Request -
State: closed - Opened by zentol over 1 year ago
- 1 comment
Labels: component=Tests, component=Connectors/HadoopCompatibility
#22503 - [FLINK-31972][tests] Remove powermock whitebox usages
Pull Request -
State: closed - Opened by zentol over 1 year ago
- 1 comment
Labels: component=Tests
#22502 - [FLINK-28215][Buildsystem] Update Maven Surefire plugin to 3.2.2
Pull Request -
State: closed - Opened by MartijnVisser over 1 year ago
- 2 comments
Labels: component=BuildSystem
#22502 - [FLINK-28215][Buildsystem] Update Maven Surefire plugin to 3.2.2
Pull Request -
State: open - Opened by MartijnVisser over 1 year ago
- 1 comment
Labels: component=BuildSystem
#22501 - [FLINK-31637][network] Implement the HashBufferAccumulator for the tiered storage
Pull Request -
State: closed - Opened by TanYuxin-tyx over 1 year ago
- 3 comments
Labels: component=Runtime/Network
#22501 - [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage
Pull Request -
State: open - Opened by TanYuxin-tyx over 1 year ago
- 1 comment
Labels: component=Runtime/Network
#22499 - [FLINK-31928][build] Upgrade okhttp3 to 4.11.0
Pull Request -
State: open - Opened by cy2008 over 1 year ago
- 3 comments
Labels: component=Deployment/Kubernetes
#22499 - [FLINK-31928][build] Upgrade okhttp3 to 4.11.0
Pull Request -
State: open - Opened by cy2008 over 1 year ago
- 3 comments
Labels: component=Deployment/Kubernetes
#22498 - [FLINK-31928][build] Upgrade okhttp3 to 4.11.0
Pull Request -
State: closed - Opened by cy2008 over 1 year ago
- 3 comments
Labels: component=Deployment/Kubernetes
#22496 - [FLINK-31959][checkpoint] Correct the unaligned checkpoint type at checkpoint level
Pull Request -
State: closed - Opened by 1996fanrui over 1 year ago
- 5 comments
Labels: component=Runtime/Checkpointing
#22496 - [FLINK-31959][checkpoint] Correct the unaligned checkpoint type at checkpoint level
Pull Request -
State: closed - Opened by 1996fanrui over 1 year ago
- 5 comments
Labels: component=Runtime/Checkpointing
#22493 - Flink 31952
Pull Request -
State: closed - Opened by xishuaidelin over 1 year ago
- 1 comment
#22493 - Flink 31952
Pull Request -
State: closed - Opened by xishuaidelin over 1 year ago
- 1 comment
#22492 - [FLINK-31950][table-planner] Introduce StateMetadata and StateMetadataJson SerDe
Pull Request -
State: closed - Opened by LadyForest over 1 year ago
- 3 comments
Labels: component=TableSQL/Planner
#22491 - [FLINK-31947] enable stdout for flink-console.sh
Pull Request -
State: open - Opened by HuangZhenQiu over 1 year ago
- 1 comment
Labels: component=flink-docker
#22488 - [FLINK-31882][sql-client] Fix sql client can't show result for DELETE statement when delete is pushed down
Pull Request -
State: closed - Opened by luoyuxia over 1 year ago
- 5 comments
#22488 - [FLINK-31882][sql-client] Fix sql client can't show result for DELETE statement when delete is pushed down
Pull Request -
State: closed - Opened by luoyuxia over 1 year ago
- 5 comments
#22487 - [FLINK-31940] DataStreamCsvITCase#CityPojo serialized as POJO
Pull Request -
State: open - Opened by zentol over 1 year ago
- 1 comment
Labels: component=Tests, component=Formats
#22484 - [FLINK-31934][rocksdb][tests] Remove mocking
Pull Request -
State: closed - Opened by zentol over 1 year ago
- 2 comments
Labels: component=Tests, component=Runtime/StateBackends
#22484 - [FLINK-31934][rocksdb][tests] Remove mocking
Pull Request -
State: closed - Opened by zentol over 1 year ago
- 2 comments
Labels: component=Tests, component=Runtime/StateBackends
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22483 - [FLINK-31118][table] Add ARRAY_UNION function.
Pull Request -
State: closed - Opened by liuyongvs over 1 year ago
- 2 comments
Labels: component=TableSQL/Planner
#22481 - [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8
Pull Request -
State: open - Opened by pgaref over 1 year ago
- 16 comments
Labels: component=Formats
#22481 - [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8
Pull Request -
State: open - Opened by pgaref over 1 year ago
- 16 comments
Labels: component=Formats
#22477 - [FLINK-31831][test] Use random ports as rest bind port and jobmanager rpc port to avoid port binding failure
Pull Request -
State: closed - Opened by wanglijie95 over 1 year ago
- 1 comment
Labels: component=Runtime/Coordination
#22475 - [FLINK-31913][sql] SQL client respects env.java.opts.client
Pull Request -
State: closed - Opened by zentol over 1 year ago
- 1 comment
Labels: component=Deployment/Scripts, component=TableSQL/Client
#22475 - [FLINK-31913][sql] SQL client respects env.java.opts.client
Pull Request -
State: closed - Opened by zentol over 1 year ago
- 1 comment
Labels: component=Deployment/Scripts, component=TableSQL/Client
#22458 - [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…
Pull Request -
State: closed - Opened by zoltar9264 over 1 year ago
- 8 comments
Labels: component=Runtime/StateBackends
#22458 - [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…
Pull Request -
State: closed - Opened by zoltar9264 over 1 year ago
- 8 comments
Labels: component=Runtime/StateBackends
#22457 - [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5
Pull Request -
State: closed - Opened by fredia over 1 year ago
- 5 comments
Labels: component=Runtime/QueryableState
#22457 - [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5
Pull Request -
State: closed - Opened by fredia over 1 year ago
- 5 comments
Labels: component=Runtime/QueryableState
#22451 - FLINK-31880: Fixed broken date test. It was failing when run in CST time zone.
Pull Request -
State: closed - Opened by kurtostfeld over 1 year ago
- 1 comment
Labels: component=Formats, component=Connectors/ORC
#22451 - FLINK-31880: Fixed broken date test. It was failing when run in CST time zone.
Pull Request -
State: closed - Opened by kurtostfeld over 1 year ago
- 1 comment
Labels: component=Formats, component=Connectors/ORC
#22451 - FLINK-31880: Fixed broken date test. It was failing when run in CST time zone.
Pull Request -
State: closed - Opened by kurtostfeld over 1 year ago
- 1 comment
Labels: component=Formats, component=Connectors/ORC
#22432 - [FLINK-18808][runtime] Include side outputs in numRecordsOut metric
Pull Request -
State: closed - Opened by reswqa over 1 year ago
- 9 comments
Labels: component=Runtime/Metrics, component=Runtime/Task
#22432 - [FLINK-18808][runtime] Include side outputs in numRecordsOut metric
Pull Request -
State: closed - Opened by reswqa over 1 year ago
- 9 comments
Labels: component=Runtime/Metrics, component=Runtime/Task
#22427 - [FLINK-30815][tests] Migrate BatchAbstractTestBase and BatchTestBase to junit5
Pull Request -
State: closed - Opened by TanYuxin-tyx over 1 year ago
- 7 comments
Labels: component=Tests
#22427 - [FLINK-30815][tests] Migrate BatchAbstractTestBase and BatchTestBase to junit5
Pull Request -
State: closed - Opened by TanYuxin-tyx over 1 year ago
- 7 comments
Labels: component=Tests
#22419 - [FLINK-31841][flink-streaming-java] remove the redundant variables in AllWindowedStream#reduce
Pull Request -
State: closed - Opened by WencongLiu over 1 year ago
- 2 comments
Labels: component=API/DataStream
#22419 - [FLINK-31841][flink-streaming-java] remove the redundant variables in AllWindowedStream#reduce
Pull Request -
State: closed - Opened by WencongLiu over 1 year ago
- 2 comments
Labels: component=API/DataStream
#22418 - [FLINK-29841] fix the typo in docs/content/docs/deployment/config.md
Pull Request -
State: closed - Opened by WencongLiu over 1 year ago
- 1 comment
Labels: component=Documentation
#22418 - [FLINK-29841] fix the typo in docs/content/docs/deployment/config.md
Pull Request -
State: closed - Opened by WencongLiu over 1 year ago
- 1 comment
Labels: component=Documentation
#22416 - [FLINK-28185][Connector/Kafka] Handle missing timestamps when there a…
Pull Request -
State: closed - Opened by objectt over 1 year ago
- 3 comments
Labels: component=Connectors/Kafka
#22413 - [FLINK-31832][runtime] Add benchmarks for end to end restarting tasks
Pull Request -
State: closed - Opened by huwh over 1 year ago
- 5 comments
Labels: component=Runtime/Coordination
#22412 - [FLINK-31778][table-planner] Fix RowToRowCastRule
Pull Request -
State: closed - Opened by soin08 over 1 year ago
- 3 comments
Labels: component=TableSQL/Planner
#22404 - [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices
Pull Request -
State: open - Opened by XComp over 1 year ago
- 3 comments
Labels: component=<none>
#22404 - [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices
Pull Request -
State: open - Opened by XComp over 1 year ago
- 3 comments
Labels: component=<none>
#22404 - [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices
Pull Request -
State: open - Opened by XComp over 1 year ago
- 3 comments
Labels: component=<none>
#22404 - [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices
Pull Request -
State: open - Opened by XComp over 1 year ago
- 5 comments
Labels: component=<none>
#22404 - [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices
Pull Request -
State: open - Opened by XComp over 1 year ago
- 5 comments
Labels: component=<none>
#22404 - [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices
Pull Request -
State: open - Opened by XComp over 1 year ago
- 3 comments
Labels: component=<none>
#22400 - [FLINK-31689][flink-connector-files] Check expired file state before …
Pull Request -
State: open - Opened by noomanee over 1 year ago
- 10 comments
Labels: component=Connectors/FileSystem
#22394 - [FLINK-31780][component=Runtime/Coordination] Allow users to disable 'Ensemble tracking' feature for ZooKeeper Curator framework
Pull Request -
State: closed - Opened by JTaky over 1 year ago
- 5 comments
Labels: component=<none>
#22394 - [FLINK-31780][component=Runtime/Coordination] Allow users to disable 'Ensemble tracking' feature for ZooKeeper Curator framework
Pull Request -
State: open - Opened by JTaky over 1 year ago
- 4 comments
Labels: component=<none>
#22390 - [FLINK-31785][runtime] Moves LeaderElectionService.stop into LeaderElection.close
Pull Request -
State: open - Opened by XComp over 1 year ago
- 3 comments
Labels: component=<none>
#22390 - [FLINK-31785][runtime] Moves LeaderElectionService.stop into LeaderElection.close
Pull Request -
State: open - Opened by XComp over 1 year ago
- 3 comments
Labels: component=<none>
#22390 - [FLINK-31785][FLINK-31786][runtime] Moves LeaderElectionService.stop into LeaderElection.close
Pull Request -
State: open - Opened by XComp over 1 year ago
- 1 comment
Labels: component=<none>
#22390 - [FLINK-31785][FLINK-31786][runtime] Moves LeaderElectionService.stop into LeaderElection.close
Pull Request -
State: open - Opened by XComp over 1 year ago
- 1 comment
Labels: component=<none>
#22390 - [FLINK-31785][FLINK-31786][runtime] Moves LeaderElectionService.stop into LeaderElection.close
Pull Request -
State: open - Opened by XComp over 1 year ago
- 1 comment
Labels: component=<none>
#22384 - [FLINK-31776][runtime] Introduces LeaderElection interface
Pull Request -
State: open - Opened by XComp over 1 year ago
- 9 comments
Labels: component=<none>
#22382 - [FLINK-31628][runtime] Check the heap index to avoid the same channel status being added/removed repeatedly.
Pull Request -
State: closed - Opened by wanglijie95 over 1 year ago
- 1 comment
Labels: component=Runtime/Task
#22380 - [FLINK-31773][runtime] Separate DefaultLeaderElectionService.start(LeaderContender) into two separate methods for starting the driver and registering a contender
Pull Request -
State: open - Opened by XComp over 1 year ago
- 14 comments
Labels: component=<none>
#22380 - [FLINK-31773][runtime] Separate DefaultLeaderElectionService.start(LeaderContender) into two separate methods for starting the driver and registering a contender
Pull Request -
State: open - Opened by XComp over 1 year ago
- 14 comments
Labels: component=<none>