dev  

Messages by Thread

• [jira] [Created] (FLINK-36779) topn.cache.size metric is incorrect and non-changing during the time Roman Boyko (Jira)
• [jira] [Created] (FLINK-36778) The default implementation shaohui hong (Jira)
• [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler yuanfeng hu
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Rui Fan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Rui Fan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Eric Xiao
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Peter Huang
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
• [jira] [Created] (FLINK-36777) The implementation of getting chunk key column in ChunkUtils.java is weired shaohui hong (Jira)
• [jira] [Created] (FLINK-36776) OracleIncrementalSource does not support partitioned table shaohui hong (Jira)
• [jira] [Created] (FLINK-36775) fetchSize set in OracleIncrementalSource is not working shaohui hong (Jira)
• [jira] [Created] (FLINK-36774) SQL gateway should support executing multiple SQL statements once tim yu (Jira)
• [jira] [Created] (FLINK-36773) Introduce new Group Agg Operator with Async State API xuyang (Jira)
• [jira] [Created] (FLINK-36772) Fix Preconditions errorMessageTemplate is error Xin Gong (Jira)
• [jira] [Created] (FLINK-36771) Flink cdc UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED] Xin Gong (Jira)
• Plans for JDBC connector for 1.20? David Radley
  • FW: Plans for JDBC connector for 1.20? David Radley
  • Re: Plans for JDBC connector for 1.20? Yanquan Lv
  • RE: Plans for JDBC connector for 1.20? David Radley
  • Re: Plans for JDBC connector for 1.20? Hang Ruan
  • Re: Plans for JDBC connector for 1.20? Peter Huang
  • RE: Plans for JDBC connector for 1.20? David Radley
  • Re: Plans for JDBC connector for 1.20? Hang Ruan
  • Re: Plans for JDBC connector for 1.20? Xingcan Cui
  • RE: Plans for JDBC connector for 1.20? David Radley
  • Re: Plans for JDBC connector for 1.20? Yanquan Lv
  • Re: Plans for JDBC connector for 1.20? Hang Ruan
  • RE: Re: Plans for JDBC connector for 1.20? Jérôme Gagnon
• [jira] [Created] (FLINK-36770) Support Request Timeout for AWS sinks Ahmed Hamdy (Jira)
• [jira] [Created] (FLINK-36769) Suport fury Serializer for pyflink xingyuan cheng (Jira)
• [jira] [Created] (FLINK-36768) Empty Checkpoint Directory created when older checkpoint fails due to timeout and the checkpoint interval is same Eaugene Thomas (Jira)
  • 回复: [jira] [Created] (FLINK-36768) Empty Checkpoint Directory created when older checkpoint fails due to timeout and the checkpoint interval is same Xia Rui
• [jira] [Created] (FLINK-36766) Use pyflink to create remote env William Que (Jira)
• [jira] [Created] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0 Siddharth R (Jira)
• [jira] [Created] (FLINK-36765) How to Handle Multi-Type Maps in Avro Schema with Flink Table API? Maneendra (Jira)
• [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 Hang Ruan
  • Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 Hang Ruan
  • Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 Leonard Xu
  • Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 Lincoln Lee
  • Re: [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 Xingbo Huang
• [jira] [Created] (FLINK-36764) Add checkpoint type to checkpoint trace Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-36761) Add document about how to deploy script with SQL Client and SQL Gateway Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources yux (Jira)
• [jira] [Created] (FLINK-36756) Bump up the sql-gateway rest api version Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36757) Introduce splitter to split scripts Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36760) Support to deploy script via sql client Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36762) Add E2ECase to run sql client in application mode Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36759) Intrdouce REST API to deploy script Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36758) Introduce driver to load the application in application mode Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36755) Relax the limit about the pipeline.jar must have one in application mode Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36754) When projection is empty or null, it is treated as an asterisk MOBIN (Jira)
• [jira] [Created] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint Rui Fan (Jira)
• [jira] [Created] (FLINK-36752) Emit state related metrics when checkpoints are disabled Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-36751) PausableRelativeClock does not pause when the source only has one split haishui (Jira)
• [jira] [Created] (FLINK-36750) Paimon connector would reuse sequence number when schema evolution happened Yanquan Lv (Jira)
• [DISCUSS] Release Flink CDC version 3.2.1 Hang Ruan
  • Re: [DISCUSS] Release Flink CDC version 3.2.1 Leonard Xu
