issues  

Messages by Thread

• [D] [Discussion] Pluggable model routing — API & design (PR #852 follow-up) [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-39783) Add translation rules to convert lateral call of SNAPSHOT function into join operator Fabian Hueske (Jira)
• [PR] Yd/fix observed generation suspended [flink-kubernetes-operator] via GitHub
• [jira] [Assigned] (FLINK-31931) Exception history page should not link to a non-existent TM log page. Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40035) Add smoke-level component specs for the web-dashboard Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40113) State restore does not validate max-parallelism agreement between operators sharing a vertex Piotr Nowojski (Jira)
• [jira] [Commented] (FLINK-39943) IS [NOT ]JSON changed nullability after upgrade to Calcite 1.38.0 Fabian Hueske (Jira)
• [jira] [Assigned] (FLINK-39943) IS [NOT ]JSON changed nullability after upgrade to Calcite 1.38.0 Fabian Hueske (Jira)
• [jira] [Closed] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-40133) Update HBase version to 2.6.6 Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40133) Update HBase version to 2.6.6 Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-40133) Update HBase version to 2.6.6 Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
• [jira] [Created] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
• [jira] [Updated] (FLINK-37925) Support type casting between variant and primitive type ASF GitHub Bot (Jira)
• [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Support casting from VARIANT to primitive types [flink] via GitHub
• [jira] [Resolved] (FLINK-39760) Fix missing JTS core dependency of PostgreSQL YAML connector Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink Yanquan Lv (Jira)
• [PR] [docs] Improve Incremental Snapshot Reading formatting and references [flink-cdc] via GitHub
  • Re: [PR] [docs] Improve Incremental Snapshot Reading formatting and references [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• [jira] [Updated] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-40126) Implement Topic integrity checks in Kafka Connector Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-37925) Support type casting between variant and primitive type Ramin Gharib (Jira)
• [PR] [FLINK-39984][runtime][webUI] Dispatch thread dump to ioExecutor and support SAFE/FULL modes [flink] via GitHub
  • Re: [PR] [FLINK-39984][runtime][webUI] Dispatch thread dump to ioExecutor and support SAFE/FULL modes [flink] via GitHub
• Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink] via GitHub
• [jira] [Assigned] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
• Re: [PR] [FLINK-39285][table] Ignore project rel node generated by FlinkFilterJoinRule in JoinToMultiJoinRule [flink] via GitHub
  • Re: [PR] [FLINK-39285][table] Ignore project rel node generated by FlinkFilterJoinRule in JoinToMultiJoinRule [flink] via GitHub
• Re: [PR] [FLINK-39237][Doc] Decouple flink-training links from the Flink branch [flink] via GitHub
  • Re: [PR] [FLINK-39237][Doc] Decouple flink-training links from the Flink branch [flink] via GitHub
• Re: [PR] Bump org.apache.avro:avro from 1.11.4 to 1.11.5 [flink] via GitHub
• [PR] [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40130][connect/paimon] Fix missing primary key type compatibility check of Paimon sink [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-33152) Prometheus Sink Connector - Integration tests ASF GitHub Bot (Jira)
• [PR] [FLINK-33152][Flink-connector-prometheus] Integration Tests [flink-connector-prometheus] via GitHub
• [jira] [Commented] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink Mao Jiayi (Jira)
• [jira] [Assigned] (FLINK-34423) Make tool/ci/compile_ci.sh not necessarily rely on clean phase Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-34423) Make tool/ci/compile_ci.sh not necessarily rely on clean phase Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-34423) Make tool/ci/compile_ci.sh not necessarily rely on clean phase Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join Xuyang Zhong (Jira)
  • [jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join Shuai Xu (Jira)
• [PR] [python] Avoid forking MCP test server from PyFlink process [flink-agents] via GitHub
  • Re: [PR] [test][python] Avoid forking MCP test server from PyFlink process [flink-agents] via GitHub
• [PR] [ci] Exclude Flink compatibility modules from Javadoc [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-34423) Make tool/ci/compile_ci.sh not necessarily rely on clean phase ASF GitHub Bot (Jira)
• [PR] [FLINK-34423][ci] Make `tools/ci/compile_ci.sh` not necessarily rely on clean phase [flink] via GitHub
  • Re: [PR] [FLINK-34423][ci] Make `tools/ci/compile_ci.sh` not necessarily rely on clean phase [flink] via GitHub
  • Re: [PR] [FLINK-34423][ci] Make `tools/ci/compile_ci.sh` not necessarily rely on clean phase [flink] via GitHub
  • Re: [PR] [FLINK-34423][ci] Make `tools/ci/compile_ci.sh` not necessarily rely on clean phase [flink] via GitHub
  • Re: [PR] [FLINK-34423][ci] Make `tools/ci/compile_ci.sh` not necessarily rely on clean phase [flink] via GitHub
• Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] via GitHub
• [PR] [kubernetes] Graceful TaskManager termination + fix wrong-signal TODO in ResourceManager [flink] via GitHub
  • Re: [PR] [kubernetes] Graceful TaskManager termination + fix wrong-signal TODO in ResourceManager [flink] via GitHub
  • Re: [PR] [kubernetes] Graceful TaskManager termination + fix wrong-signal TODO in ResourceManager [flink] via GitHub
