issues  

Messages by Thread

• [PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink] via GitHub
  • [PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37387][build] Enable license check for jdk17 and jdk21 [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37387][build] Enable license check for jdk17 and jdk21 [flink] via GitHub
• [jira] [Updated] (FLINK-37298) Custom Batch Handling in AsyncSink Poorvank Bhatia (Jira)
  • [jira] [Updated] (FLINK-37298) Custom Batch Handling in AsyncSink ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37396) Kafka connector python test fail Hongshun Wang (Jira)
• [PR] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
• Re: [PR] [HOTFIX][DOCS] fix option name [flink-connector-mongodb] via GitHub
  • Re: [PR] [hotfix][docs] fix option name [flink-connector-mongodb] via GitHub
  • Re: [PR] [hotfix][docs] fix option name [flink-connector-mongodb] via GitHub
• [jira] [Closed] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException Xuyang Zhong (Jira)
• [jira] [Reopened] (FLINK-37162) Add Data Sink Documentation Leonard Xu (Jira)
• [jira] [Comment Edited] (FLINK-37162) Add Data Sink Documentation Leonard Xu (Jira)
• [PR] [minor][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [minor][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [minor][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [minor][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [minor][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
  • Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink] via GitHub
• [jira] [Comment Edited] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” Yutong Han (Jira)
  • [jira] [Comment Edited] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” Yutong Han (Jira)
  • [jira] [Comment Edited] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” xuhuang (Jira)
• [jira] [Created] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered zexin gong (Jira)
• [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Ex… [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Ex… [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Exactly once [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Exactly once [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Exactly once [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Exactly once [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-33734] Merge unaligned checkpoint state handle [flink] via GitHub
  • Re: [PR] [FLINK-33734] Merge unaligned checkpoint state handle [flink] via GitHub
  • Re: [PR] [FLINK-33734] Merge unaligned checkpoint state handle [flink] via GitHub
  • Re: [PR] [FLINK-33734] Merge unaligned checkpoint state handle [flink] via GitHub
• [jira] [Commented] (FLINK-37388) [BUG] Field names must be unique. zexin gong (Jira)
  • [jira] [Commented] (FLINK-37388) [BUG] Field names must be unique. zexin gong (Jira)
• Re: [PR] [FLINK-36061] Support Iceberg CDC Pipeline SinkV2 [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36061] Support Iceberg CDC Pipeline SinkV2 [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException Shengkai Fang (Jira)
• [jira] [Commented] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException Shengkai Fang (Jira)
  • [jira] [Commented] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException Xuyang Zhong (Jira)
• [PR] CP [FLINK-37337][sql-client] No need to add sql-client jar as job depend… [flink] via GitHub
  • Re: [PR] CP [FLINK-37337][sql-client] No need to add sql-client jar as job depend… [flink] via GitHub
  • Re: [PR] CP [FLINK-37337][sql-client] No need to add sql-client jar as job depend… [flink] via GitHub
• Re: [PR] [FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-36402) Improper variable naming ASF GitHub Bot (Jira)
• [PR] FLINK-36402: edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
  • Re: [PR] FLINK-36402: edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
  • Re: [PR] FLINK-36402: edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
  • Re: [PR] FLINK-36402: edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
• [PR] edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
  • Re: [PR] edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
  • Re: [PR] [FLINK-36402] edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
  • Re: [PR] [FLINK-36402] edgeRemapings typo fixed to edgeRemappings [flink] via GitHub
• Re: [PR] [FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format [flink] via GitHub
  • Re: [PR] [FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format [flink] via GitHub
• [jira] [Assigned] (FLINK-36402) Improper variable naming Yun Tang (Jira)
• [PR] [hotfix] fix data race in method in [flink] via GitHub
  • Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
  • Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
  • Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
  • Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
  • Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
  • Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink] via GitHub
• [jira] [Updated] (FLINK-36855) Implement Source API in Kudu connector ASF GitHub Bot (Jira)
• [PR] [hotfix] Rename SparkJoinReorderRule to FlinkJoinReorderRule [flink] via GitHub
  • Re: [PR] [hotfix] Rename SparkJoinReorderRule to FlinkJoinReorderRule [flink] via GitHub
  • Re: [PR] [hotfix] Rename SparkJoinReorderRule to FlinkJoinReorderRule [flink] via GitHub
  • Re: [PR] [hotfix] Rename SparkJoinReorderRule to FlinkJoinReorderRule [flink] via GitHub
  • Re: [PR] [hotfix] Rename SparkJoinReorderRule to FlinkJoinReorderRule [flink] via GitHub
• Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu] via GitHub
• [jira] [Closed] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector Ferenc Csaky (Jira)
• Re: [PR] [FLINK-37394] Update CI Flink versions to 1.19 and 1.20 [flink-connector-kudu] via GitHub
• Re: [PR] [FLINK-37376] Upgrade flink-shaded to 20.0 [flink-benchmarks] via GitHub
• [jira] [Assigned] (FLINK-36855) Implement Source API in Kudu connector Ferenc Csaky (Jira)
• [jira] [Commented] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state Luca Castelli (Jira)
  • [jira] [Commented] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state junzhong qin (Jira)
• [jira] [Updated] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-37394) Update supported Flink versions to 1.19 and 1.20 in Kudu connector Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector Ferenc Csaky (Jira)
• [jira] [Resolved] (FLINK-37374) Support JSON built-in function for JSON_ARRAY Dawid Wysakowicz (Jira)
• [jira] [Updated] (FLINK-37393) Abnormally Long Checkpoint Duration After Full Checkpoint Completion Rafael Zimmermann (Jira)
• [jira] [Created] (FLINK-37393) Abnormally Long Checkpoint Duration After Full Checkpoint Completion Rafael Zimmermann (Jira)
• [jira] [Updated] (FLINK-37389) Add "flink-sql-connector-kudu" module ASF GitHub Bot (Jira)
• [PR] [FLINK-37389] Add `flink-sql-connector-kudu` module [flink-connector-kudu] via GitHub
• [jira] [Updated] (FLINK-37385) Add support for smile format in flink main repo ASF GitHub Bot (Jira)
• [PR] [FLINK-37385][table] Add support for smile format [flink] via GitHub
  • Re: [PR] [FLINK-37385][table] Add support for smile format [flink] via GitHub
  • Re: [PR] [FLINK-37385][table] Add support for smile format [flink] via GitHub
  • Re: [PR] [FLINK-37385][table] Add support for smile format [flink] via GitHub
  • Re: [PR] [FLINK-37385][table] Add support for smile format [flink] via GitHub
  • Re: [PR] [FLINK-37385][table] Add support for smile format [flink] via GitHub
  • Re: [PR] [FLINK-37385][table] Add support for smile format [flink] via GitHub
• [PR] [FLINK-37390] Push filter into ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-37390] Push filter into ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-37390] Push filter into ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-37390] Push filter into ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-37390] Push filter into ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-37390] Push filter into ChangelogNormalize [flink] via GitHub
• [jira] [Created] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state junzhong qin (Jira)
• [jira] [Created] (FLINK-37391) Change watchNamespace config in operator is not respected while running Fabian Paul (Jira)
• [jira] [Created] (FLINK-37390) Push filter into ChangelogNormalize Dawid Wysakowicz (Jira)
• [jira] [Updated] (FLINK-37390) Push filter into ChangelogNormalize Dawid Wysakowicz (Jira)
  • [jira] [Updated] (FLINK-37390) Push filter into ChangelogNormalize ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37389) Add "flink-sql-connector-kudu" module Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37388) [BUG] Field names must be unique. zexin gong (Jira)
• [PR] [BP-2.0][FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise [flink] via GitHub
• [jira] [Created] (FLINK-37387) License check behaves differently for different jdk versions Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-35350) Add documentation for Kudu Ferenc Csaky (Jira)
• [PR] [hotfix] Update failureaccess in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [hotfix] Update failureaccess in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [hotfix] Update failureaccess in order to fix java 11 license check [flink] via GitHub
  • Re: [PR] [hotfix] Update failureaccess in order to fix java 11 license check [flink] via GitHub
• [PR] [FLINK-37278] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37386) Avoid sending too much CreateTableEvents when job failover Yanquan Lv (Jira)
• [PR] [FLINK-37366] Allow configurable retry for Kafka topic metadata fetch [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37366] Allow configurable retry for Kafka topic metadata fetch [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37366] Allow configurable retry for Kafka topic metadata fetch [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37366] Allow configurable retry for Kafka topic metadata fetch [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-37366) Allow configurable retry for Kafka topic metadata fetch ASF GitHub Bot (Jira)
• [PR] [FLINK-37337][sql-client] No need to add sql-client jar [flink] via GitHub
  • Re: [PR] [FLINK-37337][sql-client] No need to add sql-client jar as job dependencies [flink] via GitHub

• Earlier messages
• Later messages