issues  

Messages by Thread

• [PR] FLINK-38449: Makes error message for fractional values for MemorySize explicit [flink] via GitHub
  • Re: [PR] FLINK-38449: Makes error message for fractional values for MemorySize explicit [flink] via GitHub
• [jira] [Updated] (FLINK-38449) Makes error message for fractional values for MemorySize explicit ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38449) Makes error message for fractional values for MemorySize explicit Navin Viswanath (Jira)
• [jira] [Created] (FLINK-38448) Fix doc CI rsync logic Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-38448) Fix doc CI rsync logic ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38448) Fix doc CI rsync logic Ferenc Csaky (Jira)
• [PR] [FLINK-38448] Replace `burnett01/rsync-deployments` with a custom `rsync-deploy` action in `docs.yaml` [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38448] Replace `burnett01/rsync-deployments` with a custom `rsync-deploy` action in `docs.yaml` [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-38447) Add table sink support for Elasticsearch 8 connector lwn (Jira)
  • [jira] [Updated] (FLINK-38447) Add table sink support for Elasticsearch 8 connector ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38447) Add table sink support for Elasticsearch 8 connector lwn (Jira)
• [PR] [FLINK-38447] Add table sink support for Elasticsearch 8 connector [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38447] Add table sink support for Elasticsearch 8 connector [flink-connector-elasticsearch] via GitHub
• [jira] [Created] (FLINK-38447) Add table sink support for Elasticsearch 8 connector lwn (Jira)
• [jira] [Comment Edited] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state Jon Cavallie Mester (Jira)
• [jira] [Commented] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state Jon Cavallie Mester (Jira)
• Re: [PR] [api][java] Combine add methods to add_resource. [flink-agents] via GitHub
• [PR] upgrade maven-shade-plugin [flink-kubernetes-operator] via GitHub
• [I] [Feature][dosc] How to build an agent - Workflow Agent docs [flink-agents] via GitHub
• [PR] [flink-table-planner] Optimize RemoveUnreachableCoalesceArgumentsRule rule [flink] via GitHub
  • Re: [PR] [flink-table-planner] Optimize RemoveUnreachableCoalesceArgumentsRule rule [flink] via GitHub
  • Re: [PR] [flink-table-planner] Optimize RemoveUnreachableCoalesceArgumentsRule rule [flink] via GitHub
  • Re: [PR] [flink-table-planner] Optimize RemoveUnreachableCoalesceArgumentsRule rule [flink] via GitHub
