issues  

Messages by Thread

• • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. [flink-cdc] via GitHub
• [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java] Introduce Long-Term Memory. [flink-agents] via GitHub
• [jira] [Commented] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated Royston Tauro (Jira)
  • [jira] [Commented] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated Royston Tauro (Jira)
• [jira] [Updated] (FLINK-38882) Introduce rules for async python scalar function ASF GitHub Bot (Jira)
• [PR] [FLINK-38882][table] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
  • Re: [PR] [FLINK-38882][table][python] Introduce rules for async python scalar function [flink] via GitHub
• [jira] [Created] (FLINK-38882) Introduce rules for async python scalar function Dian Fu (Jira)
• Re: [PR] [FLINK-38183] Fix the problem of data loss in the GTID disordered scenario [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-38596) The comment of the created MaxCompute table is incorrect Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38881) PostgreSQL Partition Table Routing Support tchivs (Jira)
• [jira] [Created] (FLINK-38881) PostgreSQL Partition Table Routing Support tchivs (Jira)
• [jira] [Updated] (FLINK-38877) Introduce VARIANT type to Flink CDC pipeline ASF GitHub Bot (Jira)
• [PR] [FLINK-38877][common] Add variant type. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38877][common] Add variant type. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38877][common] Add variant type. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38877][common] Add variant type. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38877][common] Add variant type. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38877][common] Add variant type. [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Zhu Zhu (Jira)
• [PR] [FLINK-XXXXX][postgres] Support partition table routing for PostgreSQL CDC [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38880) Add async scalar function support in Python Dian Fu (Jira)
• [jira] [Resolved] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink Dian Fu (Jira)
• [jira] [Created] (FLINK-38879) Add VARIANT type support in Paimon pipeline sink Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38878) Add PARSE_JSON/TRY_PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38877) Introduce VARIANT type to Flink CDC pipeline Yanquan Lv (Jira)
• Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.4 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• [jira] [Updated] (FLINK-38596) The comment of the created MaxCompute table is incorrect ASF GitHub Bot (Jira)
• [PR] [FLINK-38596][pipeline][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38596][pipeline][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38596][pipeline][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38596][pipeline][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent [flink-cdc] via GitHub
• [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38577) FlinkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable ASF GitHub Bot (Jira)
• [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ boxes (Jira)
• [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ boxes (Jira)
• [I] [Feature] Support Fine-Grain Durable Execution [flink-agents] via GitHub
  • Re: [I] [Feature] Support Fine-Grain Durable Execution [flink-agents] via GitHub
  • Re: [I] [Feature] Support Fine-Grain Durable Execution [flink-agents] via GitHub
• [jira] [Closed] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• [jira] [Assigned] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• [jira] [Updated] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• [jira] [Commented] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• [PR] [runtime] Introduce CallRecord to ActionState [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
  • Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
• Re: [PR] [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink [flink-cdc] via GitHub
• [jira] [Comment Edited] (FLINK-38817) Out of order data seen while running tpc-ds queries Bonnie Varghese (Jira)
  • [jira] [Comment Edited] (FLINK-38817) Out of order data seen while running tpc-ds queries Zhu Zhu (Jira)
• [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink Bowen Li (Jira)
  • [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink Dian Fu (Jira)
• Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
  • Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
  • Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
  • Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
  • Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
  • Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
  • Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
• [jira] [Assigned] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• [jira] [Created] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
  • [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
  • [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38263) Connection and secret factory ASF GitHub Bot (Jira)
• [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
  • Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
• Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
  • Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
  • Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
  • Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
• Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
• [PR] [FLINK-38875] Bump Java Operator SDK to version 5.2.2 [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38875] Bump Java Operator SDK to version 5.2.2 [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38875] Bump Java Operator SDK to version 5.2.2 [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 Jira
• [jira] [Updated] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 Jira
  • [jira] [Updated] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Yi Zhang (Jira)
  • [jira] [Updated] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Yi Zhang (Jira)
• [jira] [Commented] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• Re: [I] [Feature] Support local execution in Java [flink-agents] via GitHub
  • Re: [I] [Feature] Support local execution in Java [flink-agents] via GitHub
• Re: [I] [Tech Debt] Improve Ollama related tests(start_ollama_server.sh) in CI [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Improve Ollama related tests(start_ollama_server.sh) in CI [flink-agents] via GitHub
• Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] via GitHub

• Earlier messages
• Later messages