• [jira] [Created] (FLINK-36749) Implement rescaling for ForStKeyedStateBackend Yanfei Lei (Jira)
• Join slack Ecaterina-Sonia Lazarescu
• [jira] [Created] (FLINK-36748) Web UI can stop job with savepoint and upload yaml file vertern (Jira)
• [jira] [Created] (FLINK-36747) History server can manage archived jobs vertern (Jira)
• [jira] [Created] (FLINK-36739) Update NodeJS to v18.20.5 (LTS) Mehdi (Jira)
  • RE: [jira] [Created] (FLINK-36739) Update NodeJS to v18.20.5 (LTS) Mehdi Deboub
• [jira] [Created] (FLINK-36746) Found deadlock in SerializedThrowable xiongraorao (Jira)
• [jira] [Created] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs Andrei Kaigorodov (Jira)
• [jira] [Created] (FLINK-36744) Document operator's FlinkVersion compatibility Dylan Meissner (Jira)
• [jira] [Created] (FLINK-36743) Rescale from unaligend checkpoint failed Feifan Wang (Jira)
• [jira] [Created] (FLINK-36742) Filter unacked split for no capture tables when task restore from state Xin Gong (Jira)
• [jira] [Created] (FLINK-36741) The precision of Decimal has been lost when use FlinkCDC transform Wenkai Qi (Jira)
• [jira] [Created] (FLINK-36740) Dependencies update to address vulnerabilities Mehdi (Jira)
• [jira] [Created] (FLINK-36738) Weekly CI for MongoDB connector fails on jdk21 Jiabao Sun (Jira)
• [jira] [Created] (FLINK-36737) flink-shaded-hadoop-2-uber contains the common io version incompatible with the flink client melin (Jira)
• [jira] [Created] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive Jark Wu (Jira)
• [jira] [Created] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns Jark Wu (Jira)
• [jira] [Created] (FLINK-36734) Potential issue in autoscaler algorithm Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) Roman Khachatryan (Jira)
• Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 Arvid Heise
  • Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 Yanquan Lv
  • Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 Leonard Xu
  • Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 Martijn Visser
  • Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 Ahmed Hamdy
  • Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 Danny Cranmer
  • Re: Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 Arvid Heise
