flink-user mailing list archives: April 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
王凯 java.lang.Exception: TaskManager was lost/killed Sun, 08 Apr, 08:36
周思华 Re: java.lang.Exception: TaskManager was lost/killed Wed, 11 Apr, 03:03
周思华 Re: keyBy and parallelism Thu, 12 Apr, 08:04
杨力 Re: subuquery about flink sql Tue, 03 Apr, 08:15
杨力 Re: Access logs for a running Flink app in YARN cluster Fri, 13 Apr, 03:06
杨力 User-defined aggregation function and parallelism Mon, 16 Apr, 03:21
陈梓立 A trivial update on README Sat, 28 Apr, 03:45
Gábor Gévay Re: Recovering snapshot state saved with TypeInformation generated by the implicit macro from the scala API Fri, 13 Apr, 17:14
Zhijiang(wangzhijiang999) 回复:Checkpoints very slow with high backpressure Sun, 08 Apr, 03:08
Gyula Fóra Beam quickstart Wed, 25 Apr, 13:32
Gyula Fóra Re: Beam quickstart Thu, 26 Apr, 13:45
Szymon Szczypiński Re: DFS problem with removing checkpoint Fri, 06 Apr, 23:11
Szymon Szczypiński FlinkML Mon, 16 Apr, 21:25
Szymon Szczypiński Re: DFS problem with removing checkpoint Sun, 22 Apr, 15:22
韩宁宁 subuquery about flink sql Tue, 03 Apr, 03:23
韩宁宁 subuquery about flink sql Tue, 03 Apr, 03:39
韩宁宁 回复: subuquery about flink sql Tue, 03 Apr, 07:34
林德强 Re: Slow flink checkpoint Mon, 16 Apr, 06:56
潘 功森 Why assignTimestampsAndWatermarks parallelism same as map,it will not fired? Wed, 25 Apr, 03:15
潘 功森 答复: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired? Thu, 26 Apr, 02:15
潘 功森 答复: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired? Thu, 26 Apr, 02:25
潘 功森 答复: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired? Thu, 26 Apr, 03:26
王凯 Re:Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 08:36
周思华 Re: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired? Thu, 26 Apr, 02:50
周思华 Re: Externalized checkpoints and metadata Thu, 26 Apr, 08:45
李玥 Re: Multiple (non-consecutive) keyBy operators in a dataflow Tue, 03 Apr, 01:22
李玥 Re: subuquery about flink sql Tue, 03 Apr, 03:49
Jörn Franke Re: Graph Analytics on HBase With HGraphDB and Apache Flink Gelly Wed, 04 Apr, 21:44
Jörn Franke Re: Flink Uploaded JAR Filename Mon, 09 Apr, 16:55
Jörn Franke Re: Complexity of Flink Sat, 14 Apr, 10:43
Jörn Franke Re: Complexity of Flink Sat, 14 Apr, 12:23
Jörn Franke Re: Need Help/Code Examples with reading/writing Parquet File with Flink ? Wed, 18 Apr, 06:47
Jörn Franke Re: Multi threaded operators? Mon, 23 Apr, 11:44
Jörn Franke Re: Beam quickstart Wed, 25 Apr, 14:50
Jörn Franke Re: Different result on running Flink in local mode and Yarn cluster Thu, 26 Apr, 05:31
Adrian Hains Unable to launch job with 100 SQL queries in yarn cluster Fri, 13 Apr, 06:59
Alberto Mancini Tiemrs and restore Sun, 15 Apr, 17:19
Alberto Mancini Re: Tiemrs and restore Mon, 16 Apr, 17:00
Alex Soto akka.remote.OversizedPayloadException Mon, 23 Apr, 18:48
Alexander Smirnov Kafka exceptions in Flink log file Mon, 02 Apr, 11:32
Alexander Smirnov Restart strategy defined in flink-conf.yaml is ignored Thu, 05 Apr, 13:07
Alexander Smirnov Re: Kafka exceptions in Flink log file Thu, 05 Apr, 13:16
Alexander Smirnov Re: Restart strategy defined in flink-conf.yaml is ignored Thu, 05 Apr, 19:35
Alexander Smirnov Re: Restart strategy defined in flink-conf.yaml is ignored Thu, 05 Apr, 19:40
Alexander Smirnov Re: Restart strategy defined in flink-conf.yaml is ignored Fri, 06 Apr, 07:30
Alexander Smirnov Re: Tracking deserialization errors Sun, 08 Apr, 15:53
Alexander Smirnov Re: Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 08:41
Alexander Smirnov Re: How to add new Kafka topic to consumer Wed, 11 Apr, 12:36
Alexander Smirnov Re: Tracking deserialization errors Wed, 18 Apr, 13:10
Alexander Smirnov Multi threaded operators? Mon, 23 Apr, 09:54
Alexander Smirnov Re: Tracking deserialization errors Mon, 23 Apr, 09:59
Alexander Smirnov Re: data enrichment with SQL use case Mon, 23 Apr, 11:29
Alexander Smirnov Checkpointing barriers Mon, 23 Apr, 14:21
Alexander Smirnov Re: Checkpointing barriers Tue, 24 Apr, 08:47
Alexander Smirnov Can't send kafka message with timestamp Thu, 26 Apr, 12:59
Alexandru Gutan Re: Flink - Kafka Connector Fri, 13 Apr, 12:27
Aljoscha Krettek Re: Tiemrs and restore Mon, 16 Apr, 16:30
Aljoscha Krettek Re: Regarding BucketingSink Sat, 21 Apr, 16:54
Amit Jain Re: TaskManager deadlock on NetworkBufferPool Wed, 04 Apr, 17:21
Amit Jain Re: KeyedSream question Thu, 05 Apr, 04:21
Amit Jain Testing on Flink 1.5 Tue, 17 Apr, 07:35
Amit Jain Re: Testing on Flink 1.5 Wed, 18 Apr, 13:09
Amit Jain Re: Testing on Flink 1.5 Thu, 19 Apr, 10:49
Amit Jain Re: Testing on Flink 1.5 Fri, 20 Apr, 10:22
Amit Jain Batch job stuck in Canceled state in Flink 1.5 Sun, 29 Apr, 16:29
Amit Jain Re: Batch job stuck in Canceled state in Flink 1.5 Sun, 29 Apr, 16:30
Aneesha Kaushal Savepointing with Avro Schema change Tue, 03 Apr, 10:11
Ankit Chaudhary Re: Raspberry Pi Memory Configuration Mon, 30 Apr, 07:09
Ashish Attarde Lot of data generated in out file Fri, 06 Apr, 18:09
Ashish Attarde Re: Lot of data generated in out file Mon, 16 Apr, 05:13
Bajaj, Abhinav Re: Unable to load AWS credentials: Flink 1.2.1 + S3 + Kubernetes Mon, 02 Apr, 17:32
Bajaj, Abhinav Re: Unable to load AWS credentials: Flink 1.2.1 + S3 + Kubernetes Thu, 05 Apr, 22:29
Ben Yan Re: Record timestamp from kafka Tue, 10 Apr, 10:29
Ben Yan Re: Record timestamp from kafka Tue, 10 Apr, 11:32
Ben Yan Re: Record timestamp from kafka Tue, 10 Apr, 11:40
Bernd.Winterst...@Dev.Helaba.de Consumer offsets not visible in Kafka Thu, 19 Apr, 09:37
Bowen Li Re: 1.4.3 release/roadmap Fri, 20 Apr, 04:36
Chan, Regina RE: Fat jar fails deployment (streaming job too large) Mon, 30 Apr, 19:53
Chan, Regina Setting Parallelsim for implicit key extractor operator/NoResourceAvailableException: Not enough free slots available to run the job. Mon, 30 Apr, 22:27
Chauvet, Thomas Flink job testing with Tue, 17 Apr, 14:16
Chauvet, Thomas Flink / Kafka unit testing with scalatest-embedded-kafka Thu, 19 Apr, 13:23
Chauvet, Thomas RE: Flink / Kafka unit testing with scalatest-embedded-kafka Thu, 19 Apr, 13:31
Chengzhi Zhao Watermark Question on Failed Process Mon, 02 Apr, 21:51
Chengzhi Zhao Re: Watermark Question on Failed Process Tue, 03 Apr, 17:39
Chengzhi Zhao Re: Watermark Question on Failed Process Wed, 04 Apr, 16:38
Chengzhi Zhao Slow watermark advances Fri, 13 Apr, 15:48
Chengzhi Zhao Re: Slow watermark advances Fri, 13 Apr, 20:00
Chengzhi Zhao Multiple Streams Connect Watermark Wed, 25 Apr, 18:20
Chengzhi Zhao Re: Multiple Streams Connect Watermark Thu, 26 Apr, 18:44
Chengzhi Zhao Re: Multiple Streams Connect Watermark Fri, 27 Apr, 14:41
Chesnay Schepler Re: Flink Kafka producer: Object of class is not serializable Tue, 03 Apr, 08:12
Chesnay Schepler Re: SideOutput Issue Wed, 04 Apr, 10:21
Chesnay Schepler Re: SideOutput Issue Thu, 05 Apr, 08:25
Chesnay Schepler Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 19:48
Chesnay Schepler Re: Record timestamp from kafka Tue, 10 Apr, 10:32
Chesnay Schepler Re: How to customize triggering of checkpoints? Wed, 11 Apr, 08:35
Chesnay Schepler Re: Allowed lateness + side output late data, what's included? Wed, 11 Apr, 09:59
Chesnay Schepler Re: How to add new Kafka topic to consumer Wed, 11 Apr, 12:40
Chesnay Schepler Re: keyBy and parallelism Thu, 12 Apr, 07:31
Chesnay Schepler Re: Unsure how to further debug - operator threads stuck on java.lang.Thread.State: WAITING Sun, 15 Apr, 16:54
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Box list
Aug 2019377
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