flink-user mailing list archives: February 2020

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Re: Using s3 for checkpointing
Navneeth Krishnan   Re: Using s3 for checkpointing Sat, 01 Feb, 07:41
David Magalhães     Re: Using s3 for checkpointing Sat, 01 Feb, 10:37
Navneeth Krishnan       Re: Using s3 for checkpointing Mon, 10 Feb, 06:54
Re: DisableGenericTypes is not compatible with Kafka
Guowei Ma   Re: DisableGenericTypes is not compatible with Kafka Sat, 01 Feb, 08:44
Aljoscha Krettek     Re: DisableGenericTypes is not compatible with Kafka Tue, 04 Feb, 13:29
Oleksandr Nitavskyi     Re: [BULK]Re: DisableGenericTypes is not compatible with Kafka Wed, 05 Feb, 17:29
Aljoscha Krettek       Re: [BULK]Re: DisableGenericTypes is not compatible with Kafka Thu, 06 Feb, 10:38
Re: Does flink support retries on checkpoint write failures
Richard Deurwaarder   Re: Does flink support retries on checkpoint write failures Sat, 01 Feb, 13:44
Till Rohrmann     Re: Does flink support retries on checkpoint write failures Mon, 03 Feb, 10:14
Re: is streaming outer join sending unnecessary traffic?
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
Re: Read data from Oracle using Flink SQL API
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
Jingsong Li         Re: Read data from Oracle using Flink SQL API Mon, 03 Feb, 06:10
Bowen Li           Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 04:57
Jingsong Li             Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 09:53
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
Flavio Pompermaier                   Re: Read data from Oracle using Flink SQL API Thu, 06 Feb, 14:54
Jingsong Li                     Re: Read data from Oracle using Flink SQL API Fri, 07 Feb, 07:02
lec ssmi time column used by timer Sun, 02 Feb, 10:12
Timo Walther   Re: time column used by timer Tue, 04 Feb, 11:41
Re: Reinterpreting a pre-partitioned data stream as keyed stream
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: 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: check-pointing does not follow interval setting on some clusters Tue, 04 Feb, 10:47
Congxian Qiu     Re: check-pointing does not follow interval setting on some clusters Fri, 07 Feb, 12:48
Re: Flink solution for having shared variable between task managers
Fabian Hueske   Re: Flink solution for having shared variable between task managers Mon, 03 Feb, 09:04
Soheil Pourbafrani     Re: Flink solution for having shared variable between task managers Mon, 03 Feb, 14:11
Morgan Geldenhuys Question: Determining Total Recovery Time Mon, 03 Feb, 11:20
Timo Walther   Re: Question: Determining Total Recovery Time Tue, 04 Feb, 11:31
Arvid Heise     Re: Question: Determining Total Recovery Time Tue, 11 Feb, 07:57
Morgan Geldenhuys       Re: Question: Determining Total Recovery Time Tue, 11 Feb, 10:24
Arvid Heise         Re: Question: Determining Total Recovery Time Fri, 21 Feb, 13:44
Arvid Heise           Re: Question: Determining Total Recovery Time Wed, 26 Feb, 14:28
Zhijiang           Re: Question: Determining Total Recovery Time Wed, 26 Feb, 16:10
Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files
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
Kostas Kloudas               Re: GC overhead limit exceeded, memory full of DeleteOnExit hooks for S3a files Wed, 05 Feb, 09:43
sunfulin Flink build-in functions Tue, 04 Feb, 02:02
Wyatt Chun   Re: Flink build-in functions Tue, 04 Feb, 04:23
Jingsong Li     Re: Flink build-in functions Tue, 04 Feb, 04:35
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
jincheng sun [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience. Tue, 04 Feb, 03:48
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
Hequn Cheng         Re: [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience. Tue, 04 Feb, 06:25
Steve Whelan Performance issue with RegistryAvroSerializationSchema Tue, 04 Feb, 06:13
Robert Metzger   Re: Performance issue with RegistryAvroSerializationSchema Thu, 06 Feb, 15:11
Dawid Wysakowicz     Re: Performance issue with RegistryAvroSerializationSchema Thu, 06 Feb, 15:38
Steve Whelan       Re: Performance issue with RegistryAvroSerializationSchema Thu, 06 Feb, 17:59
Robert Metzger         Re: Performance issue with RegistryAvroSerializationSchema Fri, 07 Feb, 13:02
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
Timo Walther       Re: Flink Dynamodb as sink Tue, 04 Feb, 11:23
Re: Updating multiple database tables
Dylan Adams   Re: Updating multiple database tables Tue, 04 Feb, 12:33
Stephen Young Re: Best approach for recalculating statistics based on amended or deleted events? Tue, 04 Feb, 16:10
Timo Walther   Re: Best approach for recalculating statistics based on amended or deleted events? Tue, 04 Feb, 15:27
Stephen Young     Best approach for recalculating statistics based on amended or deleted events? Tue, 04 Feb, 15:14
Stephen Young       Re: Best approach for recalculating statistics based on amended or deleted events? Thu, 06 Feb, 11:37
Timo Walther         Re: Best approach for recalculating statistics based on amended or deleted events? Thu, 06 Feb, 15:06
Re: Task-manager kubernetes pods take a long time to terminate
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
Yang Wang         Re: Task-manager kubernetes pods take a long time to terminate Wed, 05 Feb, 08:49
Andrey Zagrebin           Re: Task-manager kubernetes pods take a long time to terminate Fri, 07 Feb, 08:03
Kurt Young [DISCUSS] Remove registration of TableSource/TableSink in Table Env and ConnectTableDescriptor Wed, 05 Feb, 06:36
Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster
Robert Metzger   Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Wed, 05 Feb, 10:24
Milind Vaidya     Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Wed, 05 Feb, 19:22
Milind Vaidya       Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Thu, 06 Feb, 23:02
Yang Wang         Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Fri, 07 Feb, 01:25
Milind Vaidya           Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Fri, 07 Feb, 19:35
Robert Metzger             Re: Failed to transfer file from TaskExecutor : Vanilla Flink Cluster Tue, 18 Feb, 15:53
Maxim Parkachov Flink 1.10 on MapR secure cluster with high availability Wed, 05 Feb, 14:12
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
Maxim Parkachov         Re: Flink 1.10 on MapR secure cluster with high availability Fri, 07 Feb, 16:02
Arvid Heise           Re: Flink 1.10 on MapR secure cluster with high availability Tue, 11 Feb, 10:26
David Magalhães NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 05 Feb, 14:21
Andrey Zagrebin   Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Thu, 06 Feb, 17:46
David Magalhães     Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Thu, 06 Feb, 22:16
Arvid Heise       Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Tue, 11 Feb, 10:06
Arvid Heise         Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 12 Feb, 10:01
David Magalhães           Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 12 Feb, 11:36
Robert Metzger             Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 12 Feb, 12:45
David Magalhães               Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 12 Feb, 19:56
Arvid Heise                 Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 12 Feb, 21:15
David Magalhães                   Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Wed, 12 Feb, 23:04
Arvid Heise                     Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Tue, 18 Feb, 13:51
David Magalhães                       Re: NoClassDefFoundError when an exception is throw inside invoke in a Custom Sink Tue, 18 Feb, 13:59
Morgan Geldenhuys Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Wed, 05 Feb, 18:41
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
Chesnay Schepler       Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 09:58
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
Morgan Geldenhuys             Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 14:52
Chesnay Schepler               Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Thu, 06 Feb, 15:13
Chesnay Schepler                 Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Wed, 12 Feb, 10:07
Robert Metzger               Re: Flink TaskManager Logs polluted with InfluxDB metrics reporter errors Fri, 21 Feb, 12:52
Re: batch job OOM
Fanbin Bu   Re: batch job OOM Wed, 05 Feb, 23:50
Jingsong Li     Re: batch job OOM Thu, 06 Feb, 03:24
Farouk Flink 1.10 feedback Thu, 06 Feb, 09:58
Yang Wang   Re: Flink 1.10 feedback Thu, 06 Feb, 14:23
ZAIDI Farouk - externe     RE: Flink 1.10 feedback Thu, 06 Feb, 15:00
Ori Popowski Exceptions in Web UI do not appear in logs Thu, 06 Feb, 16:58
Robert Metzger   Re: Exceptions in Web UI do not appear in logs Wed, 19 Feb, 09:51
Abdul Qadeer Flink Job Cleanup Sequence Thu, 06 Feb, 22:46
Xander Song Running a Beam Pipeline on GCP Dataproc Flink Cluster Thu, 06 Feb, 23:54
Ismaël Mejía   Re: Running a Beam Pipeline on GCP Dataproc Flink Cluster Fri, 07 Feb, 13:24
sunfulin Flink DataTypes json parse exception Fri, 07 Feb, 06:57
Stephen Connolly Rescaling a running topology Fri, 07 Feb, 11:40
Stephen Connolly   Re: Rescaling a running topology Fri, 07 Feb, 11:50
Stephen Connolly     Re: Rescaling a running topology Fri, 07 Feb, 11:54
Stephen Connolly       Re: Rescaling a running topology Fri, 07 Feb, 12:31
Andrey Zagrebin         Re: Rescaling a running topology Tue, 11 Feb, 13:45
Akshay Aggarwal Backfilling From Kafka Topics With Varied Ingestion Rates Fri, 07 Feb, 12:36
Aljoscha Krettek   Re: Backfilling From Kafka Topics With Varied Ingestion Rates Wed, 12 Feb, 08:26
Akshay Aggarwal     Re: Backfilling From Kafka Topics With Varied Ingestion Rates Wed, 12 Feb, 10:30
Robert Metzger       Re: Backfilling From Kafka Topics With Varied Ingestion Rates Wed, 12 Feb, 12:46
KristoffSC SSL configuration - default behaviour Fri, 07 Feb, 15:08
Robert Metzger   Re: SSL configuration - default behaviour Mon, 10 Feb, 14:11
Krzysztof Chmielewski     Re: SSL configuration - default behaviour Tue, 11 Feb, 07:22
Piotr Nowojski       Re: SSL configuration - default behaviour Thu, 13 Feb, 11:14
KristoffSC Flink HA for Job Cluster Fri, 07 Feb, 15:34
tison   Re: Flink HA for Job Cluster Mon, 10 Feb, 00:59
Yang Wang     Re: Flink HA for Job Cluster Mon, 10 Feb, 01:55
KristoffSC       Re: Flink HA for Job Cluster Mon, 10 Feb, 07:56
KristoffSC       Re: Flink HA for Job Cluster Mon, 10 Feb, 08:35
Re: Duplicate tasks for the same query
RKandoji   Re: Duplicate tasks for the same query Fri, 07 Feb, 22:40
Jark Wu     Re: Duplicate tasks for the same query Mon, 10 Feb, 02:15
Konstantin Knauf [ANNOUNCE] Weekly Community Update 2020/06 Sun, 09 Feb, 19:34
闫旭 [Help] Anyone know where I can find performance test result? Mon, 10 Feb, 03:17
Khachatryan Roman   Re: [Help] Anyone know where I can find performance test result? Mon, 10 Feb, 09:08
Khachatryan Roman     Re: [Help] Anyone know where I can find performance test result? Mon, 10 Feb, 10:11
Flink Elasticsearch upsert document in ES
ApoorvK   Flink Elasticsearch upsert document in ES Mon, 10 Feb, 07:26
Itamar Syn-Hershko     Re: Flink Elasticsearch upsert document in ES Mon, 10 Feb, 08:12
Apoorv Upadhyay       Re: Flink Elasticsearch upsert document in ES Mon, 10 Feb, 11:56
ApoorvK   Flink Elasticsearch upsert document in ES Mon, 10 Feb, 14:33
ORIOL LOPEZ SANCHEZ     Re: Flink Elasticsearch upsert document in ES Mon, 10 Feb, 14:39
KristoffSC Flink Minimal requirements Mon, 10 Feb, 08:02
Khachatryan Roman   Re: Flink Minimal requirements Mon, 10 Feb, 17:52
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Aug 202091
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