flink-user mailing list archives: February 2020

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Navneeth Krishnan Re: Using s3 for checkpointing Sat, 01 Feb, 07:41
Guowei Ma Re: DisableGenericTypes is not compatible with Kafka Sat, 01 Feb, 08:44
David Magalhães Re: Using s3 for checkpointing Sat, 01 Feb, 10:37
Richard Deurwaarder Re: Does flink support retries on checkpoint write failures Sat, 01 Feb, 13:44
kant kodali Re: is streaming outer join sending unnecessary traffic? Sat, 01 Feb, 21:17
Benchao Li Re: is streaming outer join sending unnecessary traffic? Sun, 02 Feb, 03:43
Jark Wu Re: is streaming outer join sending unnecessary traffic? Sun, 02 Feb, 06:27
Jark Wu Re: Read data from Oracle using Flink SQL API Sun, 02 Feb, 06:41
Jingsong Li Re: Read data from Oracle using Flink SQL API Sun, 02 Feb, 07:37
Flavio Pompermaier Re: Read data from Oracle using Flink SQL API Sun, 02 Feb, 09:52
lec ssmi time column used by timer Sun, 02 Feb, 10:12
Guowei Ma Re: Reinterpreting a pre-partitioned data stream as keyed stream Sun, 02 Feb, 10:38
Konstantin Knauf [ANNOUNCE] Weekly Community Update 2020/05 Sun, 02 Feb, 11:41
Günter Hipler no suitable table factory for file sources Mon, 03 Feb, 05:00
Jingsong Li Re: Read data from Oracle using Flink SQL API Mon, 03 Feb, 06:10
Jingsong Li Re: no suitable table factory for file sources Mon, 03 Feb, 06:13
Yu Yang check-pointing does not follow interval setting on some clusters Mon, 03 Feb, 08:36
Fabian Hueske Re: Flink solution for having shared variable between task managers Mon, 03 Feb, 09:04
Till Rohrmann Re: Does flink support retries on checkpoint write failures Mon, 03 Feb, 10:14
Morgan Geldenhuys Question: Determining Total Recovery Time Mon, 03 Feb, 11:20
Soheil Pourbafrani Re: Flink solution for having shared variable between task managers Mon, 03 Feb, 14:11
Mark Harris Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Mon, 03 Feb, 14:54
Piotr Nowojski Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Mon, 03 Feb, 14:58
Kostas Kloudas Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Mon, 03 Feb, 14:58
Mark Harris Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Mon, 03 Feb, 15:11
Kostas Kloudas Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Mon, 03 Feb, 15:39
Mark Harris Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Mon, 03 Feb, 16:24
Kostas Kloudas Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Mon, 03 Feb, 19:14
sunfulin Flink build-in functions Tue, 04 Feb, 02:02
jincheng sun [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience. Tue, 04 Feb, 03:48
Wyatt Chun Re: Flink build-in functions Tue, 04 Feb, 04:23
Jingsong Li Re: Flink build-in functions Tue, 04 Feb, 04:35
Wei Zhong Re: [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience. Tue, 04 Feb, 04:42
Xingbo Huang Re: [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience. Tue, 04 Feb, 05:07
Jeff Zhang Re: [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience. Tue, 04 Feb, 05:09
Steve Whelan Performance issue with RegistryAvroSerializationSchema Tue, 04 Feb, 06:13
Hequn Cheng Re: [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience. Tue, 04 Feb, 06:25
hemant singh Flink Dynamodb as sink Tue, 04 Feb, 06:37
容祖儿 Re: Flink Dynamodb as sink Tue, 04 Feb, 07:00
hemant singh Re: Flink Dynamodb as sink Tue, 04 Feb, 07:10
Fabian Hueske Re: check-pointing does not follow interval setting on some clusters Tue, 04 Feb, 10:47
Timo Walther Re: Flink Dynamodb as sink Tue, 04 Feb, 11:23
Timo Walther Re: Question: Determining Total Recovery Time Tue, 04 Feb, 11:31
Timo Walther Re: time column used by timer Tue, 04 Feb, 11:41
Dylan Adams Re: Updating multiple database tables Tue, 04 Feb, 12:33
Aljoscha Krettek Re: DisableGenericTypes is not compatible with Kafka Tue, 04 Feb, 13:29
Stephen Young Best approach for recalculating statistics based on amended or deleted events? Tue, 04 Feb, 15:14
Timo Walther Re: Best approach for recalculating statistics based on amended or deleted events? Tue, 04 Feb, 15:27
Stephen Young Re: Best approach for recalculating statistics based on amended or deleted events? Tue, 04 Feb, 16:10
Li Peng Re: Task-manager kubernetes pods take a long time to terminate Tue, 04 Feb, 21:53
Yang Wang Re: Task-manager kubernetes pods take a long time to terminate Wed, 05 Feb, 01:15
Li Peng Re: Task-manager kubernetes pods take a long time to terminate Wed, 05 Feb, 02:41
Kurt Young [DISCUSS] Remove registration of TableSource/TableSink in Table Env and ConnectTableDescriptor Wed, 05 Feb, 06:36
Yang Wang Re: Task-manager kubernetes pods take a long time to terminate Wed, 05 Feb, 08:49
Kostas Kloudas Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Wed, 05 Feb, 09:43
Robert Metzger Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Wed, 05 Feb, 10:24
Maxim Parkachov Flink 1.10 on MapR secure cluster with high availability Wed, 05 Feb, 14:12
David Magalhães NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 05 Feb, 14:21
Chesnay Schepler Re: Flink 1.10 on MapR secure cluster with high availability Wed, 05 Feb, 14:25
Maxim Parkachov Re: Flink 1.10 on MapR secure cluster with high availability Wed, 05 Feb, 14:38
Chesnay Schepler Re: Flink 1.10 on MapR secure cluster with high availability Wed, 05 Feb, 14:43
Oleksandr Nitavskyi Re: [BULK]Re: DisableGenericTypes is not compatible with Kafka Wed, 05 Feb, 17:29
Morgan Geldenhuys Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Wed, 05 Feb, 18:41
Milind Vaidya Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Wed, 05 Feb, 19:22
Fanbin Bu Re: batch job OOM Wed, 05 Feb, 23:50
sunfulin Re:Re: Flink build-in functions Thu, 06 Feb, 02:32
Jingsong Li Re: Re: Flink build-in functions Thu, 06 Feb, 03:23
Jingsong Li Re: batch job OOM Thu, 06 Feb, 03:24
Bowen Li Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 04:57
Chesnay Schepler Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 09:23
Morgan Geldenhuys Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 09:40
Jingsong Li Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 09:53
Chesnay Schepler Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 09:58
Farouk Flink 1.10 feedback Thu, 06 Feb, 09:58
Flavio Pompermaier Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 10:01
Jingsong Li Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 10:04
Morgan Geldenhuys Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 10:13
Chesnay Schepler Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 10:37
Aljoscha Krettek Re: [BULK]Re: DisableGenericTypes is not compatible with Kafka Thu, 06 Feb, 10:38
Stephen Young Re: Best approach for recalculating statistics based on amended or deleted events? Thu, 06 Feb, 11:37
Yang Wang Re: Flink 1.10 feedback Thu, 06 Feb, 14:23
Morgan Geldenhuys Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 14:52
Flavio Pompermaier Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 14:54
ZAIDI Farouk - externe RE: Flink 1.10 feedback Thu, 06 Feb, 15:00
Timo Walther Re: Best approach for recalculating statistics based on amended or deleted events? Thu, 06 Feb, 15:06
Robert Metzger Re: Performance issue with RegistryAvroSerializationSchema Thu, 06 Feb, 15:11
Chesnay Schepler Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 15:13
Dawid Wysakowicz Re: Performance issue with RegistryAvroSerializationSchema Thu, 06 Feb, 15:38
Ori Popowski Exceptions in Web UI do not appear in logs Thu, 06 Feb, 16:58
Andrey Zagrebin Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Thu, 06 Feb, 17:46
Steve Whelan Re: Performance issue with RegistryAvroSerializationSchema Thu, 06 Feb, 17:59
David Magalhães Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Thu, 06 Feb, 22:16
Abdul Qadeer Flink Job Cleanup Sequence Thu, 06 Feb, 22:46
Milind Vaidya Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Thu, 06 Feb, 23:02
Xander Song Running a Beam Pipeline on GCP Dataproc Flink Cluster Thu, 06 Feb, 23:54
Yang Wang Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Fri, 07 Feb, 01:25
sunfulin Flink DataTypes json parse exception Fri, 07 Feb, 06:57
Jingsong Li Re: Read data from Oracle using Flink SQL API Fri, 07 Feb, 07:02
Andrey Zagrebin Re: Task-manager kubernetes pods take a long time to terminate Fri, 07 Feb, 08:03
Stephen Connolly Rescaling a running topology Fri, 07 Feb, 11:40
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Box list
Jun 2021591
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