dev  

Messages by Thread

• [jira] [Created] (FLINK-35703) Nested comments in CREAT TABLE are lost Dawid Wysakowicz (Jira)
• Broken links to flink-training repository in documentation Aleksandr Pilipenko
• [jira] [Created] (FLINK-35702) Support Parquet Nested Read Wenchao Wu (Jira)
• [jira] [Created] (FLINK-35701) SqlServer the primary key type is uniqueidentifier, the scan.incremental.snapshot.chunk.size parameter does not take effect during split chunk yangxiao (Jira)
• [SUMMARY] Flink 1.20 Release Sync 06/25/2024 weijie guo
• [jira] [Created] (FLINK-35700) Loosen CDC pipeline options validation yux (Jira)
• [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION Natea Eshetu Beshada
  • Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION Jim Hughes
  • Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION Natea Eshetu Beshada
  • Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION Yanquan Lv
  • Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION Feng Jin
  • Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION Timo Walther
  • Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION Natea Eshetu Beshada
• [jira] [Created] (FLINK-35699) The flink-kubernetes artifact shades Jackson 2.15.3 from fabric8 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-35698) Parquet connector fails to load ROW<x decimal(5, 2)> after save Andrey Gaskov (Jira)
• [jira] [Created] (FLINK-35697) Release Testing: Verify FLIP-451 Introduce timeout configuration to AsyncSink Ahmed Hamdy (Jira)
• [jira] [Created] (FLINK-35696) JSON_VALUE/QUERY functions incorrectly map floating numbers Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-35695) Release Testing: Verify FLINK-32315: Support local file upload in K8s mode Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-35694) Flink-end-to-end-test kubernetes fails due to hostname --ip-adress command David Kornel (Jira)
• [VOTE] FLIP-444: Native file copy support Piotr Nowojski
  • Re: [VOTE] FLIP-444: Native file copy support Zakelly Lan
  • Re: [VOTE] FLIP-444: Native file copy support Piotr Nowojski
  • Re: [VOTE] FLIP-444: Native file copy support Piotr Nowojski
  • Re: [VOTE] FLIP-444: Native file copy support Roman Khachatryan
  • Re: [VOTE] FLIP-444: Native file copy support Yuepeng Pan
  • Re: [VOTE] FLIP-444: Native file copy support Zakelly Lan
  • Re: [VOTE] FLIP-444: Native file copy support Keith Lee
  • Re: [VOTE] FLIP-444: Native file copy support yue ma
  • Re:[VOTE] FLIP-444: Native file copy support Feifan Wang
  • Re:[VOTE] FLIP-444: Native file copy support Ferenc Csaky
  • Re: [VOTE] FLIP-444: Native file copy support Piotr Nowojski
  • Re: [VOTE] FLIP-444: Native file copy support Hong
  • Re: [VOTE] FLIP-444: Native file copy support Stefan Richter
  • Re: [VOTE] FLIP-444: Native file copy support Rui Fan
  • Re: [VOTE] FLIP-444: Native file copy support Martijn Visser
  • Re: [VOTE] FLIP-444: Native file copy support Ahmed Hamdy
• [2.0] How to handle on-going feature development in Flink 2.0? Matthias Pohl
  • Re: [2.0] How to handle on-going feature development in Flink 2.0? David Radley
  • Re: [2.0] How to handle on-going feature development in Flink 2.0? Becket Qin
  • Re: [2.0] How to handle on-going feature development in Flink 2.0? Xintong Song
  • Re: [2.0] How to handle on-going feature development in Flink 2.0? Jark Wu
  • Re: [2.0] How to handle on-going feature development in Flink 2.0? Jingsong Li
  • Re: [2.0] How to handle on-going feature development in Flink 2.0? Zakelly Lan
  • Re: [2.0] How to handle on-going feature development in Flink 2.0? Matthias Pohl
