flink-user mailing list archives: March 2021

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Re: Best way to handle BIGING to TIMESTAMP conversions
Jark Wu   Re: Best way to handle BIGING to TIMESTAMP conversions Mon, 01 Mar, 02:38
Sebastián Magrí     Re: Best way to handle BIGING to TIMESTAMP conversions Tue, 02 Mar, 11:18
Yik San Chan       Re: Best way to handle BIGING to TIMESTAMP conversions Tue, 02 Mar, 11:37
Re: Union fields with time attributes have different types
Jark Wu   Re: Union fields with time attributes have different types Mon, 01 Mar, 02:46
Re: java Flink local test failure (Could not create actor system)
Smile   Re: java Flink local test failure (Could not create actor system) Mon, 01 Mar, 03:06
Vijayendra Yadav     Re: java Flink local test failure (Could not create actor system) Wed, 03 Mar, 03:58
Re: apache-flink +spring boot - logs related to spring boot application start up not printed in file in flink 1.12
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
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
Abhishek Shukla       Re: apache-flink +spring boot - logs related to spring boot application start up not printed in file in flink 1.12 Thu, 04 Mar, 12:50
Matthias Pohl         Re: apache-flink +spring boot - logs related to spring boot application start up not printed in file in flink 1.12 Wed, 10 Mar, 08:48
Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint
Yang Wang   Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Mon, 01 Mar, 06:04
Alexey Trenikhun     Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Wed, 10 Mar, 04:16
Yang Wang       Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Thu, 11 Mar, 10:59
Alexey Trenikhun         Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Thu, 11 Mar, 16:47
Yang Wang           Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Mon, 15 Mar, 02:50
Alexey Trenikhun           Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Mon, 15 Mar, 06:28
Yang Wang             Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Mon, 15 Mar, 08:26
Alexey Trenikhun             Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Sat, 20 Mar, 02:16
Yang Wang               Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Wed, 24 Mar, 06:17
Alexey Trenikhun               Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Wed, 24 Mar, 16:08
Alexey Trenikhun   Re: Kubernetes HA - attempting to restore from wrong (non-existing) savepoint Mon, 01 Mar, 08:25
Re: Suspected classloader leak in Flink 1.11.1
Chesnay Schepler   Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 08:30
Tamir Sagi   Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 10:38
Kezhu Wang     Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 12:21
Tamir Sagi       Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 16:24
Chesnay Schepler         Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 17:00
Kezhu Wang           Re: Suspected classloader leak in Flink 1.11.1 Mon, 01 Mar, 17:54
Tamir Sagi             Re: Suspected classloader leak in Flink 1.11.1 Tue, 02 Mar, 15:52
Chesnay Schepler               Re: Suspected classloader leak in Flink 1.11.1 Tue, 02 Mar, 18:33
Kezhu Wang                 Re: Suspected classloader leak in Flink 1.11.1 Wed, 03 Mar, 05:06
Re: Issues running multiple Jobs using the same JAR
Morgan Geldenhuys   Re: Issues running multiple Jobs using the same JAR Mon, 01 Mar, 08:36
Re: Does the Kafka source perform retractions on Key?
Arvid Heise   Re: Does the Kafka source perform retractions on Key? Mon, 01 Mar, 08:43
Rex Fenley     Re: Does the Kafka source perform retractions on Key? Mon, 01 Mar, 19:53
Arvid Heise       Re: Does the Kafka source perform retractions on Key? Tue, 02 Mar, 07:48
AW: Kafka SQL Connector: dropping events if more partitions then source tasks
Jan Oelschlegel   AW: Kafka SQL Connector: dropping events if more partitions then source tasks Mon, 01 Mar, 09:46
Re: Flink’s Kubernetes HA services - NOT working
Till Rohrmann   Re: Flink’s Kubernetes HA services - NOT working Mon, 01 Mar, 10:45
Till Rohrmann     Re: Flink’s Kubernetes HA services - NOT working Mon, 01 Mar, 22:01
yidan zhao how to propagate watermarks across multiple jobs Mon, 01 Mar, 12:00
Piotr Nowojski   Re: how to propagate watermarks across multiple jobs Wed, 03 Mar, 19:16
yidan zhao     Re: how to propagate watermarks across multiple jobs Thu, 04 Mar, 02:48
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
yidan zhao           Re: how to propagate watermarks across multiple jobs Thu, 04 Mar, 08:44
yidan zhao             Re: how to propagate watermarks across multiple jobs Thu, 04 Mar, 09:21
Yuan Mei           Re: how to propagate watermarks across multiple jobs Thu, 04 Mar, 15:10
yidan zhao             Re: how to propagate watermarks across multiple jobs Fri, 05 Mar, 07:45
Re: Flink application kept restarting
Matthias Pohl   Re: Flink application kept restarting Mon, 01 Mar, 12:22
Matthias Pohl     Re: Flink application kept restarting Mon, 01 Mar, 12:38
Rainie Li       Re: Flink application kept restarting Tue, 02 Mar, 09:38
Matthias Pohl         Re: Flink application kept restarting Wed, 03 Mar, 08:24
Rainie Li           Re: Flink application kept restarting Wed, 03 Mar, 08:29
Rainie Li           Re: Flink application kept restarting Thu, 04 Mar, 21:49
Jaffe, Julian             Re: Flink application kept restarting Thu, 04 Mar, 23:04
Rainie Li               Re: Flink application kept restarting Thu, 04 Mar, 23:18
Joey Tran Scaling Higher than 10k Nodes Mon, 01 Mar, 13:42
Piotr Nowojski   Re: Scaling Higher than 10k Nodes Thu, 04 Mar, 07:38
Xintong Song     Re: Scaling Higher than 10k Nodes Thu, 04 Mar, 08:30
Piotr Nowojski       Re: Scaling Higher than 10k Nodes Thu, 04 Mar, 08:50
Yuval Itzchakov         Re: Scaling Higher than 10k Nodes Thu, 04 Mar, 15:45
Ron Crocker timeWindow()s and queryable state Mon, 01 Mar, 16:39
Dawid Wysakowicz   Re: timeWindow()s and queryable state Thu, 04 Mar, 08:42
Jan Oelschlegel State Schema Evolution within SQL API Mon, 01 Mar, 16:41
Dawid Wysakowicz   Re: State Schema Evolution within SQL API Thu, 04 Mar, 08:50
XU Qinghui     Re: State Schema Evolution within SQL API Thu, 04 Mar, 09:17
Jan Oelschlegel       AW: State Schema Evolution within SQL API Thu, 04 Mar, 11:26
Jan Oelschlegel         AW: State Schema Evolution within SQL API Thu, 04 Mar, 17:05
Claude M Timeout Exception When Producing/Consuming Messages to Hundreds of Topics Mon, 01 Mar, 17:01
Piotr Nowojski   Re: Timeout Exception When Producing/Consuming Messages to Hundreds of Topics Thu, 04 Mar, 08:41
Arvid Heise     Re: Timeout Exception When Producing/Consuming Messages to Hundreds of Topics Thu, 04 Mar, 09:45
Re: Handling Data Separation / Watermarking from Kafka in Flink
Rion Williams   Re: Handling Data Separation / Watermarking from Kafka in Flink Mon, 01 Mar, 17:55
David Anderson     Re: Handling Data Separation / Watermarking from Kafka in Flink Wed, 03 Mar, 11:01
Re: [Statefun] Exception occurs during function chaining / Async function
Seth Wiesman   Re: [Statefun] Exception occurs during function chaining / Async function Mon, 01 Mar, 19:30
황혜조 Allocating tasks to specific TaskManagers Mon, 01 Mar, 20:02
Piotr Nowojski   Re: Allocating tasks to specific TaskManagers Wed, 03 Mar, 18:37
Piotr Nowojski     Re: Allocating tasks to specific TaskManagers Fri, 05 Mar, 07:35
Chesnay Schepler       Re: Allocating tasks to specific TaskManagers Fri, 05 Mar, 07:41
Dan Hill Debugging long Flink checkpoint durations Mon, 01 Mar, 20:34
Yun Gao   Re: Debugging long Flink checkpoint durations Tue, 02 Mar, 08:50
Dan Hill     Re: Debugging long Flink checkpoint durations Tue, 02 Mar, 23:45
Dan Hill       Re: Debugging long Flink checkpoint durations Thu, 04 Mar, 20:38
Dan Hill         Re: Debugging long Flink checkpoint durations Thu, 04 Mar, 20:42
Farouk Savepoint documentation Tue, 02 Mar, 09:33
David Anderson   Re: Savepoint documentation Tue, 02 Mar, 11:24
XU Qinghui     Re: Savepoint documentation Tue, 02 Mar, 15:38
David Anderson       Re: Savepoint documentation Wed, 03 Mar, 10:15
Farouk         Re: Savepoint documentation Wed, 03 Mar, 14:44
XU Qinghui How to get operator uid from a sql Tue, 02 Mar, 10:55
Matthias Pohl   Re: How to get operator uid from a sql Tue, 23 Mar, 16:37
Flink KafkaProducer flushing on savepoints
Witzany, Tomas   Flink KafkaProducer flushing on savepoints Tue, 02 Mar, 11:08
Piotr Nowojski     Re: Flink KafkaProducer flushing on savepoints Wed, 03 Mar, 20:10
Witzany, Tomas       Re: Flink KafkaProducer flushing on savepoints Fri, 05 Mar, 10:19
Piotr Nowojski         Re: Flink KafkaProducer flushing on savepoints Fri, 05 Mar, 16:37
Sebastián Magrí [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Tue, 02 Mar, 11:26
Timo Walther   Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Tue, 02 Mar, 12:11
Jaffe, Julian     Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Tue, 02 Mar, 19:35
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
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
Leonard Xu             Re: [Flink-SQL] FLOORing OR CEILing a DATE or TIMESTAMP to WEEK uses Thursdays as week start Fri, 05 Mar, 04:25
Alexander Borgschulze Running Apache Flink on Android Tue, 02 Mar, 15:22
Piotr Nowojski   Re: Running Apache Flink on Android Wed, 03 Mar, 20:22
Alexander Borgschulze     Antw: [EXT] Re: Running Apache Flink on Android Wed, 03 Mar, 20:43
Fuyao Li Need help with JDBC Broken Pipeline Issue after some idle time Tue, 02 Mar, 18:33
Fuyao Li   Re: Need help with JDBC Broken Pipeline Issue after some idle time Tue, 02 Mar, 18:37
XU Qinghui     Re: Need help with JDBC Broken Pipeline Issue after some idle time Tue, 02 Mar, 21:40
Fuyao Li     Re: [External] : Re: Need help with JDBC Broken Pipeline Issue after some idle time Wed, 03 Mar, 23:14
Fuyao Li     Re: [External] : Re: Need help with JDBC Broken Pipeline Issue after some idle time Wed, 10 Mar, 02:36
Kevin Lam Python DataStream API Questions -- Java/Scala Interoperability? Tue, 02 Mar, 18:50
Shuiqiang Chen   Re: Python DataStream API Questions -- Java/Scala Interoperability? Wed, 03 Mar, 09:02
Kevin Lam     Re: Python DataStream API Questions -- Java/Scala Interoperability? Fri, 05 Mar, 21:29
Kevin Lam       Re: Python DataStream API Questions -- Java/Scala Interoperability? Wed, 10 Mar, 20:28
Shuiqiang Chen         Re: Python DataStream API Questions -- Java/Scala Interoperability? Mon, 15 Mar, 03:26
Re: Sliding Window Count: Tricky Edge Case / Count Zero Problem
Roman Khachatryan   Re: Sliding Window Count: Tricky Edge Case / Count Zero Problem Tue, 02 Mar, 19:40
Jan Brusch     Re: Sliding Window Count: Tricky Edge Case / Count Zero Problem Tue, 02 Mar, 20:31
Theo Diefenthal Flink + Hive + Compaction + Parquet? Tue, 02 Mar, 20:03
Dawid Wysakowicz   Re: Flink + Hive + Compaction + Parquet? Thu, 04 Mar, 09:09
Flavio Pompermaier     Re: Flink + Hive + Compaction + Parquet? Mon, 15 Mar, 09:04
Kurt Young       Re: Flink + Hive + Compaction + Parquet? Tue, 16 Mar, 04:14
Debraj Manna Flink 1.12 Compatibility with hbase-shaded-client 2.1 in application jar Wed, 03 Mar, 04:42
Debraj Manna   Re: Flink 1.12 Compatibility with hbase-shaded-client 2.1 in application jar Wed, 03 Mar, 14:27
Varun Chakravarthy Senthilnathan Flink Zookeeper leader change v 1.9.X Wed, 03 Mar, 06:26
Chesnay Schepler   Re: Flink Zookeeper leader change v 1.9.X Wed, 03 Mar, 21:37
Dan Hill Flink, local development, finish processing a stream of Kafka data Wed, 03 Mar, 07:15
Dan Hill   Does WatermarkStrategy.withIdleness work? Fri, 12 Mar, 08:46
David Anderson     Re: Does WatermarkStrategy.withIdleness work? Fri, 12 Mar, 09:54
Dan Hill       Re: Does WatermarkStrategy.withIdleness work? Fri, 12 Mar, 09:55
Re: Processing-time temporal join is not supported yet.
eric hoffmann   Re: Processing-time temporal join is not supported yet. Wed, 03 Mar, 09:47
Leonard Xu     Re: Processing-time temporal join is not supported yet. Thu, 04 Mar, 04:31
eric hoffmann       Re: Processing-time temporal join is not supported yet. Thu, 04 Mar, 11:26
Leonard Xu         Re: Processing-time temporal join is not supported yet. Thu, 04 Mar, 11:43
Re: BroadcastState dropped when data deleted in Kafka
bat man   Re: BroadcastState dropped when data deleted in Kafka Wed, 03 Mar, 09:52
Stop vs Cancel with savepoint
Thomas Eckestad   Stop vs Cancel with savepoint Wed, 03 Mar, 10:16
Chesnay Schepler     Re: Stop vs Cancel with savepoint Wed, 03 Mar, 21:02
Thomas Eckestad       Re: Stop vs Cancel with savepoint Mon, 08 Mar, 11:59
Abdullah bin Omar Compile Error Wed, 03 Mar, 15:55
Chesnay Schepler   Re: Compile Error Wed, 03 Mar, 20:49
Abdullah bin Omar     Re: Compile Error Thu, 04 Mar, 14:41
Chesnay Schepler       Re: Compile Error Thu, 04 Mar, 16:00
Abdullah bin Omar         Re: Compile Error Thu, 04 Mar, 16:24
Chesnay Schepler           Re: Compile Error Thu, 04 Mar, 17:58
soumoks Flink upgrade causes operator to lose state Wed, 03 Mar, 17:53
Chesnay Schepler   Re: Flink upgrade causes operator to lose state Wed, 03 Mar, 20:35
Jan Oelschlegel     AW: Flink upgrade causes operator to lose state Thu, 04 Mar, 11:06
Re: Independence of task parallelism
Piotr Nowojski   Re: Independence of task parallelism Wed, 03 Mar, 18:53
Jan Nitschke     Aw: Re: Independence of task parallelism Fri, 05 Mar, 08:09
Piotr Nowojski       Re: Re: Independence of task parallelism Fri, 05 Mar, 16:35
Rion Williams Unit Testing State Stores in KeyedProcessFunctions Wed, 03 Mar, 19:10
Chesnay Schepler   Re: Unit Testing State Stores in KeyedProcessFunctions Wed, 03 Mar, 20:43
Rion Williams     Re: Unit Testing State Stores in KeyedProcessFunctions Wed, 03 Mar, 20:53
Re: Flink Metrics
Piotr Nowojski   Re: Flink Metrics Wed, 03 Mar, 19:13
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
Oct 2021348
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