• [jira] [Created] (FLINK-36732) Add CompiledPlan annotations to BatchExecPythonOverAggregate Jim Hughes (Jira)
• [jira] [Created] (FLINK-36731) Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate Jim Hughes (Jira)
• [jira] [Created] (FLINK-36729) Add CompiledPlan annotations to BatchExecPythonCorrelate Jim Hughes (Jira)
• [jira] [Created] (FLINK-36730) Add CompiledPlan annotations to BatchExecPythonGroupAggregate Jim Hughes (Jira)
• [jira] [Created] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc Jim Hughes (Jira)
• [jira] [Created] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Jim Hughes (Jira)
• [jira] [Created] (FLINK-36727) Add a completeness test to cover BatchExecNodes Jim Hughes (Jira)
• [jira] [Created] (FLINK-36726) Add CompiledPlan annotations to BatchExecInputAdapter Jim Hughes (Jira)
• [jira] [Created] (FLINK-36724) Add CompiledPlan annotations to BatchExecExecutionOrderEnforcer Jim Hughes (Jira)
• [jira] [Created] (FLINK-36723) Add CompiledPlan annotations to BatchExecDynamicFilteringDataCollector Jim Hughes (Jira)
• [jira] [Created] (FLINK-36722) Add CompiledPlan annotations to BatchExecSortWindowAggregate Jim Hughes (Jira)
• [jira] [Created] (FLINK-36721) Add CompiledPlan annotations to BatchExecHashWindowAggregate Jim Hughes (Jira)
• [jira] [Created] (FLINK-36720) Add CompiledPlan annotations to BatchExecWindowTableFunction Jim Hughes (Jira)
• [jira] [Created] (FLINK-36719) Add CompiledPlan annotations to BatchExecMultipleInput Jim Hughes (Jira)
• [jira] [Created] (FLINK-36718) Add CompiledPlan annotations to BatchExecLookupJoin and BatchExecSortMergeJoin Jim Hughes (Jira)
• [RESULT][VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
• [jira] [Created] (FLINK-36717) Add health check to detect tasks stuck in DEPLOYING state Maximilian Michels (Jira)
• [jira] [Created] (FLINK-36716) Address vulnerabilities in Flink UI Mehdi (Jira)
  • RE: [jira] [Created] (FLINK-36716) Address vulnerabilities in Flink UI Mehdi Deboub
• [jira] [Created] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36714) sstmerge/CompactionScheduler termination can be interrupted Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-36713) NoSuchMethodError: PostgresConnection with PostgresIncrementalSource ar runtime Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-36712) Autoscaler should skip resource check when new parallelism/memory is lower than current Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-36711) Add tips when System out and err are redirected to LOG or discarded Vincent Woo (Jira)
• [jira] [Created] (FLINK-36710) JobIDLoggingITCase fails on SourceCoordinator logs Roman Khachatryan (Jira)
• Dynamic Iceberg Sink Péter Váry
  • Re: Dynamic Iceberg Sink Maximilian Michels
  • Re: Dynamic Iceberg Sink Leonard Xu
  • Re: Dynamic Iceberg Sink Congxian Qiu
  • Re: Dynamic Iceberg Sink Ferenc Csaky
  • Re: Dynamic Iceberg Sink ConradJam
  • Re: Dynamic Iceberg Sink Anil Dasari
  • Re: Dynamic Iceberg Sink Maximilian Michels
  • Re: Dynamic Iceberg Sink Anil Dasari
  • Re: Dynamic Iceberg Sink Anil Dasari
  • Re: Dynamic Iceberg Sink Maximilian Michels
• [jira] [Created] (FLINK-36707) Integrate PTF TypeInference into Calcite validator Timo Walther (Jira)
• [jira] [Created] (FLINK-36709) Flink parquet will throw exception when reading nested row data with last column is array. Wenchao Wu (Jira)
• [jira] [Created] (FLINK-36708) Optimize Table Collection Handling Logic to Improve Efficiency wanghaofeng (Jira)
• [jira] [Created] (FLINK-36706) Update TypeInferenceExtractor for PTFs Timo Walther (Jira)
• [jira] [Created] (FLINK-36704) Update TypeInference with StaticArgument and StateTypeStrategy Timo Walther (Jira)
• [jira] [Created] (FLINK-36705) Add ProcessTableFunction class and annotations Timo Walther (Jira)
• [jira] [Created] (FLINK-36703) FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther (Jira)
• [jira] [Created] (FLINK-36702) FLIP-480: Support to deploy SQL script in application mode Shengkai Fang (Jira)
• [jira] [Created] (FLINK-36701) Pipeline failover again after handling a schema change event as the first event after a failover zjjiang (Jira)
• [RESULT][VOTE] FLIP-480: Support to deploy script in application mode Shengkai Fang
• [jira] [Created] (FLINK-36700) Elasticsearch pipeline sink support authentication JunboWang (Jira)
• [jira] [Created] (FLINK-36699) Fix nullability when converting cdc data type to flink data type Xiao Huang (Jira)
• [jira] [Created] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding JunboWang (Jira)
• [jira] [Created] (FLINK-36697) Quickly evolving schema change in Doris fails yux (Jira)
• [jira] [Created] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-36695) Bump Parquet dependency Martijn Visser (Jira)
• [jira] [Created] (FLINK-36694) Update Hadoop shaded from 3.3.4 to 3.4.1 Rasmus Thygesen (Jira)
• [jira] [Created] (FLINK-36693) Implement checkpoint for ForStSyncKeyedStateBackend Yanfei Lei (Jira)
• [jira] [Created] (FLINK-36692) Flink Table HBase connector cris niu (Jira)
• [jira] [Created] (FLINK-36691) Support configuration to enable tasks balancing at slot level for Default Scheduler RocMarshal (Jira)
• [jira] [Created] (FLINK-36690) Pipeline occasionally blocks when handling schema change events in parallel yux (Jira)
• [ANNOUNCE] Apache flink-connector-aws 5.0.0 released Hong Liang
• [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Sergey Nuyanzin
  • Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Konstantin Knauf
  • Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Jim Hughes
  • Re:Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Xuyang
  • Re: Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Shengkai Fang
  • Re: Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Fabian Hüske
  • Re: Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Dawid Wysakowicz
  • Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Stefan Richter
  • RE: Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) David Radley
  • Re: Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Martijn Visser
  • Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
