dev  

Messages by Thread

• [jira] [Created] (FLINK-39001) [doc] Supplement the documentation regarding dynamic table addition Thorne (Jira)
• [jira] [Created] (FLINK-39000) Avoid redundant seeks during operator list state restore Ivan Torres (Jira)
• [jira] [Created] (FLINK-38999) License lineage files Efrat Levitan (Jira)
• [jira] [Created] (FLINK-38998) Cascaded event time Window Aggregate does not produce data when offset is specified Sergey Kononov (Jira)
• [jira] [Created] (FLINK-38997) Job can get stuck in state transition because unexpected error during ExecutionGraph creation Matthias Pohl (Jira)
• [jira] [Created] (FLINK-38996) Add origin transform sql expression into exception message Jia Fan (Jira)
• [jira] [Created] (FLINK-38995) Update the current Status of Disaggregated State & ForSt Yuan Mei (Jira)
• [jira] [Created] (FLINK-38994) Remove dependency log4j1 from flink-cdc-cli Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38993) Move query change validation logic from converter to operation Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Bonnie Varghese (Jira)
• [jira] [Created] (FLINK-38991) MySQL CDC fails to detect online schema changes with custom gh-ost or pt-osc table naming Vishal P R (Jira)
• Re: [DISCUSS] Status of Statefun Project Martijn Visser
  • Re: [DISCUSS] Status of Statefun Project Martijn Visser
  • Re: [DISCUSS] Status of Statefun Project Galen Warren via dev
  • RE: [DISCUSS] Status of Statefun Project frans.king
• [jira] [Created] (FLINK-38990) Support configurable initial delay for first checkpoint trigger Liu (Jira)
• [jira] [Created] (FLINK-38989) Support resetting backlog status Shuai Xu (Jira)
• [jira] [Created] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
• [jira] [Created] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem yunjiong zhao (Jira)
• [jira] [Created] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Swapna Marru (Jira)
• Proposal to release the HTTP connector version 1.0 and 2.0 David Radley
  • Re: Proposal to release the HTTP connector version 1.0 and 2.0 Ferenc Csaky
• [jira] [Created] (FLINK-38985) [Doc] Add document for VARIANT type and related functions Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38984) Python interpreter not found when using thread mode (pemja) raoraoxiong (Jira)
• [jira] [Created] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-38979) flink-tests-java17 skipped while java21 build Sergey Nuyanzin (Jira)
• [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 Rich Bowen
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 tjoch
  • RE: [VOTE] Release flink-connector-aws v6.0.0, release candidate #3 abhi Gupta
• [ANNOUNCE] New Apache Flink Committer - David Radley Robert Metzger
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Rion Williams
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Shalini
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Ferenc Csaky
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Yuepeng Pan
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Jiangang Liu
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - David Radley Xuyang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - David Radley Sergey Nuyanzin
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - David Radley Swapnal Varma
  • RE: Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • RE: Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • RE:Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Zhanghao Chen
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Weiqing Yang
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Zhe Wang
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley roryqi
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley 吴晓军
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Feng Jin
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Hang Ruan
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley Sebastien Pereira
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley dylanhz
  • RE: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - David Radley David Radley
• [jira] [Created] (FLINK-38977) Expose exceptions for applications Yi Zhang (Jira)
• [jira] [Created] (FLINK-38978) Expose JM config for applications Yi Zhang (Jira)
• [jira] [Created] (FLINK-38976) Support multiple jobs in an application Yi Zhang (Jira)
• [jira] [Created] (FLINK-38975) Re-execute applications after HA recovery in session mode Yi Zhang (Jira)
• [jira] [Created] (FLINK-38974) Handle jobs during HA recovery Yi Zhang (Jira)
• [jira] [Created] (FLINK-38973) Job ID assignment and matching based on name Yi Zhang (Jira)
• [jira] [Created] (FLINK-38972) FLIP-560: Application Capability Enhancement Yi Zhang (Jira)
• [jira] [Created] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule Roman Rybak (Jira)
• [jira] [Created] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. Swapna Marru (Jira)
• [jira] [Created] (FLINK-38968) Add toCatalogTable method to CatalogMaterializedTable interface Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Mate Czagany (Jira)
• [jira] [Created] (FLINK-38966) Update rsync Github Actions to 8.0.2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-38965) Postgres cdc source encounted "java.lang.IllegalStateException: Duplicate key Optional" Tao Wang (Jira)
• [RESULT][VOTE] FLIP-560: Application Capability Enhancement Yi Zhang
• [jira] [Created] (FLINK-38964) Reuse Calcite's SlqValidatorImpl#maybeCast Sergey Nuyanzin (Jira)
• [VOTE] Release flink-connector-aws v6.0.0, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #2 Rich Bowen
  • RE: [VOTE] Release flink-connector-aws v6.0.0, release candidate #2 abhi Gupta
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #2 Mate Czagany
  • Re: [VOTE] Release flink-connector-aws v6.0.0, release candidate #2 Ferenc Csaky
