dev  

Messages by Thread

• [jira] [Created] (FLINK-38103) DataTypeFactory cannot restore inline structured types Timo Walther (Jira)
• [jira] [Created] (FLINK-38102) RestApiMetricsCollectorTest is unstable Robert Metzger (Jira)
• [jira] [Created] (FLINK-38101) Support SI Format for CPU resources Santwana Verma (Jira)
• [jira] [Created] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector Luca Occhipinti (Jira)
• [jira] [Created] (FLINK-38099) Greenplum: Distribution column updates in Greenplum upsert zm999999 (Jira)
• [jira] [Created] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed shilei (Jira)
• [jira] [Created] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator Kumar Mallikarjuna (Jira)
• [jira] [Created] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy Jira
• [jira] [Created] (FLINK-38095) Error in Session Job autoscaler when realizing parallelism overrides Jean-Benoit Hamard (Jira)
• [jira] [Created] (FLINK-38094) Introduce pyflink.__version__ Yun Tang (Jira)
• [jira] [Created] (FLINK-38093) Update version of Fabric8 to 7.3.1 Mate Czagany (Jira)
• [jira] [Created] (FLINK-38091) Update japicmp configuration post 1.20.2 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38092) Update japicmp configuration post 1.19.3 Ferenc Csaky (Jira)
• [ANNOUNCE] Apache Flink 1.20.2 released Ferenc Csaky
  • Re: [ANNOUNCE] Apache Flink 1.20.2 released Sergey Nuyanzin
• [ANNOUNCE] Apache Flink 1.19.3 released Ferenc Csaky
  • Re: [ANNOUNCE] Apache Flink 1.19.3 released Sergey Nuyanzin
