dev  

Messages by Thread

• • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Ferenc Csaky
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Mate Czagany
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Gabor Somogyi
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
• is there a uber-jar solution in flink? I hate shade abusing. Xeno Amess
  • Re: is there a uber-jar solution in flink? I hate shade abusing. David Radley
  • Re: is there a uber-jar solution in flink? I hate shade abusing. Xeno Amess
  • RE: is there a uber-jar solution in flink? I hate shade abusing. David Radley
• [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Dawid Wysakowicz
  • Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Arvid Heise
  • Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Feng Jin
  • Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Gustavo de Morais
  • Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
• [jira] [Created] (FLINK-38514) Postgres YAML CDC support UUID_ARRAY Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38510) Remove targetColumns in SinkReuser xiangyu feng (Jira)
• [jira] [Created] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38504) Add restore test for delta join Xuyang Zhong (Jira)
• [Discuss] JDBC Connector SplitReader pass ResultSet with cursor at the first row-resend with the right tag clara xiong
• [jira] [Created] (FLINK-38488) Use 'throws Exception' instead of try-catch-fail in tests in flink-tests Mingliang Liu (Jira)
• [jira] [Created] (FLINK-38497) FLIP-535:Introduce RateLimiter to Source Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound Etienne Chauchot (Jira)
• [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Feng Jin
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Feng Jin
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
• [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Timo Walther
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ramin Gharib
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Gustavo de Morais
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Lincoln Lee
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Arvid Heise
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Feng Jin
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
• [jira] [Created] (FLINK-38477) Add FINISHED watermark status to support proper watermark aggregation Weiqing Yang (Jira)
• [jira] [Created] (FLINK-38476) Add FINISHED watermark status to support proper watermark aggregation Weiqing Yang (Jira)
• [jira] [Created] (FLINK-38415) IndexOutOfBoundsException occasionally occursIndexOutOfBoundsException in rocksdb.use-ingest-db-restore-mode after rocksdb.use-ingest-db-restore-mode is enabled Rui Fan (Jira)
• [jira] [Created] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector Fabian Paul (Jira)
• [jira] [Created] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow Wren (Jira)
• DEFAULT values for columns David Anderson
  • Re: DEFAULT values for columns Timo Walther
  • Re: DEFAULT values for columns David Anderson
  • Re: DEFAULT values for columns Gustavo de Morais
• [jira] [Created] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38455) MySQL CDC to ES8 pipeline connector cannot work li yong (Jira)
• [DISCUSS] Flink 2.0.1 release Zakelly Lan
  • Re: [DISCUSS] Flink 2.0.1 release Gabor Somogyi
  • Re: [DISCUSS] Flink 2.0.1 release Ferenc Csaky
• Missing CommittableSummary fix in release 1.20.0 Chibaev, Ilia
  • Re: Missing CommittableSummary fix in release 1.20.0 Arvid Heise
• [jira] [Created] (FLINK-38450) flink-cdc sink to iceberg table record duplication ChaoFang (Jira)
• [RESULT][VOTE] FLIP-547: Support checkpoint during recovery Rui Fan
• [jira] [Created] (FLINK-38423) Add vector search connector API Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38448) Fix doc CI rsync logic Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38449) Makes error message for fractional values for MemorySize explicit Navin Viswanath (Jira)
• [jira] [Created] (FLINK-38447) Add table sink support for Elasticsearch 8 connector lwn (Jira)
• [jira] [Created] (FLINK-38446) Pyflink explain() crashes with Index Out Of Bounds Ahmad Humayun (Jira)
• Request: Update Flink Docker Image Base OS to Ubuntu 24 (Noble) due to Security Vulnerabilities Rahul Pandey (rahulte)
• [jira] [Created] (FLINK-38428) Support to call vector search with literal value Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38443) Adapt TIDB CDC Connector to FLIP-27 API Yanquan Lv (Jira)
• [ANNOUNCE] Apache Flink CDC 3.5.0 released Yanquan Lv
• [RESULT][VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Ferenc Csaky
  • Re: [RESULT][VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable Sergey Nuyanzin (Jira)
• [RESULT] [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Yanquan Lv
• [KINDLY REMINDER] Flink 2.2 Release Sync Hang Ruan
  • Re: [KINDLY REMINDER] Flink 2.2 Release Sync Rui Fan
  • Re: [KINDLY REMINDER] Flink 2.2 Release Sync Sergey Nuyanzin
• [KINDLY REMINDER] Flink 2.1 Release Sync Hang Ruan
  • Re: [KINDLY REMINDER] Flink 2.1 Release Sync Hang Ruan
• [jira] [Created] (FLINK-38412) Refactor MultiJoin test with state ttl to avoid state expiration Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong ChaoFang (Jira)
• [jira] [Created] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table Ruan Hang (Jira)
• [jira] [Created] (FLINK-38438) Support session mini cluster when use local executor. Weijun Wang (Jira)
• [jira] [Created] (FLINK-38420) Initial BlueGreenDeployment code contribution Gyula Fora (Jira)
• Request for slack invite Royston Tauro
  • Re: Request for slack invite Gustavo de Morais
• Request to merge http connector contribution David Radley
• [jira] [Created] (FLINK-38436) Add document for VECTOR_SEARCH function Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38434) Avoid delete ForSt's directory when there happened to be an existing one Zakelly Lan (Jira)
• Request for Apache Flink Slack Invite Doanh
  • Re: Request for Apache Flink Slack Invite Gustavo de Morais
• [jira] [Created] (FLINK-38432) Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter Frank Wong (Jira)
• [jira] [Created] (FLINK-38429) Improve perf for Elasticsearch 8 connector Jiaan Geng (Jira)
• [jira] [Created] (FLINK-38431) Support VECTOR_SEARCH in batch mode Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38430) Support runtime config for VECTOR_SEARCH Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38422) FLIP-540: Support VECTOR_SEARCH in Flink SQL Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38418) Collecting TIMESTAMP_LTZ values in PyFlink fails with pickling error Mika Naylor (Jira)
• [jira] [Created] (FLINK-38426) Reuse Lookup Join operator to build search operator Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38425) Add rule to convert correlate node to vector search node in physical phase Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38427) Support to serde vector search execnode Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38421) BlueGreen Deployment Documentation Gyula Fora (Jira)
• Support LIMIT syntax with SHOW queries Ryan van Huuksloot
  • Re: Support LIMIT syntax with SHOW queries Sriram Ganesh
  • Re: Support LIMIT syntax with SHOW queries Shengkai Fang
  • Re: Support LIMIT syntax with SHOW queries Ryan van Huuksloot
  • Re: Support LIMIT syntax with SHOW queries Shengkai Fang