• [DISCUSS] Release flink-connector-parent v2.0.0 Ferenc Csaky
  • Re: [DISCUSS] Release flink-connector-parent v2.0.0 Mate Czagany
  • Re: [DISCUSS] Release flink-connector-parent v2.0.0 Ferenc Csaky
  • Re: [DISCUSS] Release flink-connector-parent v2.0.0 Leonard Xu
  • Re: [DISCUSS] Release flink-connector-parent v2.0.0 Martijn Visser
• [jira] [Created] (FLINK-38963) Altering query should be possible if MATERIALIZED TABLE schema contains non persisted columns Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38962) Add OpenSearch 3.x connector support Julian Dimitrov (Jira)
• [jira] [Created] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Liu (Jira)
• [jira] [Created] (FLINK-38960) Update the "upgrading" documentation to clarify the scope of state compatibility Han Yin (Jira)
• [jira] [Created] (FLINK-38959) Added support for schema change in the postgres pipeline connector Jira
• [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode archit goyal
• [jira] [Created] (FLINK-38958) Support provided lib archives for YARN application mode Archit Goyal (Jira)
• Reviewers for Kafka Connector Projection Pushdown Ryan van Huuksloot via dev
  • Re: Reviewers for Kafka Connector Projection Pushdown Aleksandr Savonin
• [DISCUSS] Planning Flink 2.3 David Anderson
  • Re: [DISCUSS] Planning Flink 2.3 Leonard Xu
  • Re: [DISCUSS] Planning Flink 2.3 Rui Fan
  • Re: [DISCUSS] Planning Flink 2.3 Yuepeng Pan
  • Re: [DISCUSS] Planning Flink 2.3 David Anderson
  • Re: [DISCUSS] Planning Flink 2.3 Ferenc Csaky
  • Re: [DISCUSS] Planning Flink 2.3 Jark Wu
• [discussion] Prevent direct edits to FlinkDeployments owned by FlinkBlueGreenDeployments James Kan via dev
  • Re: [discussion] Prevent direct edits to FlinkDeployments owned by FlinkBlueGreenDeployments Gyula Fóra
• [jira] [Created] (FLINK-38957) ProcessTableFunction UDFs cannot be loaded via CompiledPlan Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38956) The Web UI cannot automatically show the latest edge name for AdaptiveScheduler Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38955) Add canonical tag to generated Javadoc and PyDocs Martijn Visser (Jira)
• [jira] [Created] (FLINK-38954) Flink Benchmark Score Decreases After Upgrading JDK Versions of Flink Engine and User Program zhangxing (Jira)
• JSON_STRING and helper utilities around VARIANT data type Swapna Marru
  • Re: JSON_STRING and helper utilities around VARIANT data type Xuannan Su
• [jira] [Created] (FLINK-38953) Cleanup configurations for SSL hostname verification Mate Czagany (Jira)
• [jira] [Created] (FLINK-38952) Adapt PyFlink AWS connector code to the current Java class changes Ferenc Csaky (Jira)
• [VOTE] FLIP-560: Application Capability Enhancement Yi Zhang
  • Re: [VOTE] FLIP-560: Application Capability Enhancement Zhu Zhu
  • Re: [VOTE] FLIP-560: Application Capability Enhancement gyula . fora
  • Re: [VOTE] FLIP-560: Application Capability Enhancement Yuepeng Pan
  • Re: [VOTE] FLIP-560: Application Capability Enhancement Rui Fan
  • Re: [VOTE] FLIP-560: Application Capability Enhancement Lei Yang
  • Re: [VOTE] FLIP-560: Application Capability Enhancement Shengkai Fang
  • Re: [VOTE] FLIP-560: Application Capability Enhancement Yi Zhang