• [jira] [Created] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Hongshun Wang (Jira)
• [jira] [Created] (FLINK-35692) Remove hugo_extended package introduced by wrong operation dalongliu (Jira)
• [jira] [Created] (FLINK-35691) Fix the bugs found in releasing testing of Materialized Table dalongliu (Jira)
• [jira] [Created] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn Yuxin Tan (Jira)
• [jira] [Created] (FLINK-35689) CLONE - Release Testing: Verify FLIP-435 & FLIP-448: Introduce a New Materialized Table for Simplifying Data Pipelines dalongliu (Jira)
• [jira] [Created] (FLINK-35688) Add materialized table develop guide docs dalongliu (Jira)
• [ANNOUNCE] release-1.20 branch cut weijie guo
• [jira] [Created] (FLINK-35687) JSON_QUERY should return a proper JSON for ARRAY<STRING> Dawid Wysakowicz (Jira)
• Flink-connector-jdbc v3.2.0 support flink 1.17.x? Jerry
  • Re: Flink-connector-jdbc v3.2.0 support flink 1.17.x? Muhammet Orazov
• [jira] [Created] (FLINK-35686) Flink-connector-jdbc v3.2.0 support flink 1.17.x ZhengJunZhou (Jira)
• [jira] [Created] (FLINK-35685) Some metrics in the MetricStore are duplicated when increasing or decreasing task parallelism elon_X (Jira)
• [jira] [Created] (FLINK-35684) Add missing option for DataSource and DataSink LvYanquan (Jira)
• [jira] [Created] (FLINK-35683) CLONE - Verify that no exclusions were erroneously added to the japicmp plugin Weijie Guo (Jira)
• [jira] [Created] (FLINK-35678) CLONE - Review and update documentation Weijie Guo (Jira)
• [jira] [Created] (FLINK-35679) CLONE - Cross team testing Weijie Guo (Jira)
• [jira] [Created] (FLINK-35680) CLONE - Review Release Notes in JIRA Weijie Guo (Jira)
• [jira] [Created] (FLINK-35682) CLONE - Create a release branch Weijie Guo (Jira)
• [jira] [Created] (FLINK-35681) CLONE - Select executing Release Manager Weijie Guo (Jira)
• [jira] [Created] (FLINK-35676) CLONE - Create a new version in JIRA Weijie Guo (Jira)
• [jira] [Created] (FLINK-35677) CLONE - Triage release-blocking issues in JIRA Weijie Guo (Jira)
• [jira] [Created] (FLINK-35675) Prepare Flink 1.20 Release Weijie Guo (Jira)
• [jira] [Created] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps Thorne (Jira)
• [jira] [Created] (FLINK-35673) TestFileSource$TestFileSourceBuilder cannot be cast to class FileSource$FileSourceBuilder Weijie Guo (Jira)
• [jira] [Created] (FLINK-35672) testPreAggregatedSlidingTimeWindow failed due to due to checkpoint expired before completing Weijie Guo (Jira)
• [jira] [Created] (FLINK-35671) Support Iceberg CDC Pipeline Sink Muhammet Orazov (Jira)
• [jira] [Created] (FLINK-35670) Support Postgres Pipeline Source Muhammet Orazov (Jira)
• jira account permission zhengke zhou
  • Re: jira account permission gongzhongqiang
