dev  

Messages by Thread

• [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
  • Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Yanquan Lv
  • RE: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Zexian WU
  • RE: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Zexian WU
• [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)
• [ANNOUNCE] Introducing "Debo" – A Unified Management Tool for the Hadoop Ecosystem, Including Flink Support Surafel Temesgen
• [DISCUSS] FLIP-535: Support Storage Partition Join in Flink Lu Niu
  • Re:[DISCUSS] FLIP-535: Support Storage Partition Join in Flink Xuyang
• [jira] [Created] (FLINK-37993) Release Testing Instructions: Verify FLIP-486: Introduce a new DeltaJoin dalongliu (Jira)
• [jira] [Created] (FLINK-38006) Support Python for Flink AWS connectors in Flink 2.0 Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-37996) Release Testing Instructions: Verify FLIP-437: Support ML Models in Flink SQL dalongliu (Jira)
• [jira] [Created] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector dalongliu (Jira)
• [jira] [Created] (FLINK-37997) Release Testing Instructions: Verify FLIP-521: Integrating Variant Type into Flink dalongliu (Jira)
• [jira] [Created] (FLINK-38005) Release Testing Instructions: Verify FLIP-509: Custom Batch Handling in AsyncSink dalongliu (Jira)
• [jira] [Created] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector dalongliu (Jira)
• [jira] [Created] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data dalongliu (Jira)
• [jira] [Created] (FLINK-38001) Release Testing Instructions: Verify FLIP-508: Add support for Smile format for Compiled plans dalongliu (Jira)
• [jira] [Created] (FLINK-38000) Release Testing Instructions: Verify FLIP-507 : Add Model DDL methods in TABLE API dalongliu (Jira)
• [jira] [Created] (FLINK-37999) Release Testing Instructions: Verify FLIP-516: Streaming Multi-Way Join Optimization dalongliu (Jira)
• [jira] [Created] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner dalongliu (Jira)
• [jira] [Created] (FLINK-37998) Release Testing Instructions: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design dalongliu (Jira)
• [jira] [Created] (FLINK-37995) Release Testing Instructions: Verify FLIP-520: Simplify StructuredType handling dalongliu (Jira)
• [jira] [Created] (FLINK-37994) Release Testing Instructions: Verify FLIP-519: Introduce async lookup key ordered mode dalongliu (Jira)
• [jira] [Created] (FLINK-37991) Upgrade pemja to 0.6.x Xingbo Huang (Jira)
• [KINDLY REMINDER] release-2.1 branch cut Ron Liu
• [jira] [Created] (FLINK-37990) [Umbrella] Test Flink Release 2.1 dalongliu (Jira)
• [SUMMARY] Flink 2.1 Release Sync 06/25/2025 Ron Liu
• [jira] [Created] (FLINK-37989) Add condition support Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37988) Add left join support Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37987) Implement JdbcDynamicTableSinkV2 to use new Sink API v2 Poorvank Bhatia (Jira)
• [jira] [Created] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-37985) Refactor public config options from StreamConfig to JobConfiguration Rui Fan (Jira)
• [jira] [Created] (FLINK-37984) Move Cassandra Sink to Sink V2 Poorvank Bhatia (Jira)
• Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Qiang He
  • Re: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Leonard Xu
  • Re: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Qiang He
• Help - Question on triaging slowness Siva Ram Gujju
  • Re: Help - Question on triaging slowness Matt Cuento
  • Re:Re: Help - Question on triaging slowness Xuyang
  • Re: Re: Help - Question on triaging slowness Siva Ram Gujju
• [RESULT] [VOTE] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
• [jira] [Created] (FLINK-37983) Upgrade Kafka Client version to 3.9.1 Thomas Cooper (Jira)
• [DISCUSS] FLIP-534 Reduce OLAP Query Latency In Flink Session Cluster. wj wang
• [jira] [Created] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37982) When Watermark is updated, the result output in TableAsyncExecutionController cannot be triggered Qilong Wang (Jira)
• [jira] [Created] (FLINK-37980) Adapt Multi-way join to higher Calcite versions (Calcite 1.35+) Sergey Nuyanzin (Jira)
• [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Hao Li
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Sergey Nuyanzin
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Teunissen, F.G.J. (Fred)
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Sergey Nuyanzin
  • Re: [ANNOUNCE] Flink 2.1 feature freeze Ron Liu
• [jira] [Created] (FLINK-37979) Obsolete MySQL CDC snapshot split assigner code Sergei Morozov (Jira)
• [jira] [Created] (FLINK-37978) Change max-buffer config to max-concurrent-operations Hao Li (Jira)
• [jira] [Created] (FLINK-37977) Variant implements Serializable Xuannan Su (Jira)
• Slack invitation Jure Prevc
  • Re: Slack invitation Gustavo de Morais
  • Re: Slack invitation Fabrizzio Chavez
• [jira] [Created] (FLINK-37976) DeltaJoinITCase seems to be struck in CI Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37975) sync a lot sharding table Post Transform failed tongyp (Jira)
• [DISCUSS] FLIP-440: Annotation naming for PTFs Timo Walther
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Gustavo de Morais
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Hao Li
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Arvid Heise
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Martijn Visser
  • Re: [DISCUSS] FLIP-440: Annotation naming for PTFs Timo Walther
• [jira] [Created] (FLINK-37974) Avoid confusion when declaring table arguments Timo Walther (Jira)
• [jira] [Created] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins Gustavo de Morais (Jira)
• 2025/06/19 CHI Eastern time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-37972) Support jar and UserClassLoader sharing between jobs. Weijun Wang (Jira)
• CLIFrontend exit codes not reflecting application results? Allison
• [jira] [Created] (FLINK-37971) SQL hints are dropped by planner when Maximilian Michels (Jira)
• [jira] [Created] (FLINK-37970) Support PLAN_TEST_FORCE_OVERWRITE for .xml artifacts Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37969) Allow Transformation subgraphs to be merged during translation Arvid Heise (Jira)
• [SUMMARY] Flink 2.1 Release Sync 06/18/2025 Ron Liu
• [jira] [Created] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis Radha Krishna Peteti (Jira)
• [jira] [Created] (FLINK-37967) Add Confluent product and link to vendor solutions documentation Martijn Visser (Jira)
• [jira] [Created] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin Gustavo de Morais (Jira)
• [KINDLY REMINDER] Flink 2.1 Release Sync 06/18/2025 Ron Liu
• [jira] [Created] (FLINK-37964) AsyncSinkWriterStateSerializer should consider the estimated size of request entry Jiaan Geng (Jira)
• [jira] [Created] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover yux (Jira)
• [jira] [Created] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter Gustavo de Morais (Jira)
• Flink CDC and Debezium Version Mohsen Rezaei
  • Re: Flink CDC and Debezium Version Leonard Xu
• [jira] [Created] (FLINK-37961) Support skip some state operators in TaskManager. Weijun Wang (Jira)
• [jira] [Created] (FLINK-37960) UnalignedCheckpointRescaleITCase#shouldRescaleUnalignedCheckpoint test failed in azure pipeline dalongliu (Jira)
• [jira] [Created] (FLINK-37959) supported All postgres sql 14 field types. ouyangwulin (Jira)
• [jira] [Created] (FLINK-37958) Flink CDC Sink connector support fluss JunboWang (Jira)
• [jira] [Created] (FLINK-37957) Do not write empty lists to compiled plan Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37956) Update SQL gateway for inline structured types Timo Walther (Jira)
• [FLINK-37908] Requesting reviewers on PR Jonathan Du
• Error aware SQL streams David Radley

• Earlier messages
• Later messages