• [jira] [Created] (FLINK-38951) Upgrade pemja to 0.5.6 Xuannan Su (Jira)
• [jira] [Created] (FLINK-38950) Views with window TVFs and ORDER BY generate malformed SQL with duplicated ORDER BY clauses Sebastien Pereira (Jira)
• [jira] [Created] (FLINK-38949) unpack_build_artifact.sh script speed improvement Tom Ho (Jira)
• [jira] [Created] (FLINK-38948) Document SINGLE_VALUE aggregate function Timo Walther (Jira)
• [jira] [Created] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38946) Update Datadog API endpoint from app.datadoghq to api.datadoghq Ivan Stoiev (Jira)
• [jira] [Created] (FLINK-38945) [FLIP-561] Restructure Flink documentation Martijn Visser (Jira)
• [RESULT][VOTE] FLIP-561: Restructure Flink documentation Martijn Visser
• [jira] [Created] (FLINK-38944) Introduce a benchmark on adaptive partition selection for rescale partitioner and rebalance partitioner Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-38943) Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner Yuepeng Pan (Jira)
• [RESULT][VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
• [jira] [Created] (FLINK-38942) Add documentation for async python scalar function Dian Fu (Jira)
• [jira] [Created] (FLINK-38941) Add Python building blocks for Async Python Scalar Function Dian Fu (Jira)
• [jira] [Created] (FLINK-38940) Wait for all tasks to be running before triggering the first checkpoint Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38939) Pause sources until the 1st checkpoint to prioritize processing recovered records Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38938) Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38937) Introduce TestKafkaContainer to support Confluent and official Apache Kafka images with KRaft Aleksandr Savonin (Jira)
• [DISCUSS] SSL hostname verification Mate Czagany
  • Re: [DISCUSS] SSL hostname verification Gabor Somogyi
• [jira] [Created] (FLINK-38936) FileSystem SQL Connector,The connector metadata file.name, Caused by: java.nio.file.InvalidPathException: Illegal char <:> at index 2 liuerbao (Jira)
• [jira] [Created] (FLINK-38935) HTTP Connector Fixe Bearer token casing in OIDC Change Authorization header from "BEARER" to "Bearer" to comply with RFC 6750. David Radley (Jira)
• [jira] [Created] (FLINK-38934) Debezium config 'binlog.ssl.protocol' is ignored John Watson (Jira)
• [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
  • Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Rui Fan
  • Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Zhanghao Chen
  • Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Wei Zhong
  • Re: [VOTE] FLIP-339: Support Adaptive Partition Selection forStreamPartitioner o酷鱼o
  • Re: [VOTE] FLIP-339: Support Adaptive Partition Selection forStreamPartitioner Yuepeng Pan
  • Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner yuanfeng hu
  • Re:[VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Mang Zhang
  • Re: [VOTE] FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan
• [jira] [Created] (FLINK-38933) python udx supports get_index_of_this_subtask Jacky Lau (Jira)
• [jira] [Created] (FLINK-38932) Incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-38931) Support finish method in Python Table Function Dian Fu (Jira)
• Enhance Flink DynamicKafkaSource Bowen Li
  • Re: Enhance Flink DynamicKafkaSource Hongshun Wang
  • Re: Enhance Flink DynamicKafkaSource Hongshun Wang
• [jira] [Created] (FLINK-38930) Filtering record before processing without spilling strategy Rui Fan (Jira)
• [VOTE] FLIP-561: Restructure Flink documentation Martijn Visser
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Ryan van Huuksloot via dev
  • Re: [VOTE] FLIP-561: Restructure Flink documentation dylanhz
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Efrat Levitan
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Hao Li via dev
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Xintong Song
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Leonard Xu
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Yuepeng Pan
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Zhanghao Chen
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Zhu Zhu
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Rui Fan
  • Re: [VOTE] FLIP-561: Restructure Flink documentation David Anderson
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Zander Matheson
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Zhe Wang
  • Re: [VOTE] FLIP-561: Restructure Flink documentation Martijn Visser
• [jira] [Created] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING Dawid Wysakowicz (Jira)
• [RESULT][VOTE] FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz
• [jira] [Created] (FLINK-38929) Add the ON CONFLICT configuration options Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-38926) FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-38927) Support ON CONFLICT in SqlParser Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-38925) Update Matomo URL to the right domain Martijn Visser (Jira)
• [jira] [Created] (FLINK-38924) Redirect users to main page when encountering a 404 Martijn Visser (Jira)
• [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
  • Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Rui Fan
  • Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Aleksandr Savonin
  • Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Leonard Xu
• [jira] [Created] (FLINK-38921) osc support custom regx Jira
• [ANNOUNCE] Apache flink-connector-aws v5.1.0 released Ferenc Csaky
• [jira] [Created] (FLINK-38922) Cache Maven dependencies during documentation build Martijn Visser (Jira)
• [jira] [Created] (FLINK-38923) Pass configuration to operators/functions useInterruptibleTimers() Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API Bowen Li (Jira)
• [jira] [Created] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Bowen Li (Jira)
• [jira] [Created] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink Bowen Li (Jira)
• [jira] [Created] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka Bowen Li (Jira)
• [jira] [Created] (FLINK-38916) MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-38910) mysql-cdc-connector datastrea support scan.binlog.newly-added-table.enabled config Thorne (Jira)
• [jira] [Created] (FLINK-38915) Suspending Pipeline Breaks FlinkBlueGreenDeployment Daniel Rossos (Jira)
• FLINK-38913 David Radley

• Earlier messages