• [jira] [Created] (FLINK-38419) Update official Flink docker images Derek Chen-Becker (Jira)
• [jira] [Created] (FLINK-38417) Ensure attribute ordering when managing join attributes in JoinKeyExtractor Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38413) Support Append Only table from MySQL Pipeline Connectors Muhammad (Jira)
• [VOTE] FLIP-547: Support checkpoint during recovery Rui Fan
  • Re: [VOTE] FLIP-547: Support checkpoint during recovery Zakelly Lan
  • Re: [VOTE] FLIP-547: Support checkpoint during recovery Gabor Somogyi
  • Re: [VOTE] FLIP-547: Support checkpoint during recovery Yuepeng Pan
  • Re: [VOTE] FLIP-547: Support checkpoint during recovery Roman Khachatryan
  • Re: [VOTE] FLIP-547: Support checkpoint during recovery Piotr Nowojski
  • Re: [VOTE] FLIP-547: Support checkpoint during recovery Rui Fan
• [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Zhu Zhu
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Lei Yang
  • Re: [DISCUSS] FLIP-549: Support Application Management Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Lei Yang
  • Re: [DISCUSS] FLIP-549: Support Application Management Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Kartikey Pant
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Shengkai Fang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Venkatakrishnan Sowrirajan
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
• [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li via dev
• [jira] [Created] (FLINK-38411) Array index overflow in enumerator with continuous file source Simon Frei (Jira)
• [VOTE] Apache Flink CDC Release 3.5.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #2 Xiqian YU
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #2 Yanquan Lv
• [jira] [Created] (FLINK-38409) Showcase in Helm chart values.yaml that config.yaml can be used Jira
• [jira] [Created] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table Ruan Hang (Jira)
• [jira] [Created] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38407) GroupAggregateRestoreTest failed in test_cron_azure table Ruan Hang (Jira)
• [jira] [Created] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’ ouyangwulin (Jira)
• [jira] [Created] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result lincoln lee (Jira)
• [jira] [Created] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38397) Runtime Exception in Planner Ahmad Humayun (Jira)
• [jira] [Created] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• [VOTE] Release 1.20.3, release candidate #1 Xuannan Su
  • Re: [VOTE] Release 1.20.3, release candidate #1 Xintong Song
  • Re: [VOTE] Release 1.20.3, release candidate #1 Zakelly Lan
  • Re: [VOTE] Release 1.20.3, release candidate #1 Dian Fu
  • Re: [VOTE] Release 1.20.3, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.20.3, release candidate #1 Maximilian Michels
  • Re: [VOTE] Release 1.20.3, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 1.20.3, release candidate #1 Xuannan Su
  • ???? ????
• [jira] [Created] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by() Ahmad Humayun (Jira)
• [jira] [Created] (FLINK-38341) Introduce the rescale history configuration option. RocMarshal (Jira)
• [jira] [Created] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments Sergio Chong (Jira)

• Earlier messages
• Later messages