flink-user mailing list archives: March 2021

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · Next »Thread · Author · Date
Jark Wu Re: Best way to handle BIGING to TIMESTAMP conversions Mon, 01 Mar, 02:38
Jark Wu Re: Union fields with time attributes have different types Mon, 01 Mar, 02:46
Smile Re: java Flink local test failure (Could not create actor system) Mon, 01 Mar, 03:06
Abhishek Shukla Re: apache-flink +spring boot - logs related to spring boot application start up not printed in file in flink 1.12 Mon, 01 Mar, 03:42
Yang Wang Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Mon, 01 Mar, 06:04
Matthias Pohl Re: apache-flink +spring boot - logs related to spring boot application start up not printed in file in flink 1.12 Mon, 01 Mar, 07:36
Alexey Trenikhun Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Mon, 01 Mar, 08:25
Chesnay Schepler Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 08:30
Morgan Geldenhuys Re: Issues running multiple Jobs using the same JAR Mon, 01 Mar, 08:36
Arvid Heise Re: Does the Kafka source perform retractions on Key? Mon, 01 Mar, 08:43
Jan Oelschlegel AW: Kafka SQL Connector: dropping events if more partitions then source tasks Mon, 01 Mar, 09:46
Tamir Sagi Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 10:38
Till Rohrmann Re: Flink’s Kubernetes HA services - NOT working Mon, 01 Mar, 10:45
yidan zhao how to propagate watermarks across multiple jobs Mon, 01 Mar, 12:00
Kezhu Wang Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 12:21
Matthias Pohl Re: Flink application kept restarting Mon, 01 Mar, 12:22
Matthias Pohl Re: Flink application kept restarting Mon, 01 Mar, 12:38
Joey Tran Scaling Higher than 10k Nodes Mon, 01 Mar, 13:42
Tamir Sagi Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 16:24
Ron Crocker timeWindow()s and queryable state Mon, 01 Mar, 16:39
Jan Oelschlegel State Schema Evolution within SQL API Mon, 01 Mar, 16:41
Chesnay Schepler Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 17:00
Claude M Timeout Exception When Producing/Consuming Messages to Hundreds of Topics Mon, 01 Mar, 17:01
Kezhu Wang Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 17:54
Rion Williams Re: Handling Data Separation / Watermarking from Kafka in Flink Mon, 01 Mar, 17:55
Seth Wiesman Re: [Statefun] Exception occurs during function chaining / Async function Mon, 01 Mar, 19:30
Rex Fenley Re: Does the Kafka source perform retractions on Key? Mon, 01 Mar, 19:53
황혜조 Allocating tasks to specific TaskManagers Mon, 01 Mar, 20:02
Dan Hill Debugging long Flink checkpoint durations Mon, 01 Mar, 20:34
Till Rohrmann Re: Flink’s Kubernetes HA services - NOT working Mon, 01 Mar, 22:01
Arvid Heise Re: Does the Kafka source perform retractions on Key? Tue, 02 Mar, 07:48
Yun Gao Re: Debugging long Flink checkpoint durations Tue, 02 Mar, 08:50
Farouk Savepoint documentation Tue, 02 Mar, 09:33
Rainie Li Re: Flink application kept restarting Tue, 02 Mar, 09:38
XU Qinghui How to get operator uid from a sql Tue, 02 Mar, 10:55
Witzany, Tomas Flink KafkaProducer flushing on savepoints Tue, 02 Mar, 11:08
Sebastián Magrí Re: Best way to handle BIGING to TIMESTAMP conversions Tue, 02 Mar, 11:18
David Anderson Re: Savepoint documentation Tue, 02 Mar, 11:24
Sebastián Magrí [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Tue, 02 Mar, 11:26
Yik San Chan Re: Best way to handle BIGING to TIMESTAMP conversions Tue, 02 Mar, 11:37
Timo Walther Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Tue, 02 Mar, 12:11
Alexander Borgschulze Running Apache Flink on Android Tue, 02 Mar, 15:22
XU Qinghui Re: Savepoint documentation Tue, 02 Mar, 15:38
Tamir Sagi Re: Suspected classloader leak in Flink 1.11.1 Tue, 02 Mar, 15:52
Fuyao Li Need help with JDBC Broken Pipeline Issue after some idle time Tue, 02 Mar, 18:33
Chesnay Schepler Re: Suspected classloader leak in Flink 1.11.1 Tue, 02 Mar, 18:33
Fuyao Li Re: Need help with JDBC Broken Pipeline Issue after some idle time Tue, 02 Mar, 18:37
Kevin Lam Python DataStream API Questions -- Java/Scala Interoperability? Tue, 02 Mar, 18:50
Jaffe, Julian Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Tue, 02 Mar, 19:35
Roman Khachatryan Re: Sliding Window Count: Tricky Edge Case / Count Zero Problem Tue, 02 Mar, 19:40
Theo Diefenthal Flink + Hive + Compaction + Parquet? Tue, 02 Mar, 20:03
Jan Brusch Re: Sliding Window Count: Tricky Edge Case / Count Zero Problem Tue, 02 Mar, 20:31
XU Qinghui Re: Need help with JDBC Broken Pipeline Issue after some idle time Tue, 02 Mar, 21:40
Dan Hill Re: Debugging long Flink checkpoint durations Tue, 02 Mar, 23:45
Vijayendra Yadav Re: java Flink local test failure (Could not create actor system) Wed, 03 Mar, 03:58
Debraj Manna Flink 1.12 Compatibility with hbase-shaded-client 2.1 in application jar Wed, 03 Mar, 04:42
Kezhu Wang Re: Suspected classloader leak in Flink 1.11.1 Wed, 03 Mar, 05:06
Varun Chakravarthy Senthilnathan Flink Zookeeper leader change v 1.9.X Wed, 03 Mar, 06:26
Dan Hill Flink, local development, finish processing a stream of Kafka data Wed, 03 Mar, 07:15
Matthias Pohl Re: Flink application kept restarting Wed, 03 Mar, 08:24
Rainie Li Re: Flink application kept restarting Wed, 03 Mar, 08:29
Shuiqiang Chen Re: Python DataStream API Questions -- Java/Scala Interoperability? Wed, 03 Mar, 09:02
eric hoffmann Re: Processing-time temporal join is not supported yet. Wed, 03 Mar, 09:47
bat man Re: BroadcastState dropped when data deleted in Kafka Wed, 03 Mar, 09:52
David Anderson Re: Savepoint documentation Wed, 03 Mar, 10:15
Thomas Eckestad Stop vs Cancel with savepoint Wed, 03 Mar, 10:16
David Anderson Re: Handling Data Separation / Watermarking from Kafka in Flink Wed, 03 Mar, 11:01
Debraj Manna Re: Flink 1.12 Compatibility with hbase-shaded-client 2.1 in application jar Wed, 03 Mar, 14:27
Farouk Re: Savepoint documentation Wed, 03 Mar, 14:44
Abdullah bin Omar Compile Error Wed, 03 Mar, 15:55
soumoks Flink upgrade causes operator to lose state Wed, 03 Mar, 17:53
Piotr Nowojski Re: Allocating tasks to specific TaskManagers Wed, 03 Mar, 18:37
Piotr Nowojski Re: Independence of task parallelism Wed, 03 Mar, 18:53
Rion Williams Unit Testing State Stores in KeyedProcessFunctions Wed, 03 Mar, 19:10
Piotr Nowojski Re: Flink Metrics Wed, 03 Mar, 19:13
Piotr Nowojski Re: how to propagate watermarks across multiple jobs Wed, 03 Mar, 19:16
Piotr Nowojski Re: Job downgrade Wed, 03 Mar, 19:47
Alexey Trenikhun Re: Job downgrade Wed, 03 Mar, 20:03
Piotr Nowojski Re: Flink KafkaProducer flushing on savepoints Wed, 03 Mar, 20:10
Piotr Nowojski Re: Running Apache Flink on Android Wed, 03 Mar, 20:22
Chesnay Schepler Re: Flink upgrade causes operator to lose state Wed, 03 Mar, 20:35
Alexander Borgschulze Antw: [EXT] Re: Running Apache Flink on Android Wed, 03 Mar, 20:43
Chesnay Schepler Re: Unit Testing State Stores in KeyedProcessFunctions Wed, 03 Mar, 20:43
Chesnay Schepler Re: Compile Error Wed, 03 Mar, 20:49
Rion Williams Re: Unit Testing State Stores in KeyedProcessFunctions Wed, 03 Mar, 20:53
Chesnay Schepler Re: Stop vs Cancel with savepoint Wed, 03 Mar, 21:02
Chesnay Schepler Re: Flink Zookeeper leader change v 1.9.X Wed, 03 Mar, 21:37
Bohinski, Kevin 1.12.2 docker image Wed, 03 Mar, 22:18
Chesnay Schepler Re: 1.12.2 docker image Wed, 03 Mar, 22:40
Fuyao Li Re: [External] : Re: Need help with JDBC Broken Pipeline Issue after some idle time Wed, 03 Mar, 23:14
yidan zhao Re: how to propagate watermarks across multiple jobs Thu, 04 Mar, 02:48
Aeden Jameson pipeline.auto-watermark-interval vs setAutoWatermarkInterval Thu, 04 Mar, 03:46
Rion Williams Defining GlobalJobParameters in Flink Unit Testing Harnesses Thu, 04 Mar, 04:13
Leonard Xu Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Thu, 04 Mar, 04:14
Leonard Xu Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Thu, 04 Mar, 04:18
Leonard Xu Re: Processing-time temporal join is not supported yet. Thu, 04 Mar, 04:31
Sebastián Magrí Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Thu, 04 Mar, 07:34
Piotr Nowojski Re: Scaling Higher than 10k Nodes Thu, 04 Mar, 07:38
Piotr Nowojski Re: how to propagate watermarks across multiple jobs Thu, 04 Mar, 07:54
yidan zhao Re: how to propagate watermarks across multiple jobs Thu, 04 Mar, 08:25
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · Next »Thread · Author · Date
Box list
Dec 202179
Nov 2021504
Oct 2021530
Sep 2021511
Aug 2021609
Jul 2021469
Jun 2021668
May 2021687
Apr 2021719
Mar 2021888
Feb 2021665
Jan 2021777
Dec 2020519
Nov 2020727
Oct 2020695
Sep 2020572
Aug 2020723
Jul 2020840
Jun 2020653
May 2020766
Apr 2020849
Mar 2020795
Feb 2020690
Jan 2020652
Dec 2019530
Nov 2019527
Oct 2019542
Sep 2019534
Aug 2019627
Jul 2019635
Jun 2019413
May 2019421
Apr 2019653
Mar 2019575
Feb 2019555
Jan 2019595
Dec 2018401
Nov 2018655
Oct 2018698
Sep 2018761
Aug 2018787
Jul 2018841
Jun 2018658
May 2018580
Apr 2018612
Mar 2018634
Feb 2018533
Jan 2018597
Dec 2017525
Nov 2017474
Oct 2017527
Sep 2017645
Aug 2017737
Jul 2017476
Jun 2017670
May 2017474
Apr 2017415
Mar 2017508
Feb 2017582
Jan 2017576
Dec 2016405
Nov 2016598
Oct 2016506
Sep 2016451
Aug 2016596
Jul 2016463
Jun 2016454
May 2016701
Apr 2016741
Mar 2016614
Feb 2016655
Jan 2016443
Dec 2015322
Nov 2015487
Oct 2015330
Sep 2015401
Aug 2015252
Jul 2015433
Jun 2015446
May 2015274
Apr 2015204
Mar 2015154
Feb 2015123
Jan 201574
Dec 201488
Nov 2014243
Oct 2014124
Sep 201464