• [ANNOUNCE] Apache flink-connector-prometheus 1.0.0 released Hong Liang
• [RESULT][VOTE] flink-connector-aws v5.0.0, release candidate #3 Hong Liang
• [jira] [Created] (FLINK-36689) [UI] Upgrade runtime web Angular framework and associated deps to v15 Jason TANG (Jira)
• [jira] [Created] (FLINK-36688) table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1 Di Wu (Jira)
• [jira] [Created] (FLINK-36686) allow customizing envs for flink-webhook container Shuyi Chen (Jira)
• [jira] [Created] (FLINK-36685) Enable update/create operation on flinkdeployment resource in mutation webhook Shuyi Chen (Jira)
• [jira] [Created] (FLINK-36684) Support append only mode for MySQL CDC connector Runkang He (Jira)
• [jira] [Created] (FLINK-36683) Support metadata 'row_kind' virtual column for Mongo CDC Connector Runkang He (Jira)
• [jira] [Created] (FLINK-36682) Add split assign strategy to avoid OOM error in TaskManager Yanquan Lv (Jira)
• [jira] [Created] (FLINK-36681) Wrong chunks splitting query in incremental snapshot reading section in mysql cdc doc Runkang He (Jira)
• [jira] [Created] (FLINK-36680) Flink K8S operator image 1.20.0 is still using Flink 1.19.1 Maxime (Jira)
• [jira] [Created] (FLINK-36679) Add a metric to track checkpoint _metadata size Mingliang Liu (Jira)
• [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Attila Kreiner
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Mate Czagany
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Márton Balassi
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Arvid Heise
  • Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-36678) The Flink CDC Yarn deployment mode document description is incorrect xuweiwei (Jira)
• [jira] [Created] (FLINK-36677) Instruct users to change log level dynamically in operator Luke Chen (Jira)
• [jira] [Created] (FLINK-36676) Flink CDC SQL Server Connector Missing Data Chance (Jira)
• [jira] [Created] (FLINK-36675) Dynamic option hints will not take effect when restoring exec plan from json plan without setting 'table.plan.compile.catalog-objects' to 'all' xuyang (Jira)
• [RESULT][VOTE] flink-connector-prometheus v1.0.0, release candidate #1 Hong Liang
• [DISCUSS] Flink PubSub connector bump release needed Radek Stankiewicz
  • Re: [DISCUSS] Flink PubSub connector bump release needed Ahmed Hamdy
  • Re: [DISCUSS] Flink PubSub connector bump release needed Radek Stankiewicz
• [VOTE]FLIP-480: Support to deploy script in application mode Shengkai Fang
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode Lincoln Lee
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode yuanfeng hu
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode Feng Jin
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode Gyula Fóra
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode Gyula Fóra
  • Re: [VOTE]FLIP-480: Support to deploy script in application mode Ron Liu

• Earlier messages
• Later messages