dev  

Messages by Thread

• • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Lorenzo Nicora
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Danny Cranmer
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Hong Liang
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Hong Liang
  • Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 Yanquan Lv
• [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 weijie guo
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Xintong Song
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Danny Cranmer
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Danny Cranmer
  • Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 Hong Liang
• [jira] [Created] (FLINK-36657) Release Flink 1.20 Matyas Orhidi (Jira)
• Flink technical debt. David Radley
  • Re: Flink technical debt. Robert Metzger
  • RE: Flink technical debt. David Radley
  • RE: Flink technical debt. Nic Townsend
  • RE: Flink technical debt. David Radley
  • Re: Flink technical debt. Jim Hughes
  • FW: Re: Flink technical debt. David Radley
  • RE: Flink technical debt. David Radley
  • Re: Flink technical debt. Robert Metzger
  • RE: Flink technical debt. David Radley
  • FW: RE: Flink technical debt. David Radley
  • Re: FW: RE: Flink technical debt. Jim Hughes
  • RE: FW: RE: Flink technical debt. David Radley
  • FW: Re: Flink technical debt. David Radley
  • Re: FW: Re: Flink technical debt. Sergey Nuyanzin
  • RE: FW: Re: Flink technical debt. David Radley
  • FW: Re: Flink technical debt. David Radley
  • FW: Re: Flink technical debt. Chi meeting David Radley
  • FW: FW: Re: Flink technical debt. Chi meeting David Radley
  • Flink technical debt. Chi meeting David Radley
  • Re: Flink technical debt. Tom Cooper
  • RE: Flink technical debt. David Radley
  • Re: Flink technical debt. Jim Hughes
  • Re: Flink technical debt. Ferenc Csaky
  • Re: Flink technical debt. Shalini
  • Re: Flink technical debt. Lajith Koova
  • Re: Flink technical debt. Lyrics Cool
  • Re: Flink technical debt. Hong Liang
  • RE: Flink technical debt. Sebastien Pereira
  • RE: Re: Flink technical debt. Ammu P
• [jira] [Created] (FLINK-36656) Flink CDC treats MySQL Sharding table with boolean type conversion error Leonard Xu (Jira)
• [jira] [Created] (FLINK-36655) using flink state processor api to process big state in rocksdb is very slow guanghua pi (Jira)
• [jira] [Created] (FLINK-36654) Decimal divide Integer reports Null pointer exception Shuai Xu (Jira)
• [jira] [Created] (FLINK-36653) OnlineLogisticRegressionModel not updating servable and prediction result Yunfeng Zhou (Jira)
• [jira] [Created] (FLINK-36652) Upgrade Apache ORC to 1.9.4 Yuchi Duan (Jira)
• [jira] [Created] (FLINK-36651) Fix CI tests for ElasticSearch Connector Ahmed Hamdy (Jira)
• [jira] [Created] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists Jerome Gagnon (Jira)
• [jira] [Created] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed Di Wu (Jira)
• [jira] [Created] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector LvYanquan (Jira)
• [jira] [Created] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform Wenkai Qi (Jira)
• [jira] [Created] (FLINK-36646) Support Java 17+ job images more conveniently in the operator Rob Young (Jira)
• [jira] [Created] (FLINK-36645) Gracefully handle null execution plan from autoscaler Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability Thomas Cooper (Jira)
• [jira] [Created] (FLINK-36644) TIMESTAMPDIFF can not be string serialized Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-36642) Table API expressions with several built-in functions are not correctly serialized to SQL Fabian Hueske (Jira)
• JSON-Path CVEs Tom Cooper
  • Re: JSON-Path CVEs Sergey Nuyanzin