• [jira] [Created] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types Timo Walther (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.12.1 released Gyula Fóra
• Flink HTTP connector health proposal going forward. David Radley
  • Re: Flink HTTP connector health proposal going forward. Martijn Visser
  • RE: Flink HTTP connector health proposal going forward. David Radley
• [jira] [Created] (FLINK-38089) Avoid pushing down non-deterministic filter in agg, join and union Qilong Wang (Jira)
• [jira] [Created] (FLINK-38088) If source config "scan.startup.mode:snapshot",not create replicatedconnect. ouyangwulin (Jira)
• [jira] [Created] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage Mingliang Liu (Jira)
• [jira] [Created] (FLINK-38086) Make ChangelogNormalize reusable if possible Sergey Nuyanzin (Jira)
• [RESULT][VOTE] FLIP-523 - Handle TLS Certificate Renewal Alex Nitavsky
• [jira] [Created] (FLINK-38085) Use buildx for Docker image creation Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38084) Update model provider download doc Hao Li (Jira)
• [jira] [Created] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38082) User's async function timeout call may result in unexpected retries lincoln lee (Jira)
• [jira] [Created] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38080) Avoid pushing down non-deterministic relNodes by mistake Qilong Wang (Jira)
• [jira] [Created] (FLINK-38079) Add Pipeline support for DateType and TimeType wuzexian (Jira)
• [jira] [Created] (FLINK-38078) DataStream API Execution Configuration doc contains deleted API usage Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing Gyula Fora (Jira)
• [jira] [Created] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 fallenup (Jira)
• [jira] [Created] (FLINK-38075) [Window]Data loss when using ltz time. kaitian (Jira)
• [jira] [Created] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng (Jira)
• [jira] [Created] (FLINK-38073) Add documentation for the MultiJoin Operator Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38072) EventTimeWindowCheckpointingITCase#testSlidingTimeWindow test failed in cron ci dalongliu (Jira)
• [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry Lincoln Lee
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry Lincoln Lee
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry HONGGEUN JI
  • Re: [Bug Report] timeout() not triggered on retries in AsyncDataStream.unorderedWaitWithRetry Lincoln Lee
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra
• Flink Connector Kafka Releases Tom Cooper
• Re: [Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector Mingliang Liu
• [ANNOUNCE] Release 2.1.0, release candidate #0 Ron Liu
• [jira] [Created] (FLINK-38071) FLIP-485: Add UDF Metrics Weiqing Yang (Jira)
• [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re: [DISCUSS] Add UDF Metrics Shengkai Fang
  • Re: [DISCUSS] Add UDF Metrics Alan Sheinberg
  • Re: [DISCUSS] Add UDF Metrics Weiqing Yang
  • Re:Re: [DISCUSS] Add UDF Metrics Xuyang
  • Re: [DISCUSS] Add UDF Metrics Weiqing Yang
• [jira] [Created] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API Yash Anand (Jira)
• [jira] [Created] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL Dylan He (Jira)
• [jira] [Created] (FLINK-38068) Fix distribution Hao Li (Jira)
• [jira] [Created] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li (Jira)
• [jira] [Created] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL Hao Li (Jira)
• [jira] [Created] (FLINK-38065) Mismatching bracket in PostgresOffset#toString Sergei Morozov (Jira)
• [jira] [Created] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 Siddharth R (Jira)
• Flink Kubenetes Operator client version David Radley
  • Re: Flink Kubenetes Operator client version Gyula Fóra
  • RE: Flink Kubenetes Operator client version David Radley
  • Re: Flink Kubenetes Operator client version Tom Cooper
• [jira] [Created] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project Thomas Cooper (Jira)
• [jira] [Created] (FLINK-38062) ENCODE behaves wrong Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint potterhe (Jira)
• [jira] [Created] (FLINK-38060) Github action build python wheel on linux failed dalongliu (Jira)
• Re: [Discuss] FLIP-485: Flink UDF metrics Weiqing Yang
• [jira] [Created] (FLINK-38059) [docs] Add fluss pipeline connector documentation Leonard Xu (Jira)
• [jira] [Created] (FLINK-38058) Add e2e test for fluss pipeline connector Leonard Xu (Jira)
• [jira] [Created] (FLINK-38057) Connector emit time lag may be a wrong value Ruan Hang (Jira)
• [jira] [Created] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-38055) The internalTimerService must initialize watermark before processing data Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38054) Kryo Deserialization Error in ElasticSearch 8 Sink 3.1.0 With Flink 1.20.0 Andrey Starostin (Jira)
• [jira] [Created] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink dalongliu (Jira)
• [jira] [Created] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator dalongliu (Jira)
• [jira] [Created] (FLINK-38051) Fix flaky test JobAutoScalerImplTest Mate Czagany (Jira)
• 2025/07/02 CHI Eastern time zone workgroup meeting minutes David Radley
• Request for PMC to get PyPI access Ferenc Csaky
  • Re: Request for PMC to get PyPI access Dian Fu
• [jira] [Created] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38049) UpgradeMode falls back to last-state mode on HA resubmission even for stateless Lucas Borges (Jira)
• [jira] [Created] (FLINK-38048) flink-connector-parent java version should be set to 11 Etienne Chauchot (Jira)
• [jira] [Created] (FLINK-38047) Bump cert-manager in the Kubernetes Operator Kumar Mallikarjuna (Jira)
• [jira] [Created] (FLINK-38046) Solve the issue of missing one piece of data jingzi (Jira)
• [jira] [Created] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache wuzexian (Jira)
• [jira] [Created] (FLINK-38044) [UI] upgrade runtime web Angular framework and related deps to lastest version Ao Yuchen (Jira)
• [jira] [Created] (FLINK-38043) Support joining without join keys Gustavo de Morais (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Mate Czagany
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Weiqing Yang
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Maximilian Michels
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.1, release candidate #1 Gyula Fóra
• Slack Invite ! Sachin
  • Re: Slack Invite ! Gustavo de Morais
• Review nit: s David Radley
• [jira] [Created] (FLINK-38042) Warn the user on full table scans Etienne Chauchot (Jira)
• Invite to Slack Juliusz Nadbereżny
  • Re: Invite to Slack Gustavo de Morais
• Flink CDC Pipeline connector support for Postgres dontu balu
  • Re: Flink CDC Pipeline connector support for Postgres Leonard Xu
• [DISCUSS] Kubernetes Operator 1.12.1 patch release Gyula Fóra
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Tom Cooper
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Ryan van Huuksloot
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Gabor Somogyi
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Weiqing Yang
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Yuepeng Pan
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Kumar Mallikarjuna
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Mate Czagany
  • Re: [DISCUSS] Kubernetes Operator 1.12.1 patch release Attila Mészáros
• [RESULT][VOTE] Release 1.20.2, release candidate #2 Ferenc Csaky
  • Re: [RESULT][VOTE] Release 1.20.2, release candidate #2 Maximilian Michels
• [RESULT][VOTE] Release 1.19.3, release candidate #2 Ferenc Csaky
  • Re: [RESULT][VOTE] Release 1.19.3, release candidate #2 Maximilian Michels
• [jira] [Created] (FLINK-38041) Schema.Builder#fromResolvedSchema dropps comments Arvid Heise (Jira)
• [jira] [Created] (FLINK-38040) Documentation for VARIANT type and PARSE_JSON Xuannan Su (Jira)
• [jira] [Created] (FLINK-38039) Fix broken link and improve instructions for using connectors in Docker mode Mingliang Liu (Jira)
• [jira] [Created] (FLINK-38038) Fix some typos in code, tests and docs Mingliang Liu (Jira)
• [jira] [Created] (FLINK-38037) Configure hashDistribution with commonJoinKey Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38036) Make PlannerBase#getExecNodeGraphProcessors pulbic Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) Niha (Jira)
• [jira] [Created] (FLINK-38034) raise back the visibility of org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest to public Etienne Chauchot (Jira)
• [jira] [Created] (FLINK-38033) Job upgrades fail for operator v1.12 Salva (Jira)
• [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink David Radley
  • Re: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink Sergey Nuyanzin
  • Re: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink Robert Metzger
  • Re: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink Leonard Xu
  • RE: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink David Radley
  • Re: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink Sergey Nuyanzin
  • RE: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink David Radley
  • Re: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink Robert Metzger
  • Re: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink Robert Metzger
  • RE: [RESULT][VOTE] Flip-532 Donate GetInData HTTP Connector to Flink David Radley
• [VOTE] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [VOTE] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [VOTE] FLIP-523 - Handle TLS Certificate Renewal archzi lu
  • Re: [VOTE] FLIP-523 - Handle TLS Certificate Renewal wj wang
  • Re: [VOTE] FLIP-523 - Handle TLS Certificate Renewal Yuepeng Pan
  • Re: [VOTE] FLIP-523 - Handle TLS Certificate Renewal Gyula Fóra
  • Re: [VOTE] FLIP-523 - Handle TLS Certificate Renewal Őrhidi Mátyás
  • Re: [VOTE] FLIP-523 - Handle TLS Certificate Renewal Alex Nitavsky
• Flink 1.20.1 - Window Tumbling Group has empty result but event_time and watermark have been set dmitri yanno mahayana
• [jira] [Created] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode Shuai Xu (Jira)
• [jira] [Created] (FLINK-38031) Support and Release Connectors for Flink 2.1 dalongliu (Jira)
• [jira] [Created] (FLINK-38030) Table.explainSql throw exception: xxx cannot be cast to class org.apache.flink.table.catalog.AbstractCatalog Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38028) Rename MLPredictUtils and FunctionCallUtils Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38027) Apply simplify for watermark expresions Sergey Nuyanzin (Jira)
• [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Alexander Matheson
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Dian Fu
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Zander Matheson
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Dian Fu
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Dian Fu
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Guowei Ma
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Zander Matheson
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Dian Fu
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Zander Matheson
  • Re: [DISCUSS] FLIP-XXX Improving PyFlink - The Zen of Flink Dian Fu
• [jira] [Created] (FLINK-38026) Oracle CDC scanNewlyAddedTableEnabled is case-sensitive to the database name, which results in the inability to match the database tables. Wenkai Qi (Jira)
• [jira] [Created] (FLINK-38025) Update Flink Doc for aws connector v6.0.0 Daren Wong (Jira)
• Minutres of 2025/06/26 CHI Western time zone workgroup meeting David Radley
• [VOTE] Release flink-connector-aws v6.0.0, release candidate #1 Daren Wong
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #1 Keith Lee
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #1 Keith Lee
• [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Daren Wong
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Keith Lee
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Keith Lee
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Daren Wong
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Daren Wong
• [jira] [Created] (FLINK-38024) Unify the timestamp types to use TimestampData with time zone information. zjjiang (Jira)
• [jira] [Created] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema Keshav Kansal (Jira)
• [jira] [Created] (FLINK-38022) StreamingDeltaJoinOperator hangs with timeout Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38021) The problem of double quotation marks in the default value of automatic table parsing Thorne (Jira)
• [jira] [Created] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE Hao Li (Jira)
• [jira] [Created] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38018) Migrate state processor API from sink API v1 to source API v2 Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38017) [Release-2.1] Add release note for release 2.1 dalongliu (Jira)
• [jira] [Created] (FLINK-38016) [Release-2.1] Verify that no exclusions were erroneously added to the japicmp plugin dalongliu (Jira)
• [jira] [Created] (FLINK-38015) [Release-2.1] Review and update documentation dalongliu (Jira)
• [jira] [Created] (FLINK-38014) [Release-2.1] Triage release-blocking issues in JIRA dalongliu (Jira)
• [jira] [Created] (FLINK-38013) [Release-2.1] Cross team testing dalongliu (Jira)
• [jira] [Created] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA dalongliu (Jira)
• [jira] [Created] (FLINK-38011) [Release-2.1] Prepare RC0 release dalongliu (Jira)
• [ANNOUNCE] release-2.1 branch cut Ron Liu
• [jira] [Created] (FLINK-38010) [Release-2.1] Create a release branch dalongliu (Jira)
• [jira] [Created] (FLINK-38009) [Release-2.1] Select executing Release Manager dalongliu (Jira)
• [jira] [Created] (FLINK-38008) [Release-2.1] Create a new version in JIRA dalongliu (Jira)
• [jira] [Created] (FLINK-38007) Prepare Flink 2.1 Release dalongliu (Jira)

• Earlier messages