flink-user mailing list archives: May 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
周思华 Re:Flink Memory Usage Thu, 10 May, 03:56
杨力 Jobs running on a yarn per-job cluster fail to restart when a task manager is lost Tue, 22 May, 08:33
陈梓立 Why FoldFunction deprecated? Fri, 04 May, 21:36
Gyula Fóra PartitionNotFoundException after deployment Fri, 04 May, 08:27
Gyula Fóra Re: PartitionNotFoundException after deployment Fri, 04 May, 13:36
Szymon Szczypiński Re: DFS problem with removing checkpoint Wed, 16 May, 21:49
Jörn Franke Re: Batch writing from Flink streaming job Sun, 13 May, 12:09
Jörn Franke Re: How to sleep for 1 sec and then call keyBy for partitioning Wed, 16 May, 20:41
Jörn Franke Re: Writing Table API results to a csv file Sun, 27 May, 17:51
Abdul Qadeer Multiple Task Slots support in Flink 1.5 Wed, 30 May, 21:26
Ajay Tripathy Stream.union doesn't change the parallelism of the new stream? Thu, 03 May, 20:29
Ajay Tripathy Re: JVM metrics disappearing after job crash, restart Thu, 31 May, 00:30
Alberto Mancini Timers and Checkpoints Fri, 25 May, 11:41
Alberto Mancini Re: Timers and Checkpoints Fri, 25 May, 13:19
Alberto Mancini Re: Timers and Checkpoints Fri, 25 May, 22:11
Alexander Smirnov This server is not the leader for that topic-partition Fri, 04 May, 13:45
Alexander Smirnov Re: This server is not the leader for that topic-partition Fri, 04 May, 15:55
Alexander Smirnov Re: This server is not the leader for that topic-partition Mon, 07 May, 10:12
Alexander Smirnov Re: This server is not the leader for that topic-partition Mon, 07 May, 12:00
Alexander Smirnov Re: Consolidated log for a job? Mon, 14 May, 14:33
Alexandru Gutan Re: Is Flink:1.5 Docker image broken? Thu, 31 May, 06:58
Aljoscha Krettek Re: KafkaProducer with generic (Avro) serialization schema Wed, 02 May, 14:47
Aljoscha Krettek Re: ConnectedIterativeStreams and processing state 1.4.2 Thu, 03 May, 10:09
Aljoscha Krettek Re: ConnectedIterativeStreams and processing state 1.4.2 Thu, 03 May, 11:09
Aljoscha Krettek Re: Missing MapState when Timer fires after restored state Tue, 15 May, 06:22
Amit Jain Re: Batch job stuck in Canceled state in Flink 1.5 Wed, 02 May, 10:21
Amit Jain Re: Batch job stuck in Canceled state in Flink 1.5 Thu, 03 May, 11:33
Amit Jain Re: Question about datasource replication Fri, 04 May, 12:50
Amit Jain [Flink 1.5.0] BlobServer data for a job is not getting cleaned up at JM Wed, 16 May, 11:58
Amit Jain Re: [Flink 1.5.0] BlobServer data for a job is not getting cleaned up at JM Wed, 16 May, 12:12
Amit Jain Message guarantees with S3 Sink Thu, 17 May, 09:57
Amit Jain Re: Message guarantees with S3 Sink Thu, 17 May, 17:26
Amit Jain Re: Message guarantees with S3 Sink Mon, 21 May, 07:14
Amit Jain Re: Batch job stuck in Canceled state in Flink 1.5 Mon, 21 May, 07:27
Amit Jain Re: Checkpointing when reading from files? Mon, 21 May, 19:24
Amit Jain Re: Strange Behaviour with task manager oom ? Mon, 21 May, 19:30
Amit Jain Re: Batch job stuck in Canceled state in Flink 1.5 Tue, 22 May, 11:29
Amit Jain Re: Batch job stuck in Canceled state in Flink 1.5 Thu, 24 May, 11:28
Amit Jain Re: Batch job stuck in Canceled state in Flink 1.5 Tue, 29 May, 14:56
Andrei Shumanski Fwd: Decrease initial source read speed Wed, 16 May, 14:30
Andrei Shumanski Re: Fwd: Decrease initial source read speed Fri, 18 May, 09:59
Andrei Shumanski Re: Decrease initial source read speed Wed, 23 May, 13:10
Andrei Shumanski Re: Decrease initial source read speed Wed, 23 May, 14:16
Andrew Whitaker unsubscribe Mon, 07 May, 14:26
Anil Trigerring Savepoint for the Flink Job Thu, 31 May, 20:01
Bajaj, Abhinav Akka heartbeat configurations Mon, 14 May, 23:42
Bajaj, Abhinav Re: Akka heartbeat configurations Wed, 16 May, 19:02
Bajaj, Abhinav Flink 1.2.1 - Job initial start time Thu, 31 May, 16:30
Bajaj, Abhinav Re: Flink 1.2.1 - Job initial start time Thu, 31 May, 16:34
Benjamin Cuthbert jvm options for individual jobs / topologies Tue, 08 May, 09:46
Bowen Li Re: Recommended books Wed, 09 May, 17:17
Bowen Li Re: Missing MapState when Timer fires after restored state Mon, 14 May, 17:48
Bowen Li Re: Clarification in TumblingProcessing TimeWindow Documentation Mon, 28 May, 06:39
Bowen Li Re: [ANNOUNCE] Apache Flink 1.5.0 release Mon, 28 May, 18:54
Bowen Li Re: Flink and AWS S3 integration: java.lang.NullPointerException: null uri host Thu, 31 May, 01:06
Chan, Regina Lost JobManager Tue, 01 May, 22:38
Chan, Regina RE: Lost JobManager Tue, 08 May, 15:41
Chan, Regina Data sink finishes before previous task finishes Tue, 22 May, 19:03
Chengzhi Zhao Better way to clean up state when connect Fri, 11 May, 16:48
Chengzhi Zhao Re: Better way to clean up state when connect Mon, 14 May, 14:05
Chengzhi Zhao Re: Better way to clean up state when connect Tue, 15 May, 19:25
Chengzhi Zhao Re: Better way to clean up state when connect Wed, 16 May, 01:52
Chesnay Schepler Re: Configure provided libraries with maven Thu, 03 May, 11:33
Chesnay Schepler Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes Mon, 07 May, 06:46
Chesnay Schepler Re: Error handling Wed, 09 May, 07:10
Chesnay Schepler Re: Using two different configurations for StreamExecutionEnvironment Wed, 09 May, 11:34
Chesnay Schepler Re: Using two different configurations for StreamExecutionEnvironment Wed, 09 May, 12:19
Chesnay Schepler Re: Using two different configurations for StreamExecutionEnvironment Wed, 09 May, 15:04
Chesnay Schepler Re: Do Flink metrics survive a shutdown? Wed, 09 May, 18:29
Chesnay Schepler Re: [Flink 1.5.0] BlobServer data for a job is not getting cleaned up at JM Wed, 16 May, 12:03
Chesnay Schepler Re: Job execution fails when parallelism is increased beyond 1 Mon, 28 May, 12:17
Chesnay Schepler Re: What is the package in Flink-Cassandra-connector, includes Cassandra datastax core Tue, 29 May, 12:01
Chesnay Schepler Re: Build Cassandra Connector with some customization Wed, 30 May, 08:03
Chesnay Schepler Re: is it OK to PR just for code comment errors? Thu, 31 May, 14:54
Chirag Dewan Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes Mon, 07 May, 06:18
Chirag Dewan Flink FSStateBackend Checkpointing Buffer size Mon, 14 May, 09:24
Chirag Dewan Large number of sources in Flink Job Mon, 28 May, 04:35
Chirag Dewan Gluster as file system for state backend Thu, 31 May, 04:56
Chirag Dewan Is Flink:1.5 Docker image broken? Thu, 31 May, 05:09
Chris Ruegger Re: Writing Table API results to a csv file Mon, 28 May, 09:13
Daniel Tavares LocatableInputSplit flink and not Assigning properly Thu, 17 May, 12:31
David Corley Zookeeper DR backup needed for Flink HA mode? Tue, 15 May, 13:20
Dawid Wysakowicz Re: cep performance Thu, 24 May, 07:39
Dawid Wysakowicz Re: sharebuffer prune code Sun, 27 May, 12:24
Dawid Wysakowicz Re: NPE in flink sql over-window Wed, 30 May, 07:25
Deepak Sharma Re: Multiple hdfs Tue, 22 May, 14:07
Derek VerLee intentional back-pressure (or a poor man's side-input) Wed, 02 May, 14:31
Derek VerLee Re: Migration to Flip6 Kubernetes Wed, 02 May, 21:17
Derek VerLee Re: intentional back-pressure (or a poor man's side-input) Thu, 03 May, 17:03
Derek VerLee strange behavior with jobmanager.rpc.address on standalone HA cluster Sat, 05 May, 13:34
Dhruv Kumar Signal for End of Stream Mon, 07 May, 11:18
Dhruv Kumar Re: Signal for End of Stream Mon, 07 May, 15:18
Dhruv Kumar Re: Signal for End of Stream Tue, 08 May, 03:37
Dhruv Kumar Re: Signal for End of Stream Tue, 08 May, 08:57
Dhruv Kumar Replaying logs with microsecond delay Tue, 15 May, 17:40
Dhruv Kumar Re: Replaying logs with microsecond delay Tue, 15 May, 20:20
Dhruv Kumar Re: Replaying logs with microsecond delay Wed, 16 May, 01:41
Dhruv Kumar Re: Replaying logs with microsecond delay Wed, 16 May, 02:35
Dhruv Kumar Clarification in TumblingProcessing TimeWindow Documentation Sun, 27 May, 19:43
Dhruv Kumar Re: Clarification in TumblingProcessing TimeWindow Documentation Mon, 28 May, 15:30
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
Dec 2019312
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