• [jira] [Created] (FLINK-35669) Release Testing: Verify FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs Junrui Li (Jira)
• [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Sergio Pena
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Timo Walther
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Jim Hughes
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Jeyhun Karimov
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Sergey Nuyanzin
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement gongzhongqiang
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Yanquan Lv
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Ferenc Csaky
  • Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement Martijn Visser
• [jira] [Created] (FLINK-35668) Throw exception "java.lang.OutOfMemoryError" when import data of a MySQL table to StarRocks Lv Luo Gang (Jira)
• [jira] [Created] (FLINK-35667) Implement Reducing Async State API for ForStStateBackend Zakelly Lan (Jira)
• [jira] [Created] (FLINK-35666) Implement Aggregating Async State API for ForStStateBackend Zakelly Lan (Jira)
• [jira] [Created] (FLINK-35665) Release Testing: FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI Rui Fan (Jira)
• [jira] [Created] (FLINK-35664) Flink CDC pipeline transform supports mask function melin (Jira)
• [jira] [Created] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax Yubin Li (Jira)
• [jira] [Created] (FLINK-35662) Use maven batch mode in k8s-operator CI Ferenc Csaky (Jira)
• FW: Non Nullable fields within objects David Radley
• [jira] [Created] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Ivan Burmistrov (Jira)
• [jira] [Created] (FLINK-35660) Implement parent-child ordering for DDB Streams source Aleksandr Pilipenko (Jira)
• [RESULT][VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Matthias Pohl
• [jira] [Created] (FLINK-35659) Fix TestFileSystem Connector error setting execution mode dalongliu (Jira)
• [jira] [Created] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel Yuxin Tan (Jira)
• [jira] [Created] (FLINK-35657) Flink UI not support show float metric value Can Luo (Jira)
• [jira] [Created] (FLINK-35656) Hive Source has issues setting max parallelism in dynamic inference mode xingbe (Jira)
• [jira] [Created] (FLINK-35655) Support more pipeline sources linqigeng (Jira)
• [jira] [Created] (FLINK-35654) Add Flink CDC verification guide in docs yux (Jira)
• [jira] [Created] (FLINK-35653) "fraud detection" example missed "env.execute" explanation Luke Chen (Jira)
• [jira] [Created] (FLINK-35652) FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join Weijie Guo (Jira)
• [RESULT][VOTE] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join weijie guo
• [jira] [Created] (FLINK-35651) Unable to call argument-less built-in functions with parentheses yux (Jira)
• [jira] [Created] (FLINK-35650) Incorrect TIMESTAMP_LTZ type behavior in Table SQL Andrey Gaskov (Jira)
• Re: [DISCUSS] FLIP-XXX: Improve JDBC connector extensibility for Table API lorenzo . affetti
• [jira] [Created] (FLINK-35649) Bump Flink version to 1.19.1 in k8s-operator Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-35648) Pipeline job doesn't support multiple routing yux (Jira)
• [jira] [Created] (FLINK-35647) Pipeline route rule supports placeholder replacement yux (Jira)
• [jira] [Created] (FLINK-35646) Add gateway refresh rest api doc dalongliu (Jira)
• [jira] [Created] (FLINK-35645) Add materialized table quickstart doc dalongliu (Jira)
• [jira] [Created] (FLINK-35643) Add materialized table statement doc dalongliu (Jira)
• [jira] [Created] (FLINK-35644) Add workflow scheduler doc dalongliu (Jira)
• [jira] [Created] (FLINK-35642) parsing the configuration file in flink, when configuring the s3 key, if there is contain # char, the correct key will be split blackpighe (Jira)
• [jira] [Created] (FLINK-35641) ParquetSchemaConverter should correctly handle field optionality Alex Sorokoumov (Jira)
• [ANNOUNCE] Apache Flink 1.19.1 released Hong Liang
  • Re: [ANNOUNCE] Apache Flink 1.19.1 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink 1.19.1 released Rui Fan
  • Re: [ANNOUNCE] Apache Flink 1.19.1 released Hong Liang
• [jira] [Created] (FLINK-35640) Drop Flink 1.15 support for the operator Mate Czagany (Jira)
• [ANNOUNCE] Apache Flink CDC 3.1.1 released Qingsheng Ren
  • Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released Paul Lam
  • Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released gongzhongqiang
  • Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released Muhammet Orazov
  • Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released Ahmed Hamdy
• [RESULT][VOTE] Apache Flink CDC Release 3.1.1, release candidate #0 Qingsheng Ren
• [jira] [Created] (FLINK-35639) upgrading to 1.19 with job in HA state with restart strategy crashes job manager yazgoo (Jira)
• [jira] [Created] (FLINK-35638) Modify OceanBase Docker container to make the test cases runnable on non-Linux systems He Wang (Jira)
• [jira] [Created] (FLINK-35637) ScalarFunctionCallGen does not handle complex argument type properly Qinghui Xu (Jira)
• [jira] [Created] (FLINK-35636) Streaming File Sink s3 end-to-end test did not finish after 900 seconds Weijie Guo (Jira)
• [jira] [Created] (FLINK-35635) Release Testing: Verify FLIP-445: Support dynamic parallelism inference for HiveSource xingbe (Jira)
• [jira] [Created] (FLINK-35634) Add a CDC quickstart utility yux (Jira)
• [jira] [Created] (FLINK-35633) Early verification and clearer error message of pipeline YAML definition yux (Jira)
• [SUMMARY] Flink 1.20 Release Sync 06/18/2024 weijie guo
• [jira] [Created] (FLINK-35632) The example provided in the kafkaSource documentation for topic regex subscription is incorrect elon_X (Jira)
• Re: [ANNOUNCE] Flink 1.20 feature freeze weijie guo
  • Re: [ANNOUNCE] Flink 1.20 feature freeze Ferenc Csaky
  • Re: [ANNOUNCE] Flink 1.20 feature freeze Xintong Song
  • Re: [ANNOUNCE] Flink 1.20 feature freeze weijie guo
  • Re: [ANNOUNCE] Flink 1.20 feature freeze Ferenc Csaky
• [jira] [Created] (FLINK-35631) KafkaSource parameter partition.discovery.interval.ms with a default value of 5 minutes does not take effect elon_X (Jira)
• [jira] [Created] (FLINK-35630) Kafka source may reset the consume offset to earliest when the partition leader changes tanjialiang (Jira)
• [jira] [Created] (FLINK-35629) Performance regression in stringRead and stringWrite Rui Fan (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Mate Czagany
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Rui Fan
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Thomas Weise
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-35628) Translate “DataGen Connector" of "DataStream Connectors" into Chinese Hao Yu (Jira)
• [jira] [Created] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart. LvYanquan (Jira)
• Re: [VOTE] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join Lincoln Lee
  • Re: [VOTE] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join Feng Jin
  • Re: [VOTE] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join Jingsong Li
• [jira] [Created] (FLINK-35626) Add support for FIPS Mark (Jira)
• [DISCUSS] Support to group rows by column ordinals Jeyhun Karimov
  • Re: [DISCUSS] Support to group rows by column ordinals Muhammet Orazov
  • Re: [DISCUSS] Support to group rows by column ordinals Sergey Nuyanzin
  • Re: [DISCUSS] Support to group rows by column ordinals Jeyhun Karimov
  • Re: [DISCUSS] Support to group rows by column ordinals Sergey Nuyanzin
  • Re: [DISCUSS] Support to group rows by column ordinals Jeyhun Karimov
  • Re: [DISCUSS] Support to group rows by column ordinals Muhammet Orazov
• [jira] [Created] (FLINK-35625) FLIP-464: Merge "flink run" and "flink run-application" Ferenc Csaky (Jira)
• Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement Sergio Pena
  • Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement Ron Liu
  • Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement Sergio Pena
  • Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement Sergio Pena
  • Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement Timo Walther
• Re: [DISCUSS] FLIP-444: Native file copy support Piotr Nowojski
  • Re: [DISCUSS] FLIP-444: Native file copy support Keith Lee
  • Re: [DISCUSS] FLIP-444: Native file copy support Keith Lee
• Re: [DISCUSSION] FLIP-456: CompiledPlan support for Batch Execution Mode Jim Hughes
  • Re: [DISCUSSION] FLIP-456: CompiledPlan support for Batch Execution Mode Alexey Leonov-Vendrovskiy
  • Re: [DISCUSSION] FLIP-456: CompiledPlan support for Batch Execution Mode Alexey Leonov-Vendrovskiy
• Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler weijie guo
  • Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Zhanghao Chen
  • Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Zdenek Tison
  • Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Ferenc Csaky
  • Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Gabor Somogyi
  • Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Thomas Weise
  • Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Matthias Pohl
• Re: [VOTE] Apache Flink CDC Release 3.1.1, release candidate #0 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.1.1, release candidate #0 Leonard Xu
  • Re: [VOTE] Apache Flink CDC Release 3.1.1, release candidate #0 Jark Wu
  • Re: [VOTE] Apache Flink CDC Release 3.1.1, release candidate #0 Lincoln Lee
• Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong Feng Jin
  • Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong Muhammet Orazov
  • Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong Yubin Li
  • Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong Jacky Lau
  • Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong Swapnal Varma
  • Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong archzi lu
  • Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong archzi lu
• Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan Feng Jin
  • Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan Muhammet Orazov
  • Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan Yubin Li
  • Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan Jacky Lau

• Later messages