flink-user mailing list archives: May 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Lasse Nedergaard ConnectedIterativeStreams and processing state 1.4.2 Tue, 01 May, 08:20
Piotr Nowojski   Re: ConnectedIterativeStreams and processing state 1.4.2 Wed, 02 May, 13:35
Lasse Nedergaard     Re: ConnectedIterativeStreams and processing state 1.4.2 Wed, 02 May, 14:25
Aljoscha Krettek       Re: ConnectedIterativeStreams and processing state 1.4.2 Thu, 03 May, 10:09
Lasse Nedergaard         Re: ConnectedIterativeStreams and processing state 1.4.2 Thu, 03 May, 10:28
Aljoscha Krettek           Re: ConnectedIterativeStreams and processing state 1.4.2 Thu, 03 May, 11:09
Lasse Nedergaard             Re: ConnectedIterativeStreams and processing state 1.4.2 Thu, 03 May, 11:27
Rich Bowen ApacheCon North America 2018 schedule is now live. Tue, 01 May, 12:36
Re: KafkaProducer with generic (Avro) serialization schema
Wouter Zorgdrager   Re: KafkaProducer with generic (Avro) serialization schema Tue, 01 May, 14:30
Piotr Nowojski     Re: KafkaProducer with generic (Avro) serialization schema Wed, 02 May, 14:34
Aljoscha Krettek       Re: KafkaProducer with generic (Avro) serialization schema Wed, 02 May, 14:47
Fabian Hueske       Re: KafkaProducer with generic (Avro) serialization schema Wed, 02 May, 14:47
Wouter Zorgdrager         Re: KafkaProducer with generic (Avro) serialization schema Wed, 02 May, 17:27
Zhenhao Li strange GC behaviour Tue, 01 May, 15:38
Zhenhao Li   Re: strange GC behaviour Tue, 01 May, 16:33
Ted Yu   Re: strange GC behaviour Tue, 01 May, 16:39
Zhenhao Li     Re: strange GC behaviour Tue, 01 May, 17:40
Vishal Santoshi Windows aligned with EDT ( with day light saving ) Tue, 01 May, 16:00
Vishal Santoshi   Re: Windows aligned with EDT ( with day light saving ) Wed, 02 May, 13:12
Fabian Hueske     Re: Windows aligned with EDT ( with day light saving ) Wed, 02 May, 13:19
Vishal Santoshi       Re: Windows aligned with EDT ( with day light saving ) Wed, 02 May, 13:31
Vishal Santoshi         Re: Windows aligned with EDT ( with day light saving ) Wed, 02 May, 18:00
Tzanko Matev How to log uncaught exceptions during job execution Tue, 01 May, 21:08
Chan, Regina Lost JobManager Tue, 01 May, 22:38
Fabian Hueske   Re: Lost JobManager Mon, 07 May, 10:31
Chan, Regina     RE: Lost JobManager Tue, 08 May, 15:41
Fabian Hueske       Re: Lost JobManager Tue, 08 May, 19:20
Stephan Ewen         Re: Lost JobManager Fri, 11 May, 18:26
Newport, Billy           RE: Lost JobManager Fri, 11 May, 18:46
anaray FLIP-6 Docker / Kubernetes Tue, 01 May, 23:29
Fabian Hueske   Re: FLIP-6 Docker / Kubernetes Mon, 07 May, 10:36
anaray     Re: FLIP-6 Docker / Kubernetes Mon, 07 May, 17:48
Gary Yao       Re: FLIP-6 Docker / Kubernetes Fri, 11 May, 06:39
syed IOException: Size of the state is larger than the maximum permitted memory-backed state Wed, 02 May, 01:25
Gary Yao   Re: IOException: Size of the state is larger than the maximum permitted memory-backed state Thu, 03 May, 15:50
Re: coordinate watermarks between jobs?
Fabian Hueske   Re: coordinate watermarks between jobs? Wed, 02 May, 09:43
Tao Xia     Re: coordinate watermarks between jobs? Fri, 04 May, 17:07
Eron Wright       Re: coordinate watermarks between jobs? Sat, 05 May, 00:07
Re: Application logs missing from jobmanager log
Fabian Hueske   Re: Application logs missing from jobmanager log Wed, 02 May, 09:53
Juho Autio     Re: Application logs missing from jobmanager log Fri, 11 May, 08:31
Fabian Hueske       Re: Application logs missing from jobmanager log Fri, 11 May, 08:34
Re: Batch job stuck in Canceled state in Flink 1.5
Fabian Hueske   Re: Batch job stuck in Canceled state in Flink 1.5 Wed, 02 May, 10:12
Amit Jain     Re: Batch job stuck in Canceled state in Flink 1.5 Wed, 02 May, 10:21
Stephan Ewen       Re: Batch job stuck in Canceled state in Flink 1.5 Thu, 03 May, 07:28
Amit Jain         Re: Batch job stuck in Canceled state in Flink 1.5 Thu, 03 May, 11:33
Stephan Ewen           Re: Batch job stuck in Canceled state in Flink 1.5 Thu, 03 May, 12:07
Nico Kruber             Re: Batch job stuck in Canceled state in Flink 1.5 Thu, 03 May, 15:01
Amit Jain               Re: Batch job stuck in Canceled state in Flink 1.5 Mon, 21 May, 07:27
Nico Kruber                 Re: Batch job stuck in Canceled state in Flink 1.5 Tue, 22 May, 10:39
Amit Jain                   Re: Batch job stuck in Canceled state in Flink 1.5 Tue, 22 May, 11:29
Till Rohrmann                     Re: Batch job stuck in Canceled state in Flink 1.5 Tue, 22 May, 23:13
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
Till Rohrmann                           Re: Batch job stuck in Canceled state in Flink 1.5 Wed, 30 May, 07:23
Re: Setting the parallelism in a cluster of machines properly
Fabian Hueske   Re: Setting the parallelism in a cluster of machines properly Wed, 02 May, 10:16
m@xi     Re: Setting the parallelism in a cluster of machines properly Wed, 02 May, 10:20
Fabian Hueske       Re: Setting the parallelism in a cluster of machines properly Wed, 02 May, 13:34
m@xi         Re: Setting the parallelism in a cluster of machines properly Wed, 02 May, 14:35
Re: Insert data into Cassandra without Flink Cassandra connection
Piotr Nowojski   Re: Insert data into Cassandra without Flink Cassandra connection Wed, 02 May, 11:08
Shuyi Chen     Re: Insert data into Cassandra without Flink Cassandra connection Wed, 02 May, 18:42
Peter Zende Wiring batch and stream together Wed, 02 May, 11:36
Fabian Hueske   Re: Wiring batch and stream together Fri, 11 May, 07:35
Re: Odd job failure
Piotr Nowojski   Re: Odd job failure Wed, 02 May, 11:37
Stephan Ewen     Re: Odd job failure Thu, 03 May, 08:22
Stephan Ewen       Re: Odd job failure Thu, 03 May, 08:24
Elias Levy       Re: Odd job failure Sat, 26 May, 15:58
Piotr Nowojski         Re: Odd job failure Mon, 28 May, 08:48
Elias Levy           Re: Odd job failure Mon, 28 May, 18:13
Piotr Nowojski             Re: Odd job failure Tue, 29 May, 12:28
Re: Apache Flink - Flink Forward SF 2018 - Scaling stream data pipelines (source code)
Piotr Nowojski   Re: Apache Flink - Flink Forward SF 2018 - Scaling stream data pipelines (source code) Wed, 02 May, 12:14
Till Rohrmann     Re: Apache Flink - Flink Forward SF 2018 - Scaling stream data pipelines (source code) Mon, 07 May, 05:48
M Singh       Re: Apache Flink - Flink Forward SF 2018 - Scaling stream data pipelines (source code) Mon, 07 May, 17:10
Re: Fat jar fails deployment (streaming job too large)
Piotr Nowojski   Re: Fat jar fails deployment (streaming job too large) Wed, 02 May, 12:46
Julio Biason Cannot submit jobs on a HA Standalone JobManager Wed, 02 May, 12:52
Julio Biason   Re: Cannot submit jobs on a HA Standalone JobManager Wed, 02 May, 16:51
Gary Yao     Re: Cannot submit jobs on a HA Standalone JobManager Thu, 03 May, 12:36
Julio Biason       Re: Cannot submit jobs on a HA Standalone JobManager Thu, 03 May, 14:00
Julio Biason         Re: Cannot submit jobs on a HA Standalone JobManager Thu, 03 May, 20:23
Gary Yao           Re: Cannot submit jobs on a HA Standalone JobManager Sat, 05 May, 08:19
Re: merge/union fast and slow streams based on event timestamp
Fabian Hueske   Re: merge/union fast and slow streams based on event timestamp Wed, 02 May, 12:54
Re: Setting Parallelsim for implicit key extractor operator/NoResourceAvailableException: Not enough free slots available to run the job.
Fabian Hueske   Re: Setting Parallelsim for implicit key extractor operator/NoResourceAvailableException: Not enough free slots available to run the job. Wed, 02 May, 13:07
Derek VerLee intentional back-pressure (or a poor man's side-input) Wed, 02 May, 14:31
Piotr Nowojski   Re: intentional back-pressure (or a poor man's side-input) Thu, 03 May, 14:49
Derek VerLee     Re: intentional back-pressure (or a poor man's side-input) Thu, 03 May, 17:03
Piotr Nowojski       Re: intentional back-pressure (or a poor man's side-input) Fri, 04 May, 09:53
Re: Migration to Flip6 Kubernetes
Derek VerLee   Re: Migration to Flip6 Kubernetes Wed, 02 May, 21:17
Padarn Wilson Window over events defined by a time range Thu, 03 May, 06:39
Fabian Hueske   Re: Window over events defined by a time range Thu, 03 May, 07:57
shashank734 How to set fix JobId for my application. Thu, 03 May, 07:23
Gary Yao   Re: How to set fix JobId for my application. Thu, 03 May, 15:20
shashank734     Re: How to set fix JobId for my application. Thu, 03 May, 18:21
Gary Yao       Re: How to set fix JobId for my application. Sat, 05 May, 07:47
shashank734         Re: How to set fix JobId for my application. Mon, 14 May, 14:17
RE: use of values of previously accepted event
Esa Heikkinen   RE: use of values of previously accepted event Thu, 03 May, 10:37
Esa Heikkinen     RE: use of values of previously accepted event Fri, 04 May, 09:13
Georgi Stoyanov Configure provided libraries with maven Thu, 03 May, 10:56
Chesnay Schepler   Re: Configure provided libraries with maven Thu, 03 May, 11:33
Ken Krugler Stashing key with AggregateFunction Thu, 03 May, 17:53
Stefan Richter   Re: Stashing key with AggregateFunction Fri, 04 May, 14:31
Fabian Hueske   Re: Stashing key with AggregateFunction Fri, 04 May, 14:35
Ken Krugler     Re: Stashing key with AggregateFunction Fri, 04 May, 22:46
Fabian Hueske       Re: Stashing key with AggregateFunction Sun, 06 May, 18:25
ani.desh1512 Flink + Marathon (Mesos) Memory Issues Thu, 03 May, 19:59
Stefan Richter   Re: Flink + Marathon (Mesos) Memory Issues Fri, 04 May, 09:31
hao gao     Re: Flink + Marathon (Mesos) Memory Issues Fri, 04 May, 21:53
Ajay Tripathy Stream.union doesn't change the parallelism of the new stream? Thu, 03 May, 20:29
Fabian Hueske   Re: Stream.union doesn't change the parallelism of the new stream? Thu, 03 May, 21:21
Re: Classloader and removal of native libraries <SOLVED>
Martin Eden   Re: Classloader and removal of native libraries <SOLVED> Thu, 03 May, 21:41
Meghashyam Sandeep V dynamic tables in cassandra sink Thu, 03 May, 23:31
Michael Latta   Re: dynamic tables in cassandra sink Thu, 03 May, 23:37
Gyula Fóra PartitionNotFoundException after deployment Fri, 04 May, 08:27
Ufuk Celebi   Re: PartitionNotFoundException after deployment Fri, 04 May, 12:52
Piotr Nowojski     Re: PartitionNotFoundException after deployment Fri, 04 May, 13:33
Gyula Fóra       Re: PartitionNotFoundException after deployment Fri, 04 May, 13:36
Edward Rojas Dynamically deleting kafka topics does not remove partitions from kafkaConsumer Fri, 04 May, 10:15
Tzu-Li (Gordon) Tai   Re: Dynamically deleting kafka topics does not remove partitions from kafkaConsumer Mon, 07 May, 03:29
Ted Yu     Re: Dynamically deleting kafka topics does not remove partitions from kafkaConsumer Mon, 07 May, 03:42
Tzu-Li (Gordon) Tai       Re: Dynamically deleting kafka topics does not remove partitions from kafkaConsumer Mon, 07 May, 03:51
Edward Alexander Rojas Clavijo         Re: Dynamically deleting kafka topics does not remove partitions from kafkaConsumer Mon, 07 May, 15:06
Re: checkpoint stuck with rocksdb statebackend and s3 filesystem
Tony Wei   Re: checkpoint stuck with rocksdb statebackend and s3 filesystem Fri, 04 May, 10:27
Stefan Richter     Re: checkpoint stuck with rocksdb statebackend and s3 filesystem Fri, 04 May, 12:29
Flavio Pompermaier Question about datasource replication Fri, 04 May, 12:44
Amit Jain   Re: Question about datasource replication Fri, 04 May, 12:50
Flavio Pompermaier     Re: Question about datasource replication Fri, 04 May, 12:55
Fabian Hueske       Re: Question about datasource replication Fri, 04 May, 15:14
Flavio Pompermaier         Re: Question about datasource replication Fri, 04 May, 15:25
Fabian Hueske           Re: Question about datasource replication Fri, 04 May, 16:02
Flavio Pompermaier             Re: Question about datasource replication Fri, 04 May, 16:05
Fabian Hueske               Re: Question about datasource replication Fri, 04 May, 16:09
Alexander Smirnov This server is not the leader for that topic-partition Fri, 04 May, 13:45
Stefan Richter   Re: This server is not the leader for that topic-partition Fri, 04 May, 13:53
Piotr Nowojski     Re: This server is not the leader for that topic-partition Fri, 04 May, 13:58
Alexander Smirnov       Re: This server is not the leader for that topic-partition Fri, 04 May, 15:55
Piotr Nowojski         Re: This server is not the leader for that topic-partition Sat, 05 May, 07:19
Alexander Smirnov           Re: This server is not the leader for that topic-partition Mon, 07 May, 10:12
Piotr Nowojski             Re: This server is not the leader for that topic-partition Mon, 07 May, 11:59
Alexander Smirnov               Re: This server is not the leader for that topic-partition Mon, 07 May, 12:00
gerardg                 Re: This server is not the leader for that topic-partition Tue, 22 May, 14:28
Flavio Pompermaier Wrong joda lib Fri, 04 May, 16:02
Stefan Richter   Re: Wrong joda lib Fri, 04 May, 16:11
Flavio Pompermaier     Re: Wrong joda lib Fri, 04 May, 16:14
Stefan Richter       Re: Wrong joda lib Fri, 04 May, 16:16
Flavio Pompermaier     Re: Wrong joda lib Fri, 04 May, 16:29
Stefan Richter       Re: Wrong joda lib Fri, 04 May, 16:51
Peter Zende Init RocksDB state backend during startup Fri, 04 May, 16:31
Tao Xia   Re: Init RocksDB state backend during startup Fri, 04 May, 17:47
Fabian Hueske     Re: Init RocksDB state backend during startup Mon, 07 May, 11:59
陈梓立 Why FoldFunction deprecated? Fri, 04 May, 21:36
Fabian Hueske   Re: Why FoldFunction deprecated? Mon, 07 May, 12:05
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
May 2019362
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