• [jira] [Resolved] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
• [PR] [FLINK-38727][test] Backport to release-2.1: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
  • Re: [PR] [FLINK-38727][test] Backport to release-2.1: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
• [PR] [FLINK-38727][test] Backport to release-2.2: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
  • Re: [PR] [FLINK-38727][test] Backport to release-2.2: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
• [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Efrat Levitan (Jira)
  • [jira] [Updated] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Static source Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source Efrat Levitan (Jira)
• [jira] [Created] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Datasteam Efrat Levitan (Jira)
• [PR] tests passing for topic-integrity-source-only [flink-connector-kafka] via GitHub
• [PR] [BP-1.20][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
• [PR] [BP-2.1][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
• [PR] [BP-2.2][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
• [PR] [FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40125][ci] Add auto cancel for concurrently running jobs [flink] via GitHub
• [jira] [Commented] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40125) Add auto cancel for concurrently running jobs Sergey Nuyanzin (Jira)
• [PR] [hotfix][runtime-web] Fix savepointPath query parameter in JarService.runJob() [flink] via GitHub
  • Re: [PR] [hotfix][runtime-web] Fix savepointPath query parameter in JarService.runJob() [flink] via GitHub
  • Re: [PR] [hotfix][runtime-web] Fix savepointPath query parameter in JarService.runJob() [flink] via GitHub
• [jira] [Updated] (FLINK-40127) JDBC connector: 37 files ship without the required ASF license header ASF GitHub Bot (Jira)
• [PR] [FLINK-40127][jdbc] Add missing ASF license headers [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40127][jdbc] Add missing ASF license headers [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40127][jdbc] Add missing ASF license headers [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40127][jdbc] Add missing ASF license headers [flink-connector-jdbc] via GitHub
• [jira] [Created] (FLINK-40127) JDBC connector: 37 files ship without the required ASF license header Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40126) Implement Topic integrity checks in Kafka Connector Efrat Levitan (Jira)
• [PR] [hotfix] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-40125) Add auto cancel for concurrently run jobs ASF GitHub Bot (Jira)
• [PR] [FLINK-40125][ci] Add auto cancel for concurrently run jobs [flink] via GitHub
  • Re: [PR] [FLINK-40125][ci] Add auto cancel for concurrently run jobs [flink] via GitHub
  • Re: [PR] [FLINK-40125][ci] Add auto cancel for concurrently run jobs [flink] via GitHub
  • Re: [PR] [FLINK-40125][ci] Add auto cancel for concurrently run jobs [flink] via GitHub
• [jira] [Created] (FLINK-40125) Add auto cancel for concurrently run jobs Sergey Nuyanzin (Jira)
• [PR] [FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
  • Re: [PR] [FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
  • Re: [PR] [FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
  • [PR] [FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
  • Re: [PR] [FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40124][ci] Do not store cache on every run if no dependency changed [flink] via GitHub
• [jira] [Updated] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change Sergey Nuyanzin (Jira)
• Re: [PR] [hotfix] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-jdbc] via GitHub
• Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
• Re: [PR] [FLINK-39218] Introduce Flink-Kafka Transactions Management Tool [flink-connector-kafka] via GitHub
• [PR] [hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner [flink-cdc] via GitHub
  • Re: [PR] [hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner [flink-cdc] via GitHub
  • Re: [PR] [hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner [flink-cdc] via GitHub
• Re: [PR] [hotfix] disk space and file descriptor leaks in ChangelogStreamHandleReaderWithCache [flink] via GitHub
  • Re: [PR] [hotfix] disk space and file descriptor leaks in ChangelogStreamHandleReaderWithCache [flink] via GitHub
• Re: [PR] [hotfix][docs] Fix broken and stale documentation links [flink] via GitHub
• [jira] [Commented] (FLINK-38592) [Phase 1] Native Flink S3 FileSystem Michael Johnson (Jira)
• [jira] [Commented] (FLINK-38350) Update Hadoop Library to 3.4.2 Michael Johnson (Jira)
• [jira] [Resolved] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 ASF GitHub Bot (Jira)
• [PR] [FLINK-40121] Update to Flink 2.3.0 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40121] Update to Flink 2.3.0 [flink-connector-kafka] via GitHub
• [PR] [hotfix] Use `systemPropertyVariables` instead of `systemProperties` [flink] via GitHub
  • Re: [PR] [hotfix][build] Use `systemPropertyVariables` instead of `systemProperties` [flink] via GitHub
  • Re: [PR] [hotfix][build] Use `systemPropertyVariables` instead of `systemProperties` [flink] via GitHub
  • Re: [PR] [hotfix][build] Use `systemPropertyVariables` instead of `systemProperties` [flink] via GitHub
• [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Shekhar Prasad Rajak (Jira)
• [jira] [Created] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Shekhar Prasad Rajak (Jira)
• Re: [PR] Kafka 4.x Queue Semantics support [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-39571) Improve Flink Kubernetes Operator documentation coverage Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-40122) Expose a public getter for the persisted RowData field names ASF GitHub Bot (Jira)
• [PR] [FLINK-40122][table] Expose a public getter for the persisted RowData field names [flink] via GitHub
  • Re: [PR] [FLINK-40122][table] Expose a public getter for the persisted RowData field names [flink] via GitHub
  • Re: [PR] [FLINK-40122][table] Expose a public getter for the persisted RowData field names [flink] via GitHub
  • Re: [PR] [FLINK-40122][table] Expose a public getter for the persisted RowData field names [flink] via GitHub
• [jira] [Created] (FLINK-40122) Expose a public getter for the persisted RowData field names Weiqing Yang (Jira)
• [PR] [FLINK-40120][table] Persist RowData field names in RowDataSerializerSnapshot [flink] via GitHub
  • Re: [PR] [FLINK-40120][table] Persist RowData field names in RowDataSerializerSnapshot [flink] via GitHub
  • Re: [PR] [FLINK-40120][table] Persist RowData field names in RowDataSerializerSnapshot [flink] via GitHub
• [jira] [Updated] (FLINK-34807) [Feature][mysql] Mysql-cdc source adapts mariadb. ASF GitHub Bot (Jira)
• [PR] [FLINK-34807][mysql] Add MariaDB GTID support [flink-cdc] via GitHub
• Re: [PR] [FLINK-38023][formats] Fix GenericRecord Avro state migration [flink] via GitHub
• [PR] [python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [python] Prevent Beam state access after runner shutdown [flink] via GitHub
• Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot Weiqing Yang (Jira)
  • [jira] [Updated] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Sylwester Lachiewicz (Jira)
• [jira] [Updated] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 ASF GitHub Bot (Jira)
• [PR] [FLINK-40066][Connectors/MongoDB] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-40066][Connectors/MongoDB] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-40066][Connectors/MongoDB] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-40066][Connectors/MongoDB] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-40066][Connectors/MongoDB] Update flink-connector-parent to 2.0.0 and Flink to 2.1.2 [flink-connector-mongodb] via GitHub
• [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
• [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
  • Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
  • Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
  • Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
  • Re: [PR] [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism [flink] via GitHub
• [jira] [Updated] (FLINK-40119) Blue/Green: after an aborted transition, the next deploy deletes Blue immediately instead of waiting the deletion delay ASF GitHub Bot (Jira)

• Earlier messages