• [jira] [Created] (FLINK-36641) Support and Release Connectors for Flink 1.20 LvYanquan (Jira)
• [jira] [Created] (FLINK-36640) Provide an easy way to reset autoscaling Matyas Orhidi (Jira)
• [jira] [Created] (FLINK-36639) Use table aliases in Table API asSerializableString Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-36638) Remove legacy bounded blocking shuffle Weijie Guo (Jira)
• [jira] [Created] (FLINK-36637) Fix ListShards for Kinesis streams with large number of shards Elphas Toringepi (Jira)
• [jira] [Created] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform Wenkai Qi (Jira)
• *TemporarySystemFunction API without ignoreIfExists option Venkatakrishnan Sowrirajan
• [jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed Yi Zhang (Jira)
• [jira] [Created] (FLINK-36634) Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime xingbe (Jira)
• [jira] [Created] (FLINK-36633) Add support for Flink 1.20 in Flink OpenSearch connector Andriy Redko (Jira)
• [jira] [Created] (FLINK-36632) When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data MOBIN (Jira)
• [jira] [Created] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN Di Wu (Jira)
• [jira] [Created] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment Alberto Lago (Jira)
• [jira] [Created] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy Lei Yang (Jira)
• [jira] [Created] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP Weijie Guo (Jira)
• [DISCUSS][FLINK-36547] Add option to retain `RowKind` sematics for cdc formats Yubin Li
• [jira] [Created] (FLINK-36627) Failure to process a CSV file in Flink due to a character encoding mismatch: the file is in ISO-8859 and the application expects UTF-8. Hector Miuler Malpica Gallegos (Jira)
• kafka-connector random WakeupException after enabling watermark alignment Alberto Lago
• Micro batching with flink Anil Dasari
  • Re: Micro batching with flink Venkatakrishnan Sowrirajan
  • Re: Micro batching with flink Anil Dasari
  • Re: Micro batching with flink Gabor Somogyi
  • Re: Micro batching with flink Arvid Heise
  • Re: Micro batching with flink Anil Dasari
• [jira] [Created] (FLINK-36626) Flink SQL JOINs behavior change from Flink 1.15 to Flink 1.18+ Eduardo Breijo (Jira)
• [jira] [Created] (FLINK-36625) Add helper classes for Lineage integration in connectors Zhenqiu Huang (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.10.0 released Őrhidi Mátyás
• [jira] [Created] (FLINK-36624) Log JobID in SourceCoordinator Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-36623) Improve logging in DefaultStateTransitionManager Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-36622) Remove the dependency of StateBenchmark on RocksDBKeyedStateBackend APIs. Han Yin (Jira)
• [jira] [Created] (FLINK-36621) Build failure: StatefulSink not found Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats zjjiang (Jira)
• [DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set 李阳
  • Re:[DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set Xuyang
  • Re: [DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set Feng Jin
• [jira] [Created] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added linqigeng (Jira)
• [jira] [Created] (FLINK-36618) Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC Hongshun Wang (Jira)
• [jira] [Created] (FLINK-36617) Migrate kryo package Siddharth R (Jira)
• [jira] [Created] (FLINK-36616) Null pointer in PubSub's GcpPublisherConfig Jira
• [jira] [Created] (FLINK-36615) Support LEAD/LAG functions in Table API Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase Youle (Jira)
• [jira] [Created] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink LvYanquan (Jira)
• [jira] [Created] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes yux (Jira)
• [jira] [Created] (FLINK-36609) Protobuf Format not support proto3 Hongshun Wang (Jira)
• [jira] [Created] (FLINK-36608) Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator xingbe (Jira)
• [jira] [Created] (FLINK-36607) Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join xingbe (Jira)
• [jira] [Created] (FLINK-36606) TimestampITCase generates test artifacts outside of tmp folder Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36605) Upgrade Debezium version to 2.7.x Anil Dasari (Jira)
• [jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh Mingliang Liu (Jira)
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 Őrhidi Mátyás
• [jira] [Created] (FLINK-36603) Inconsistent spelling of "behavior" across the API Lorenzo Nicora (Jira)
• [jira] [Created] (FLINK-36602) Upgrade Calcite version to 1.38.0 Thomas Cooper (Jira)
• [jira] [Created] (FLINK-36601) Add JobID property to FlinkResultSet Yi Cai (Jira)
• [jira] [Created] (FLINK-36600) Implement java.sql.Wrapper interface. Yi Cai (Jira)
• [jira] [Created] (FLINK-36599) Correct the name of the config which enables response codes group Alan Zhang (Jira)
• [jira] [Created] (FLINK-36598) [state/forst] Refactor initialization of ForSt db core Zakelly Lan (Jira)
• [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Feng Jin
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Ron Liu
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Ron Liu
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Ron Liu
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Junrui Lee
  • Re:Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Xuyang
  • Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re:Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Xuyang
  • Re:Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Ferenc Csaky
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Lincoln Lee
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Gyula Fóra
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Gyula Fóra
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Gyula Fóra
  • Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Feng Jin
  • Re: [DISCUSS] FLIP-480: Support to deploy script in application mode Hongshun Wang
• [jira] [Created] (FLINK-36597) Optimize SnapshotSplitAssigner error log output MOBIN (Jira)
• [jira] [Created] (FLINK-36596) YAML Pipeline fails to schema change with no projection fields specified yux (Jira)
• [jira] [Created] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20 Aleksandr Pilipenko (Jira)
• https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw Hanyu (Peter) Zheng
  • RE: https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw Hanyu (Peter) Zheng
• Re: Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng
  • Re: Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng
  • Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng
• [jira] [Created] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back slankka (Jira)
• [jira] [Created] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE Thomas Cooper (Jira)
• [ANNOUNCE] Apache Flink 2.0 Preview released Xintong Song
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released weijie guo
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released Zakelly Lan
• [jira] [Created] (FLINK-36592) Support file cache for ForStStateBackend Yanfei Lei (Jira)
• [jira] [Created] (FLINK-36591) WikipediaEditsSourceTest fails in all cases Martijn Visser (Jira)
• [jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x yux (Jira)
• [jira] [Created] (FLINK-36589) Decouple the initialization of sync and async keyed statebackend Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml ouyangwulin (Jira)
• [jira] [Created] (FLINK-36587) Postgres-cdc: Add support to override connector.class Anil Dasari (Jira)
• [jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+ ZhengYu Chen (Jira)
• [jira] [Created] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. Jiangjie Qin (Jira)
• [jira] [Created] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots Anil Dasari (Jira)
• [jira] [Created] (FLINK-36583) Add Slow Request Kube Client Metrics Matyas Orhidi (Jira)
• [jira] [Created] (FLINK-36582) sql client hang when querying a parquet table Lu Niu (Jira)
• [DISCUSS] Release HBase connector with partial JDK support Ferenc Csaky
  • Re: [DISCUSS] Release HBase connector with partial JDK support Márton Balassi
  • Re: [DISCUSS] Release HBase connector with partial JDK support Yanquan Lv
  • Re: [DISCUSS] Release HBase connector with partial JDK support Yanquan Lv
  • Re: [DISCUSS] Release HBase connector with partial JDK support Ferenc Csaky
  • Re: [DISCUSS] Release HBase connector with partial JDK support Ferenc Csaky
  • Re: [DISCUSS] Release HBase connector with partial JDK support Márton Balassi
  • Re: [DISCUSS] Release HBase connector with partial JDK support Yanquan Lv
  • Re: [DISCUSS] Release HBase connector with partial JDK support Leonard Xu
• [jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters LvYanquan (Jira)
• [jira] [Created] (FLINK-36580) Using debezium.column.exclude.list causes job failure MOBIN (Jira)
• [jira] [Created] (FLINK-36579) mysql cdc charset collation sort not equals java string compare. LIU (Jira)
• [RESULT][VOTE] FLIP-478: Introduce Config Option Scope Junrui Lee
• [jira] [Created] (FLINK-36578) Fixed bug when converting json to string Lee SeungMin (Jira)
• [jira] [Created] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD Mate Czagany (Jira)
• [jira] [Created] (FLINK-36576) Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider Lei Yang (Jira)
• [jira] [Created] (FLINK-36575) ExecutionVertexInputInfo supports consuming subpartition groups Lei Yang (Jira)
• [RESULT][VOTE] Release 2.0-preview1, release candidate #1 Xintong Song
• [jira] [Created] (FLINK-36574) The file STDOUT is not available on the TaskExecutor fangmin.yang (Jira)
• [jira] [Created] (FLINK-36573) Add table information of binlog offsets when checkpointing Runkang He (Jira)
• [jira] [Created] (FLINK-36572) The local time zone is wrongly set in StarRocks pipeline sink Runkang He (Jira)
• [jira] [Created] (FLINK-36571) Flink dashboard does not show Busy / Backpressure Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36570) Fatal error occurred in the cluster entrypoint zyh (Jira)
• [jira] [Created] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success Jake.zhang (Jira)
• [jira] [Created] (FLINK-36568) IllegalStateException Causes Collect Sink to Fail to Collect Result Junrui Li (Jira)
• [jira] [Created] (FLINK-36567) Planner module didn't use the setting from flink-conf.yaml liting liu (Jira)
• [jira] [Created] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator LvYanquan (Jira)
• [jira] [Created] (FLINK-36565) Pipeline YAML should allow merging decimal with different precisions yux (Jira)
• [jira] [Created] (FLINK-36564) Running CI in random timezone to expose more time related bugs LvYanquan (Jira)

• Earlier messages
• Later messages