dev
Thread
Date
Later messages
Messages by Thread
[jira] [Created] (FLINK-36924) cannot initialize module JavadocMethod - Property 'allowUndeclaredRTE' does not exist, please check the documentation
luoyuxia (Jira)
[jira] [Created] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19
Yanquan Lv (Jira)
[DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Michas Szacillo (BLOOMBERG/ 919 3RD A)
Re: [DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Mate Czagany
Re: [DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Lajith Koova
Re: [DISCUSS] Flink checkpointInfo and FlinkStateSnapshots
Mate Czagany
[jira] [Created] (FLINK-36922) Add warning when creating KryoSerializer for generic type
LEONID ILYEVSKY (Jira)
[DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Sergey Nuyanzin
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Ron Liu
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Sergey Nuyanzin
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Timo Walther
Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment
Sergey Nuyanzin
CHI: Automatic Stale PR Cleanup
Tom Cooper
Re: CHI: Automatic Stale PR Cleanup
Jim Hughes
Re: CHI: Automatic Stale PR Cleanup
Gyula Fóra
Re: CHI: Automatic Stale PR Cleanup
Matthias Pohl
Re: CHI: Automatic Stale PR Cleanup
Rui Fan
Re: CHI: Automatic Stale PR Cleanup
Tom Cooper
Re: CHI: Automatic Stale PR Cleanup
Hong
[DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Matthias Pohl
Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Matthias Pohl
Re:Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
Re: Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Matthias Pohl
Re: Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history
Yuepeng Pan
[jira] [Created] (FLINK-36921) AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails
Robert Metzger (Jira)
Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira
Alexander Fedulov
Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira
Matthias Pohl
Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira
Alexander Fedulov
[RESULT][VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
FW: FW: Re: Flink technical debt. Chi meeting
David Radley
Flink technical debt. Chi meeting
David Radley
[jira] [Created] (FLINK-36920) Update org.quartz-schedule:quartz
Anupam Aggarwal (Jira)
[jira] [Created] (FLINK-36919) Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-36918) Introduce ProcTimeSortOperator in TemporalSort with Async State API
Wang Qilong (Jira)
[jira] [Created] (FLINK-36917) Add OceanBase DataSource to Flink CDC
ChaomingZhang (Jira)
[jira] [Created] (FLINK-36916) Unexpected error in type inference logic of function 'TYPEOF' for ROW
Yiyu Tian (Jira)
[jira] [Created] (FLINK-36915) flink-oracle-cdc supports user-defined conditions or time updates
twan1588 (Jira)
[jira] [Created] (FLINK-36914) Sources with watermark alignment should wait for watermark generation
Xingcan Cui (Jira)
[VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Yanfei Lei
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Yunfeng Zhou
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Gabor Somogyi
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Hangxiang Yu
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Yuan Mei
Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan
Full Checkpoint information in UI and API
Ryan van Huuksloot
Re: Full Checkpoint information in UI and API
Zakelly Lan
Re: Full Checkpoint information in UI and API
Ryan van Huuksloot
Re: Full Checkpoint information in UI and API
Gabor Somogyi
[jira] [Created] (FLINK-36913) Add an option in Kafka Sink to manual map table to topic name.
Yanquan Lv (Jira)
[jira] [Created] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP
Weijie Guo (Jira)
[jira] [Created] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade
Jacky Lau (Jira)
[jira] [Created] (FLINK-36910) Support calling time-related dynamic functions with parenthesis
Gustavo de Morais (Jira)
[jira] [Created] (FLINK-36909) Reduce Stream Creation in StreamPatternSubscriber
xiaochen.zhou (Jira)
Log4j JSONTemplateLayout
Ryan van Huuksloot
Re: Log4j JSONTemplateLayout
Ryan van Huuksloot
Operator IPv6 support
Attila Kreiner
Re: Operator IPv6 support
Gyula Fóra
Re: Operator IPv6 support
Attila Kreiner
Re: Operator IPv6 support
Gyula Fóra
[RESULT][VOTE] FLIP-484: Add custom metric variables to operators
Piotr Nowojski
[RESULT][VOTE] FLIP-483: Add support for children Spans
Piotr Nowojski
Re: [VOTE] FLIP-483: Add support for children Spans
Piotr Nowojski
[RESULT][VOTE] FLIP-482: Add OpenTelemetryEventReporter
Piotr Nowojski
Re: [VOTE] FLIP-482: Add OpenTelemetryEventReporter
Piotr Nowojski
[RESULT][VOTE] FLIP-481: Introduce Event Reporting
Piotr Nowojski
Re: [VOTE] FLIP-481: Introduce Event Reporting
Piotr Nowojski
[jira] [Created] (FLINK-36908) All builds are failing
Martijn Visser (Jira)
[jira] [Created] (FLINK-36907) Bump flink-connector-aws to 1.20
Yanquan Lv (Jira)
[jira] [Created] (FLINK-36906) Optimize the logic for determining if a split is finished.
xiaochen.zhou (Jira)
[jira] [Created] (FLINK-36905) Update Chinese document to reflect the changes of FLIP-398
Zhanghao Chen (Jira)
[DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Feng Jin
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Feng Jin
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Ron Liu
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Lincoln Lee
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Feng Jin
Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.
Feng Jin
[jira] [Created] (FLINK-36904) Fix doc error on how to programmatically register a 3rd-party serializer
Zhanghao Chen (Jira)
[jira] [Created] (FLINK-36903) Add switch for built-in serialization support for common collection types
Zhanghao Chen (Jira)
[jira] [Created] (FLINK-36902) Security Manager deprecation
Liam Miller-Cushon (Jira)
[jira] [Created] (FLINK-36901) Backport Update the NodeJS to v22.11.0 (LTS)
Mehdi (Jira)
[jira] [Created] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python
Mika Naylor (Jira)
Pyflink in Docker Container
Dev
[jira] [Created] (FLINK-36899) Introduce metrics for cache
Yanfei Lei (Jira)
[Discuss] Hive connector bump to Flink 1.20
Yanquan Lv
Re: [Discuss] Hive connector bump to Flink 1.20
Leonard Xu
Re: [Discuss] Hive connector bump to Flink 1.20
Peter Huang
Re: [Discuss] Hive connector bump to Flink 1.20
Yanquan Lv
[jira] [Created] (FLINK-36898) Support SQL FLOOR and CEIL functions with NanoSecond
Hanyu Zheng (Jira)
[VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Jim Hughes
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Timo Walther
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Leonard Xu
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Ron Liu
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Leonard Xu
Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD
David Radley
[jira] [Created] (FLINK-36897) Error in calling processElement for AbstractAsynchronous StateStreamOperator
Wang Qilong (Jira)
[jira] [Created] (FLINK-36896) Table API trim expression incorrectly translated to SQL
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed.
ouyangwulin (Jira)
[jira] [Created] (FLINK-36894) rowId comparision is incorrect in oracle connector
shaohui hong (Jira)
[jira] [Created] (FLINK-36893) Support periodic full checkpoint
Xingcan Cui (Jira)
[jira] [Created] (FLINK-36892) Properly handle the watermark status
Zakelly Lan (Jira)
[DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Timo Walther
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Fabian Hüske
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Fabian Hüske
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Timo Walther
Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg
[jira] [Created] (FLINK-36891) MySQL CDC connector produces corrupted state in case of serialization failure
Sergei Morozov (Jira)
[jira] [Created] (FLINK-36890) ObservedGeneration is not updated on NOOP spec updates
Maximilian Michels (Jira)
[jira] [Created] (FLINK-36889) Mention locking down a Flink cluster in the 'Production Readiness Checklist'
Robert Metzger (Jira)
[jira] [Created] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out
Matthias Pohl (Jira)
[jira] [Created] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector
Yanquan Lv (Jira)
Re: cannot locate classes in flink-release-2.0-preview1 source
Zakelly Lan
[jira] [Created] (FLINK-36886) Support interruptible timers with async state processing
Zakelly Lan (Jira)
[jira] [Created] (FLINK-36885) Multiple tests are incorrectly migrated to JUnit 5
Dawid Wysakowicz (Jira)
Re: [DISCUSS] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Yanfei Lei
Re: [DISCUSS] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan
Re: [DISCUSS] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs
Zakelly Lan
[DISCUSS] Release flink-connector-mongodb 2.0.0
Jiabao Sun
Re: [DISCUSS] Release flink-connector-mongodb 2.0.0
Leonard Xu
[jira] [Created] (FLINK-36884) GCS 503 Error Codes for `flink-checkpoints/<id>/shared/` file after upload complete
Ryan van Huuksloot (Jira)
RE: Re: [DISCUSS] Flink 1.20.1 release
Ammu P
RE: Re: [DISCUSS] Flink 1.20.1 release
David Radley
Re: Re: [DISCUSS] Flink 1.20.1 release
ConradJam
Re: Re: [DISCUSS] Flink 1.20.1 release
Alexander Fedulov
Re: [DISCUSS] Flink 1.20.1 release
Ammu P
RE: [DISCUSS] Flink 1.20.1 release
Piotr Przybylski
Re: [DISCUSS] Flink 1.20.1 release
Alexander Fedulov
Re: [DISCUSS] Flink 1.20.1 release
Piotr Przybylski
[DISCUSS] Content older than one year will be deleted the Flink Slack starting January 28th, 2025
Robert Metzger
Re: [DISCUSS] Content older than one year will be deleted the Flink Slack starting January 28th, 2025
Jim Hughes
[jira] [Created] (FLINK-36883) Views should keep the time attributes of the query
Dawid Wysakowicz (Jira)
[jira] [Created] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API
Wang Qilong (Jira)
[jira] [Created] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API
Wang Qilong (Jira)
[jira] [Created] (FLINK-36880) Hybrid Shuffle support batch job recovery
xuhuang (Jira)
[jira] [Created] (FLINK-36879) CDC yaml transform supports to convert delete as insert
Ruan Hang (Jira)
[jira] [Created] (FLINK-36878) Shade kafka dependency in cdc yaml with the same path as sql connector
Ruan Hang (Jira)
[jira] [Created] (FLINK-36877) Kafka Sink output canal-json format of deleted record is incorrect format.
Yanquan Lv (Jira)
[jira] [Created] (FLINK-36876) Operator Heap Memory Leak
chenyuzhi (Jira)
[DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Junrui Lee
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Yunfeng Zhou
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xintong Song
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Yunfeng Zhou
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Hongshun Wang
Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks
Xu Huang
[jira] [Created] (FLINK-36875) Complete timer before emiting watermark
Yanfei Lei (Jira)
[jira] [Created] (FLINK-36874) KafkaSourceBuilder in pyflink did not implement setDeserializer() method
Shuyi Chen (Jira)
[jira] [Created] (FLINK-36873) Adapting batch job progress recovery to Apache Celeborn
xuhuang (Jira)
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
Re: [Discussion] Session Clusters Support Heterogeneous Task Manager Images
Ryan van Huuksloot
[jira] [Created] (FLINK-36872) The standby jobmanager webui cannot view the taskmanager logs
yuanfenghu (Jira)
Re: [DISCUSS] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
Re: [DISCUSS] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Sergey Nuyanzin
Re: [DISCUSS] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment
Timo Walther
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-36871) Add internalRescale metrics to distinguish internalRestart Metrics
Zhenqiu Huang (Jira)
[jira] [Created] (FLINK-36870) Start scale down timer after initial scale up
Maximilian Michels (Jira)
Re: Blue/Green Deployments support for Flink
Yang LI
Re: Blue/Green Deployments support for Flink
Alexander Fedulov
Re: Blue/Green Deployments support for Flink
Alex Nitavsky
Re: Blue/Green Deployments support for Flink
Sergio Chong Loo
[jira] [Created] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API
Wang Qilong (Jira)
[jira] [Created] (FLINK-36868) Provide file system methods with string parameters for ForSt JNI
Zakelly Lan (Jira)
[jira] [Created] (FLINK-36867) flink on k8s operator could not create TM
Jira
RE: [VOTE] FLIP-484: Add custom metric variables to operators
David Radley
Re: [VOTE] FLIP-484: Add custom metric variables to operators
Piotr Nowojski
Re: [VOTE] FLIP-484: Add custom metric variables to operators
Piotr Nowojski
[jira] [Created] (FLINK-36866) Support more CDC YAML numeric casting paths
yux (Jira)
[jira] [Created] (FLINK-36865) Provide UNIX_TIMESTAMP series functions in YAML pipeline
yux (Jira)
[jira] [Created] (FLINK-36864) YAML Pipeline could not write number literals that exceeds Int32 range
yux (Jira)
[jira] [Created] (FLINK-36863) Use the maximum parallelism in the past scale-down.interval window when scaling down
Rui Fan (Jira)
Expired slack invite link
Vincent Stollenwerk
Re: Expired slack invite link
Robert Metzger
Later messages