dev  

Messages by Thread

• [jira] [Created] (FLINK-38915) Suspending Pipeline Breaks FlinkBlueGreenDeployment Daniel Rossos (Jira)
• FLINK-38913 David Radley
• [jira] [Created] (FLINK-38912) Upgrade Flink to use Netty 4.2.6.Final Mate Czagany (Jira)
• [jira] [Created] (FLINK-38914) Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) Martijn Visser (Jira)
• [jira] [Created] (FLINK-38913) ArrayIndexOutOfBoundsException when creating a table with nested objects david radley (Jira)
• Kubernetes Operator 1.14.0 release planning Gyula Fóra
  • Re: Kubernetes Operator 1.14.0 release planning Daniel Rossos via dev
  • Re: Kubernetes Operator 1.14.0 release planning Gyula Fóra
  • Re: Kubernetes Operator 1.14.0 release planning Daniel Rossos via dev
  • Re: Kubernetes Operator 1.14.0 release planning Maximilian Michels
  • Re: Kubernetes Operator 1.14.0 release planning Daniel Rossos via dev
  • Re: Kubernetes Operator 1.14.0 release planning Gyula Fóra
• [jira] [Created] (FLINK-38911) mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled config Thorne (Jira)
• [jira] [Created] (FLINK-38909) Unable to delete S3 checkpoint due to presence of default file CHANHAE OH (Jira)
• [jira] [Created] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently Mate Czagany (Jira)
• [jira] [Created] (FLINK-38907) Records lost using filtered autocreate mode Gio Gutierrez (Jira)
• [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Bonnie Arogyam Varghese via dev
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Maximilian Michels
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Zhanghao Chen
  • Re: [DISCUSS] A design proposal to fix the wrong dynamic replacement of partitioner from FORWARD to REBLANCE for AutoScaler and AdaptiveScheduler Yuepeng Pan
• [ANNOUNCE] Apache Flink-shaded 21.0 released Martijn Visser
• [RESULT][VOTE] Release flink-shaded 21.0, release candidate #3 Martijn Visser
• [jira] [Created] (FLINK-38906) Polish YAML transform built-in functions Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38905) YAML Transform to handle dirty data gracefully Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38904) MySQL CDC binlog reader hangs due to TLS 1.3 KeyUpdate deadlock (potentially JDK-8241239) John Watson (Jira)
• [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
  • Re:[VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Xuyang
  • Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Sergey Nuyanzin
  • Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Martijn Visser
  • Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Gustavo de Morais
  • Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Timo Walther
  • Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Ramin Gharib
  • Re: [VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
• [jira] [Created] (FLINK-38903) Upgrade Flink to Flink-Shaded 21.0 Martijn Visser (Jira)
• [RESULT][VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Ferenc Csaky
• [jira] [Created] (FLINK-38902) Add user instructions and usage documentation for FLIP-487. RocMarshal (Jira)
• [jira] [Created] (FLINK-38901) Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
• [jira] [Created] (FLINK-38899) Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
• [jira] [Created] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
• [jira] [Created] (FLINK-38898) Introduce the Rescales/Overview sub-page for streaming jobs with the adaptive scheduler enabled RocMarshal (Jira)
• [jira] [Created] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API RocMarshal (Jira)
• [jira] [Created] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API RocMarshal (Jira)
• [jira] [Created] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API RocMarshal (Jira)
• [jira] [Created] (FLINK-38892) Introduce the scheduler and type information of the target job in the /jobs/overview endpoint of the REST API RocMarshal (Jira)
• [jira] [Created] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API RocMarshal (Jira)
• [jira] [Created] (FLINK-38893) Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API RocMarshal (Jira)
• [RESULT][VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
• [jira] [Created] (FLINK-38891) Migrate MiniBatchIntervalInferRule Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38890) Migrate PullUpWindowTableFunctionIntoWindowAggregateRule Roman Rybak (Jira)
• [jira] [Created] (FLINK-38889) YAML Kafka sink connector supports serializing complex types yux (Jira)
• [jira] [Created] (FLINK-38888) YAML Pipeline supports item subscription of complex types yux (Jira)
• [jira] [Created] (FLINK-38887) YAML Transform module supports nested types yux (Jira)
• [jira] [Created] (FLINK-38886) Provide GenericRecordData in Pipeline public API yux (Jira)
• [jira] [Created] (FLINK-38885) Migrate StreamPhysicalJoinRuleBase and its children Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38884) Migrate IncrementalAggregateRule Roman Rybak (Jira)
• [DISCUSS] FLINK-38290 - Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated Royston Tauro
• [jira] [Created] (FLINK-38883) Race condition of REST API and JRS entry might lead to inconsistent state Matthias Pohl (Jira)
• [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Yuepeng Pan
  • Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Amos Aidoo
  • Re: [ANNOUNCE] New Apache Flink PMC Member �C Hang Ruan Biao Geng
  • Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Swapnal Varma
  • Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Xiqian YU
  • Re:Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Xuyang
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Archzi Lu
  • RE: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan David Radley
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Ahmed Hamdy
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Guowei Ma
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Feng Jin
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Lincoln Lee
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Zakelly Lan
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Shengkai Fang
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Aleksandr Savonin
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Jiangang Liu
  • Re: Re: [ANNOUNCE] New Apache Flink PMC Member – Hang Ruan Weiqing Yang
• [jira] [Created] (FLINK-38882) Introduce rules for async python scalar function Dian Fu (Jira)
• [jira] [Created] (FLINK-38881) PostgreSQL Partition Table Routing Support tchivs (Jira)
• [jira] [Created] (FLINK-38880) Add async scalar function support in Python Dian Fu (Jira)
• [jira] [Created] (FLINK-38877) Introduce VARIANT type to Flink CDC pipeline Yanquan Lv (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-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• [jira] [Created] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 Jira
• [jira] [Created] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• [VOTE] Release flink-shaded 21.0, release candidate #3 Martijn Visser
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Gabor Somogyi
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Rich Bowen
  • RE: [VOTE] Release flink-shaded 21.0, release candidate #3 abhi Gupta
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Sergey Nuyanzin
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Leonard Xu
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Martijn Visser
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #3 Martijn Visser
• [jira] [Created] (FLINK-38873) mysql pipeline error when adding the same column ouyangwulin (Jira)
• [jira] [Created] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely ConfX (Jira)
• [jira] [Created] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields Vishal Kamlapure (Jira)
• [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Rich Bowen
  • RE: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 abhi Gupta
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Danny Cranmer
  • RE: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 tjoch
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Robert Metzger
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Gabor Somogyi
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Mate Czagany
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Sergey Nuyanzin
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Leonard Xu
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Hang Ruan
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #2 Ferenc Csaky
• Proposal to start a Flink digest blog. David Radley
  • Re: Proposal to start a Flink digest blog. Robert Metzger
  • RE: Proposal to start a Flink digest blog. David Radley
• Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Martijn Visser
  • Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Sergey Nuyanzin
  • Re: [VOTE] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
• [DISCUSS] FLIP-561: Restructure Flink documentation Martijn Visser
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Robin Moffatt via dev
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Leonard Xu
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Ryan van Huuksloot via dev
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Zander Matheson
  • Re:[DISCUSS] FLIP-561: Restructure Flink documentation dylanhz
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Xintong Song
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Martijn Visser
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Ryan van Huuksloot via dev
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation David Anderson
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Xintong Song
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Martijn Visser
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Zhe Wang
  • Re: [DISCUSS] FLIP-561: Restructure Flink documentation Martijn Visser
• [jira] [Created] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss ConfX (Jira)
• [jira] [Created] (FLINK-38869) InitializationContext for KafkaSubscriber Efrat Levitan (Jira)
• [DISCUSSION] Question on FLIP-450 network buffer removal and high-throughput regression in Flink 2.0 Han You via dev
• [jira] [Created] (FLINK-38868) Bump Flink version to 1.20.3 for AWS connector v5.1 Ferenc Csaky (Jira)
• [DISCUSSION] FlinkBlueGreenDeployment Suspending Pipeline Daniel Rossos via dev
  • Re: [DISCUSSION] FlinkBlueGreenDeployment Suspending Pipeline Sergio Chong Loo
  • Re: [DISCUSSION] FlinkBlueGreenDeployment Suspending Pipeline Gyula Fóra
• [jira] [Created] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath James Kan (Jira)
• [jira] [Created] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode Matt Cuento (Jira)
• [jira] [Created] (FLINK-38865) Docs: Fix typos and clarify capacity scope in Async I/O documentation Vishal Kamlapure (Jira)
• [jira] [Created] (FLINK-38864) HTTP Connector : Add IGNORE_STATUS_CODE http-completion-state david radley (Jira)
• [jira] [Created] (FLINK-38863) flink-opensearch tests fail with "Connector production code must depend only on public API when outside of connector packages" Roman Grebennikov (Jira)
• [jira] [Created] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) Efrat Levitan (Jira)
• [jira] [Created] (FLINK-38861) Update Documentation to cover new CREATE/ALTER operations for MATERIALIZED TABLEs Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38860) Remove flink shaded guava usage from operator Gyula Fora (Jira)
• [jira] [Created] (FLINK-38859) Do not apply minimum job vertex parallelism for whole job in native mode Gyula Fora (Jira)
• [jira] [Created] (FLINK-38858) Reuse jobid after failed submissions to guard against job duplication Gyula Fora (Jira)
• [jira] [Created] (FLINK-38857) Introduce a Triton inference module under flink-models for batch-oriented AI inference featzhang (Jira)
• [jira] [Created] (FLINK-38856) Add support for ALTER MATERIALIZED TABLE DROP schema component Sergey Nuyanzin (Jira)
• Re: [jira] [Updated] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema Matthias Pohl
• [jira] [Created] (FLINK-38855) Upgrade jackson to 2.20.1 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38854) Enrich upsert keys across equivalence relations in MultiJoin Anton Borisov (Jira)
• [jira] [Created] (FLINK-38853) Enhance the standardization of the REST API JSON schema Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38852) FLIP-556: Introduce BITMAP Data Type dylanhz (Jira)
• [jira] [Created] (FLINK-38851) [Connector/JDBC] Support passing arbitrary database options to JDBC Catalog CHANHAE OH (Jira)
• [jira] [Created] (FLINK-38850) [Connector/JDBC] Support PostgreSQL uuid type CHANHAE OH (Jira)
• [jira] [Created] (FLINK-38849) HybridSourceReader does not respect pauseOrResumeSplits implementations Matt Cuento (Jira)
  • Re: [jira] [Created] (FLINK-38849) HybridSourceReader does not respect pauseOrResumeSplits implementations MD
• [jira] [Created] (FLINK-38848) Catalog#getTable should indicate if it's for writing He Qi (Jira)
• [jira] [Created] (FLINK-38847) Incorrect construction of Postgres ConnectionPoolId Di Wu (Jira)
• [jira] [Created] (FLINK-38846) Binlog client use LinkedList to store binlog content Jira
• [jira] [Created] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Yi Zhang (Jira)
• [jira] [Created] (FLINK-38844) Add metadata column support for PostgreSQL Pipeline Connector tchivs (Jira)
• [jira] [Created] (FLINK-38843) Flakey test case ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart RocMarshal (Jira)
• [jira] [Created] (FLINK-38842) FileSink may leave orphaned temporary files in COS after restoring from a checkpoint, due to missing cleanup logic for temporary files in the checkpointed state. linguoxuan (Jira)
• [VOTE] Release flink-shaded 21.0, release candidate #2 Martijn Visser
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #2 Mate Czagany
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #2 Sergey Nuyanzin
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #2 Martijn Visser
• [jira] [Created] (FLINK-38841) Nullability is lost in FamilyArgumentStrategy dylanhz (Jira)
• [jira] [Created] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38839) Support semicolon delimiter for transform table-options tchivs (Jira)
• [Ask Help] Update migration tests failed for Flink 2.2.0 Hang Ruan
  • Re: [Ask Help] Update migration tests failed for Flink 2.2.0 Hang Ruan
  • Re: [Ask Help] Update migration tests failed for Flink 2.2.0 Leonard Xu
  • Re: [Ask Help] Update migration tests failed for Flink 2.2.0 Hang Ruan
• [jira] [Created] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 Yanquan Lv (Jira)
• [VOTE] Release flink-shaded 21.0, release candidate #1 Martijn Visser
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release flink-shaded 21.0, release candidate #1 Martijn Visser via dev
• [jira] [Created] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector Leonard Xu (Jira)
• [jira] [Created] (FLINK-38836) Chinese documentation for pipeline configuration options is missing. peiyu (Jira)
• [jira] [Created] (FLINK-38835) When using postgresql cdc to read timestamp data with a value of 1900-01-01, abnormal data occurred Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38834) Support modify column type DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization peiyu (Jira)
• [jira] [Created] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38831) The route configuration supports matching the first one peiyu (Jira)
• [jira] [Created] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-38829) Support rename column DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)

• Earlier messages
• Later messages