• [jira] [Resolved] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode Sergey Nuyanzin (Jira)
• Re: [I] [Feature] [api] Combine add methods of Agent and Environment in Java [flink-agents] via GitHub
• [jira] [Created] (FLINK-38446) Pyflink explain() crashes with Index Out Of Bounds Ahmad Humayun (Jira)
• Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38232] [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 suhwan (Jira)
• Re: [PR] [example][java] Add single agent example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add single agent example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add single agent example [flink-agents] via GitHub
  • [PR] [example][java] Add single agent example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add multiple agent integration example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add multiple agent integration example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add multiple agent integration example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add multiple agent integration example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add single agent example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add single agent example [flink-agents] via GitHub
  • Re: [PR] [example][java] Add single agent example [flink-agents] via GitHub
• [PR] [BP-to-2.0][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [BP-to-2.0][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [BP-to-2.0][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
• [PR] [FLINK-38418][python] Support pickling Instants when collecting TIMESTAMP_LTZ types in PyFlink [flink] via GitHub
  • Re: [PR] [FLINK-38418][python] Support pickling Instants when collecting TIMESTAMP_LTZ types in PyFlink [flink] via GitHub
• Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• Re: [PR] [BP-to-2.1][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [BP-to-2.1][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
• Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka] via GitHub
• [PR] [BP-to-1.20][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [BP-to-1.20][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [BP-to-1.20][FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
• [PR] [FLINK-38408][checkpoint] Complete the checkpoint CompletableFuture after updating statistics to ensures semantic correctness and prevent test failure [flink] via GitHub
• [jira] [Updated] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests ASF GitHub Bot (Jira)
• [jira] [Comment Edited] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests Rui Fan (Jira)
  • [jira] [Comment Edited] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests Rui Fan (Jira)
• Re: [PR] [FLINK-38445][table] Add test plans for MultiJoin that preserve upsertKeys [flink] via GitHub
• [jira] [Updated] (FLINK-38445) Create test plans to validate upsert keys ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38445) Create test plans to validate upsert keys Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join Gustavo de Morais (Jira)
• [jira] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Jon Cavallie Mester (Jira)
• [jira] [Commented] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Jon Cavallie Mester (Jira)
• [PR] [example] Add React Agent quick start example [flink-agents] via GitHub
  • Re: [PR] [example] Add React Agent quick start example [flink-agents] via GitHub
  • Re: [PR] [example] Add React Agent quick start example [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38418) Collecting TIMESTAMP_LTZ values in PyFlink fails with pickling error ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38320) Upgrade Pekko to 1.2.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-38320] Upgrade Netty version to 4.2.4.Final [flink-shaded] via GitHub
• Re: [PR] Support skip verify ssl certificate and hostname [flink-connector-elasticsearch] via GitHub
  • Re: [PR] Support skip verify ssl certificate and hostname [flink-connector-elasticsearch] via GitHub
  • Re: [PR] Support skip verify ssl certificate and hostname [flink-connector-elasticsearch] via GitHub
• [jira] [Created] (FLINK-38443) Adapt TIDB CDC Connector to FLIP-27 API Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. Wei Zhong (Jira)
• Re: [PR] Rebuild website [flink-web] via GitHub
• Re: [PR] [FLINK-38437] Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable ASF GitHub Bot (Jira)
• [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] via GitHub
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] via GitHub
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] via GitHub
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] via GitHub
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] via GitHub
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] via GitHub
• [jira] [Comment Edited] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable Sergey Nuyanzin (Jira)
• [PR] [integration] Configure the model name uniformly in ChatModelSetup. [flink-agents] via GitHub
• [I] [Tech Debt] Configure the model name uniformly in ChatModelSetup. [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Configure the model name uniformly in ChatModelSetup. [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests Rui Fan (Jira)
• [jira] [Resolved] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration Yanquan Lv (Jira)
• [PR] [BP-2.1][FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-38400][table] Fix FILTER condition loss in STDDEV/VAR decomposition by AggregateReduceFunctionsRule [flink] via GitHub
• [PR] Fix to table [flink-agents] via GitHub
  • Re: [PR] Fix to table [flink-agents] via GitHub
  • Re: [PR] [runtime] Fix exception when integrate agent from datastream to table. [flink-agents] via GitHub
• [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] via GitHub
  • Re: [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] via GitHub
  • Re: [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] via GitHub
  • Re: [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] via GitHub
  • Re: [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] via GitHub
  • Re: [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] via GitHub
  • Re: [PR] [Feature][docs] add docs for introducing embedding models and vector stores [flink-agents] via GitHub
• Re: [PR] Run ci [flink] via GitHub
• Re: [PR] [FLINK-37575] Simplify the code for creating Netty shuffle environment. [flink] via GitHub
  • Re: [PR] [FLINK-37575] Simplify the code for creating Netty shuffle environment. [flink] via GitHub
• [PR] [FLINK-38440][pipeline-connector][iceberg] fixed iceberg write SMALLINT/TINYINT data wrong [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38440][pipeline-connector][iceberg] fixed iceberg write SMALLINT/TINYINT data wrong [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table Ruan Hang (Jira)
  • [jira] [Commented] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table Mate Czagany (Jira)
• [jira] [Updated] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong ASF GitHub Bot (Jira)
• Re: [I] [Tech Debt] Refactor Agent resource declaration in python. [flink-agents] via GitHub
• [jira] [Commented] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong ChaoFang (Jira)
• [jira] [Created] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table Ruan Hang (Jira)
• [I] [Feature] Separate messages and arguments for prompt of chat method in BaseChatModelSetup [flink-agents] via GitHub
• [I] [Feature] [example] Implement ReAct Agent quick start example [flink-agents] via GitHub
  • Re: [I] [Feature] [example] Implement ReAct Agent quick start example [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38416) Wrong constructor argument order for NestedMapConstraint ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38416) Wrong constructor argument order for NestedMapConstraint Ryan Murray (Jira)
• [PR] [package] Refactor the packaging of Flink-Agents [flink-agents] via GitHub
  • Re: [PR] [package] Refactor the packaging of Flink-Agents [flink-agents] via GitHub
  • Re: [PR] [package] Refactor the packaging of Flink-Agents [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38438) Support session mini cluster when use local executor. ASF GitHub Bot (Jira)
• [PR] [FLINK-38438][Runtime] Support session mini cluster when use local ex… [flink] via GitHub
  • Re: [PR] [FLINK-38438][Runtime] Support session mini cluster when use local ex… [flink] via GitHub
• [jira] [Created] (FLINK-38438) Support session mini cluster when use local executor. Weijun Wang (Jira)
• [PR] [hotfix] [docs] Fix Typo in Stateful Stream Processing introduction [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix Typo in Stateful Stream Processing introduction [flink] via GitHub
• Re: [I] [Tech Debt] Pemja Bug Tracking [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38412) Refactor MultiJoin test with state ttl to avoid state expiration ASF GitHub Bot (Jira)
• Re: [PR] Change base image from jre-jammy to jre-noble for security improvements [flink-docker] via GitHub
• [PR] Debugging the Blue/Green e2e tests [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-35500][Connectors/DynamoDB] DynamoDb Table API Sink fails to delete elements due to key not found [flink-connector-aws] via GitHub
• Re: [PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink] via GitHub
• Re: [PR] [FLINK-37710] Use schemas from the state in SchemaOperator [flink-cdc] via GitHub
• Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support Yanquan Lv (Jira)
  • [jira] [Commented] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support Poorvank Bhatia (Jira)
• [PR] [FLINK-38435][table] Refactor codegen and runner for MLPredict and Lo… [flink] via GitHub
  • Re: [PR] [FLINK-38435][table] Refactor codegen and runner for MLPredict and Lo… [flink] via GitHub
• [PR] Update Dockerfiles for 1.20.3 release [flink-docker] via GitHub
  • Re: [PR] Update Dockerfiles for 1.20.3 release [flink-docker] via GitHub
  • Re: [PR] Update Dockerfiles for 1.20.3 release [flink-docker] via GitHub
  • Re: [PR] Update Dockerfiles for 1.20.3 release [flink-docker] via GitHub
• [PR] Add GPG key for 1.20.3 release [flink-docker] via GitHub
  • Re: [PR] Add GPG key for 1.20.3 release [flink-docker] via GitHub
• [PR] [docs] Typo fix [flink] via GitHub
  • Re: [PR] [docs] Typo fix [flink] via GitHub
• [jira] [Commented] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests Ruan Hang (Jira)
  • [jira] [Commented] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests Ruan Hang (Jira)
• Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
  • Re: [PR] [FLINK-38336][state/forst] Avoid data copy during failover for ForSt statebackend [flink] via GitHub
• [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] via GitHub
  • Re: [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] via GitHub
  • Re: [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] via GitHub
  • Re: [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] via GitHub
  • Re: [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] via GitHub
  • Re: [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] via GitHub
  • Re: [PR] [FLINK-38433][state/forst] Avoid delete ForSt's directory when there happened to be an existing one. [flink] via GitHub
• Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink] via GitHub
• [jira] [Updated] (FLINK-38435) Refactor codegen and runner for MLPredict and LookupJoin ASF GitHub Bot (Jira)
• Re: [PR] [runtime] Only persist memory changes to flink state when action is finished [flink-agents] via GitHub
  • Re: [PR] [runtime] Only persist memory changes to flink state when action is finished [flink-agents] via GitHub
  • Re: [PR] [runtime] Only persist memory changes to flink state when action is finished [flink-agents] via GitHub
  • Re: [PR] [runtime] Only persist memory changes to flink state when action is finished [flink-agents] via GitHub
• [PR] [runtime] Bump flink version to 1.20.3 [flink-agents] via GitHub
  • Re: [PR] [runtime] Bump flink version to 1.20.3 [flink-agents] via GitHub
  • Re: [PR] [runtime] Bump flink version to 1.20.3 [flink-agents] via GitHub
  • Re: [PR] [runtime] Bump flink version to 1.20.3 [flink-agents] via GitHub
  • Re: [PR] [runtime] Bump flink version to 1.20.3 [flink-agents] via GitHub
• [PR] [FLINK-38100] Bump Iceberg dependency to 1.10.0 in iceberg-pipeline-sink connector [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38437) Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator Jira
• [jira] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)
• [jira] [Commented] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)
  • [jira] [Commented] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)
• [PR] [FLINK-38100] bump iceberg to 1.10.0 for iceberg-pipeline-connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38100] bump iceberg to 1.10.0 for iceberg-pipeline-connector [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38360) HadoopRecoverableWriterTest#testRecoverWithState failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)
• [jira] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)

• Earlier messages
• Later messages