flink-user mailing list archives: December 2017

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Re: FlinkKafkaProducerXX
Tzu-Li (Gordon) Tai   Re: FlinkKafkaProducerXX Fri, 01 Dec, 04:16
Stephan Ewen     Re: FlinkKafkaProducerXX Sun, 03 Dec, 19:08
Mikhail Pryakhin       Re: FlinkKafkaProducerXX Mon, 04 Dec, 08:49
Re: [EXTERNAL] difference between checkpoints & savepoints
Hao Sun   Re: [EXTERNAL] difference between checkpoints & savepoints Fri, 01 Dec, 06:21
Rahul Raj ElasticSearch Connector for version 6.x and scala 2.11 Fri, 01 Dec, 06:22
Fabian Hueske   Re: ElasticSearch Connector for version 6.x and scala 2.11 Fri, 01 Dec, 08:52
Jens Oberender     Re: ElasticSearch Connector for version 6.x and scala 2.11 Fri, 01 Dec, 13:42
Re: Questions about checkpoints/savepoints
Hao Sun   Re: Questions about checkpoints/savepoints Fri, 01 Dec, 06:35
Steven Wu Checkpoint expired before completing Fri, 01 Dec, 06:36
Nico Kruber   Re: Checkpoint expired before completing Fri, 01 Dec, 14:17
Steven Wu     Re: Checkpoint expired before completing Fri, 01 Dec, 21:10
Stephan Ewen       Re: Checkpoint expired before completing Sat, 02 Dec, 16:58
Steven Wu         Re: Checkpoint expired before completing Sat, 02 Dec, 22:10
Steven Wu           Re: Checkpoint expired before completing Sat, 02 Dec, 22:30
Nico Kruber             Re: Checkpoint expired before completing Mon, 04 Dec, 13:29
Re: flink local & interactive development
Fabian Hueske   Re: flink local & interactive development Fri, 01 Dec, 09:10
Georg Heiler     Re: flink local & interactive development Fri, 01 Dec, 15:36
Re: Non-intrusive way to detect which type is using kryo ?
Kien Truong   Re: Non-intrusive way to detect which type is using kryo ? Fri, 01 Dec, 12:42
Timo Walther     Re: Non-intrusive way to detect which type is using kryo ? Fri, 01 Dec, 14:35
Re: Kafka consumer to sync topics by event time?
Juho Autio   Re: Kafka consumer to sync topics by event time? Fri, 01 Dec, 12:43
Fabian Hueske     Re: Kafka consumer to sync topics by event time? Mon, 04 Dec, 13:30
Juho Autio       Re: Kafka consumer to sync topics by event time? Mon, 04 Dec, 13:42
Fabian Hueske         Re: Kafka consumer to sync topics by event time? Mon, 04 Dec, 14:29
vijayakumar palaniappan Incremental RocksDB checkpointing Fri, 01 Dec, 15:34
Stefan Richter   Re: Incremental RocksDB checkpointing Fri, 01 Dec, 16:39
vijayakumar palaniappan     Re: Incremental RocksDB checkpointing Fri, 01 Dec, 17:22
Stefan Richter       Re: Incremental RocksDB checkpointing Fri, 01 Dec, 17:33
Vishal Santoshi aggregate does not allow RichAggregateFunction ? Fri, 01 Dec, 18:38
Vishal Santoshi   Re: aggregate does not allow RichAggregateFunction ? Wed, 06 Dec, 02:52
Fabian Hueske     Re: aggregate does not allow RichAggregateFunction ? Wed, 06 Dec, 13:57
Aljoscha Krettek       Re: aggregate does not allow RichAggregateFunction ? Fri, 08 Dec, 14:11
Vishal Santoshi         Re: aggregate does not allow RichAggregateFunction ? Fri, 08 Dec, 18:12
Vishal Santoshi           Re: aggregate does not allow RichAggregateFunction ? Sat, 09 Dec, 17:09
Fabian Hueske             Re: aggregate does not allow RichAggregateFunction ? Mon, 11 Dec, 09:34
Vishal Santoshi               Re: aggregate does not allow RichAggregateFunction ? Mon, 11 Dec, 15:13
Vishal Santoshi                 Re: aggregate does not allow RichAggregateFunction ? Sun, 17 Dec, 19:46
Hao Sun non-shared TaskManager-specific config file Fri, 01 Dec, 22:14
Chesnay Schepler   Re: non-shared TaskManager-specific config file Mon, 04 Dec, 08:50
Hao Sun     Re: non-shared TaskManager-specific config file Mon, 04 Dec, 15:15
Fabian Hueske       Re: non-shared TaskManager-specific config file Mon, 04 Dec, 15:25
Hao Sun         Re: non-shared TaskManager-specific config file Mon, 04 Dec, 15:35
Hao Sun           Re: non-shared TaskManager-specific config file Mon, 04 Dec, 20:13
Hao Sun Trace jar file name from jobId, is that possible? Fri, 01 Dec, 23:28
Fabian Hueske   Re: Trace jar file name from jobId, is that possible? Mon, 04 Dec, 12:51
Hao Sun     Re: Trace jar file name from jobId, is that possible? Mon, 04 Dec, 20:01
Hao Sun       Re: Trace jar file name from jobId, is that possible? Thu, 07 Dec, 15:59
Fabian Hueske         Re: Trace jar file name from jobId, is that possible? Thu, 07 Dec, 16:28
Hao Sun           Re: Trace jar file name from jobId, is that possible? Thu, 07 Dec, 16:32
Fabian Hueske             Re: Trace jar file name from jobId, is that possible? Thu, 07 Dec, 16:47
Hao Sun               Re: Trace jar file name from jobId, is that possible? Thu, 07 Dec, 16:56
Soheil Pourbafrani using regular expression to specify Kafka topics Sat, 02 Dec, 21:28
Tzu-Li (Gordon) Tai   Re: using regular expression to specify Kafka topics Mon, 04 Dec, 07:02
Tzu-Li (Gordon) Tai     Re: using regular expression to specify Kafka topics Mon, 04 Dec, 11:36
Gyula Fóra       Re: using regular expression to specify Kafka topics Mon, 04 Dec, 12:10
Aljoscha Krettek         Re: using regular expression to specify Kafka topics Mon, 04 Dec, 13:35
Bernd.Winterst...@Dev.Helaba.de Blob server not working with 1.4.0.RC2 Mon, 04 Dec, 09:03
Nico Kruber   Re: Blob server not working with 1.4.0.RC2 Mon, 04 Dec, 13:16
Bernd.Winterst...@Dev.Helaba.de   AW: Blob server not working with 1.4.0.RC2 Wed, 06 Dec, 07:45
Fabian Hueske     Re: Blob server not working with 1.4.0.RC2 Wed, 06 Dec, 08:32
Nico Kruber     Re: AW: Blob server not working with 1.4.0.RC2 Wed, 06 Dec, 08:43
Marchant, Hayden TaskManager HA on YARN Mon, 04 Dec, 10:31
Till Rohrmann   Re: TaskManager HA on YARN Mon, 04 Dec, 11:14
Re: Maintain heavy hitters in Flink application
Fabian Hueske   Re: Maintain heavy hitters in Flink application Mon, 04 Dec, 10:51
m@xi     Re: Maintain heavy hitters in Flink application Tue, 05 Dec, 08:52
Fabian Hueske       Re: Maintain heavy hitters in Flink application Tue, 05 Dec, 09:32
Kostas Kloudas         Re: Maintain heavy hitters in Flink application Thu, 07 Dec, 10:10
m@xi           Re: Maintain heavy hitters in Flink application Sat, 09 Dec, 07:01
Re: Flik typesafe configuration
Fabian Hueske   Re: Flik typesafe configuration Mon, 04 Dec, 11:11
Tao Xia Window function support on SQL Mon, 04 Dec, 21:17
Fabian Hueske   Re: Window function support on SQL Mon, 04 Dec, 23:32
Tao Xia     Re: Window function support on SQL Tue, 05 Dec, 00:40
Fabian Hueske       Re: Window function support on SQL Tue, 05 Dec, 09:27
Yuta Morisawa CPU Cores of JobManager Tue, 05 Dec, 04:13
Timo Walther   Re: CPU Cores of JobManager Tue, 05 Dec, 09:02
Yuta Morisawa     Re: CPU Cores of JobManager Tue, 05 Dec, 09:37
Timo Walther       Re: CPU Cores of JobManager Tue, 05 Dec, 10:55
Yuta Morisawa         Re: CPU Cores of JobManager Wed, 06 Dec, 00:20
Chesnay Schepler           Re: CPU Cores of JobManager Wed, 06 Dec, 08:08
Yuta Morisawa             Re: CPU Cores of JobManager Wed, 06 Dec, 08:50
Stephan Ewen               Re: CPU Cores of JobManager Wed, 06 Dec, 09:22
Chesnay Schepler                 Re: CPU Cores of JobManager Wed, 06 Dec, 09:36
Chesnay Schepler                   Re: CPU Cores of JobManager Wed, 06 Dec, 09:52
Yuta Morisawa                     Re: CPU Cores of JobManager Thu, 07 Dec, 00:01
Xin Wang subscribe Tue, 05 Dec, 07:21
Chesnay Schepler   Re: subscribe Tue, 05 Dec, 08:09
Shailesh Jain Share state across operators Tue, 05 Dec, 10:58
Shailesh Jain   Re: Share state across operators Tue, 05 Dec, 11:14
Timo Walther   Re: Share state across operators Tue, 05 Dec, 11:25
Shailesh Jain     Re: Share state across operators Tue, 05 Dec, 16:48
Jayant Ameta Flink with Ceph as the persistent storage Tue, 05 Dec, 11:00
Gyula Fóra   Re: Flink with Ceph as the persistent storage Tue, 05 Dec, 11:04
Jayant Ameta     Re: Flink with Ceph as the persistent storage Tue, 05 Dec, 11:15
Gyula Fóra       Re: Flink with Ceph as the persistent storage Tue, 05 Dec, 11:16
Sofer, Tovi slot group indication per operator Tue, 05 Dec, 15:25
Timo Walther   Re: slot group indication per operator Tue, 05 Dec, 16:55
Sofer, Tovi     RE: slot group indication per operator Mon, 11 Dec, 08:19
Re: S3 Write Execption
vinay patil   Re: S3 Write Execption Tue, 05 Dec, 17:18
vinay patil   Re: S3 Write Execption Tue, 05 Dec, 17:21
Garrett Barton Flink Batch Performance degradation at scale Tue, 05 Dec, 21:03
Fabian Hueske   Re: Flink Batch Performance degradation at scale Tue, 05 Dec, 22:36
Garrett Barton     Re: Flink Batch Performance degradation at scale Wed, 06 Dec, 15:45
Fabian Hueske       Re: Flink Batch Performance degradation at scale Wed, 06 Dec, 16:49
Garrett Barton         Re: Flink Batch Performance degradation at scale Wed, 06 Dec, 22:32
Fabian Hueske           Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 09:49
Garrett Barton             Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 15:30
Fabian Hueske               Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 16:59
Garrett Barton                 Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 17:35
Fabian Hueske                   Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 17:39
Garrett Barton                     Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 17:56
Fabian Hueske                       Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 18:08
Greg Hogan   Re: Flink Batch Performance degradation at scale Thu, 07 Dec, 21:36
Re: How to perform efficient DataSet reuse between iterations
Miguel Coimbra   Re: How to perform efficient DataSet reuse between iterations Wed, 06 Dec, 02:01
Fabian Hueske     Re: How to perform efficient DataSet reuse between iterations Wed, 06 Dec, 08:48
Miguel Coimbra       Re: How to perform efficient DataSet reuse between iterations Wed, 06 Dec, 10:10
Fabian Hueske         Re: How to perform efficient DataSet reuse between iterations Wed, 06 Dec, 10:27
Miguel Coimbra           Re: How to perform efficient DataSet reuse between iterations Thu, 07 Dec, 14:40
Fabian Hueske             Re: How to perform efficient DataSet reuse between iterations Thu, 07 Dec, 17:16
Jayant Ameta Performance of docker-flink Wed, 06 Dec, 08:43
Gary Yao   Re: Performance of docker-flink Thu, 07 Dec, 11:07
Jayant Ameta     Re: Performance of docker-flink Thu, 07 Dec, 11:49
the location of JsonRowDeserializationSchema.java
Sendoh   the location of JsonRowDeserializationSchema.java Wed, 06 Dec, 16:35
Sendoh   the location of JsonRowDeserializationSchema.java Wed, 06 Dec, 16:35
Fabian Hueske     Re: the location of JsonRowDeserializationSchema.java Wed, 06 Dec, 16:56
Sendoh       Re: the location of JsonRowDeserializationSchema.java Thu, 07 Dec, 09:18
Fabian Hueske         Re: the location of JsonRowDeserializationSchema.java Thu, 07 Dec, 09:25
Vishal Santoshi save points through REST API not supported ? Wed, 06 Dec, 18:56
vipul singh   Re: save points through REST API not supported ? Wed, 06 Dec, 18:59
Vishal Santoshi     Re: save points through REST API not supported ? Wed, 06 Dec, 20:52
Lasse Nedergaard       Re: save points through REST API not supported ? Wed, 06 Dec, 21:01
Vishal Santoshi         Re: save points through REST API not supported ? Wed, 06 Dec, 23:20
Chesnay Schepler           Re: save points through REST API not supported ? Wed, 06 Dec, 23:56
Vishal Santoshi             Re: save points through REST API not supported ? Thu, 07 Dec, 02:43
Chesnay Schepler               Re: save points through REST API not supported ? Thu, 07 Dec, 11:51
Chesnay Schepler                 Re: save points through REST API not supported ? Thu, 07 Dec, 12:00
Lasse Nedergaard                   Re: save points through REST API not supported ? Thu, 07 Dec, 12:42
Chesnay Schepler                     Re: save points through REST API not supported ? Mon, 11 Dec, 09:54
Vishal Santoshi                       Re: save points through REST API not supported ? Tue, 12 Dec, 04:22
Vishal Santoshi                 Re: save points through REST API not supported ? Thu, 07 Dec, 16:59
Fabian Hueske                   Re: save points through REST API not supported ? Thu, 07 Dec, 17:28
Nishu Data loss in Flink Kafka Pipeline Thu, 07 Dec, 08:43
Sendoh   Re: Data loss in Flink Kafka Pipeline Thu, 07 Dec, 09:20
Fabian Hueske     Re: Data loss in Flink Kafka Pipeline Thu, 07 Dec, 17:35
Chen Qin       Re: Data loss in Flink Kafka Pipeline Thu, 07 Dec, 18:13
Nishu         Re: Data loss in Flink Kafka Pipeline Thu, 07 Dec, 22:13
Fabian Hueske           Re: Data loss in Flink Kafka Pipeline Thu, 07 Dec, 22:47
Nishu             Re: Data loss in Flink Kafka Pipeline Thu, 07 Dec, 23:00
Fabian Hueske               Re: Data loss in Flink Kafka Pipeline Fri, 08 Dec, 11:31
Aljoscha Krettek                 Re: Data loss in Flink Kafka Pipeline Fri, 08 Dec, 12:04
Nishu   Re: Data loss in Flink Kafka Pipeline Fri, 08 Dec, 12:52
romain.jln ClassNotFoundException in custom SourceFunction Thu, 07 Dec, 09:35
Tugdual Grall   Re: ClassNotFoundException in custom SourceFunction Thu, 07 Dec, 09:44
Fabian Hueske     Re: ClassNotFoundException in custom SourceFunction Thu, 07 Dec, 17:33
romain.jln       Re: ClassNotFoundException in custom SourceFunction Fri, 08 Dec, 10:27
Fabian Hueske         Re: ClassNotFoundException in custom SourceFunction Fri, 08 Dec, 11:24
Aljoscha Krettek           Re: ClassNotFoundException in custom SourceFunction Fri, 08 Dec, 12:08
romain.jln             Re: ClassNotFoundException in custom SourceFunction Fri, 08 Dec, 13:13
Aljoscha Krettek               Re: ClassNotFoundException in custom SourceFunction Fri, 08 Dec, 13:20
romain.jln                 Re: ClassNotFoundException in custom SourceFunction Sat, 09 Dec, 12:12
Re: Taskmanagers are quarantined
T Obi   Re: Taskmanagers are quarantined Thu, 07 Dec, 12:06
Marchant, Hayden Hardware Reference Architecture Thu, 07 Dec, 12:53
Kostas Kloudas   Re: Hardware Reference Architecture Thu, 07 Dec, 17:36
Kostas Kloudas     Re: Hardware Reference Architecture Mon, 11 Dec, 15:50
Joern Kottmann Flink 1.4.0 RC3 and Avro objects with maps have null values Thu, 07 Dec, 14:19
Timo Walther   Re: Flink 1.4.0 RC3 and Avro objects with maps have null values Thu, 07 Dec, 14:54
Timo Walther     Re: Flink 1.4.0 RC3 and Avro objects with maps have null values Thu, 07 Dec, 14:57
Joern Kottmann       Re: Flink 1.4.0 RC3 and Avro objects with maps have null values Thu, 07 Dec, 16:07
Timo Walther         Re: Flink 1.4.0 RC3 and Avro objects with maps have null values Thu, 07 Dec, 16:19
Aljoscha Krettek           Re: Flink 1.4.0 RC3 and Avro objects with maps have null values Fri, 08 Dec, 13:13
Stephan Ewen             Re: Flink 1.4.0 RC3 and Avro objects with maps have null values Fri, 08 Dec, 15:54
Sofer, Tovi Testing CoFlatMap correctness Thu, 07 Dec, 16:54
Kostas Kloudas   Re: Testing CoFlatMap correctness Thu, 07 Dec, 17:10
Sofer, Tovi     RE: Testing CoFlatMap correctness Sun, 10 Dec, 09:04
Fabian Hueske       Re: Testing CoFlatMap correctness Tue, 12 Dec, 10:06
Re: specify user name when connecting to hdfs
Edward   Re: specify user name when connecting to hdfs Thu, 07 Dec, 20:49
Gordon Weakliem     Re: specify user name when connecting to hdfs Thu, 07 Dec, 21:07
Jinhua Luo does the flink sink only support bio? Fri, 08 Dec, 07:11
Stefan Richter   Re: does the flink sink only support bio? Fri, 08 Dec, 10:25
Jinhua Luo     Re: does the flink sink only support bio? Fri, 08 Dec, 13:37
Stefan Richter       Re: does the flink sink only support bio? Fri, 08 Dec, 13:50
rost...@informatik.uni-leipzig.de Problem with runGatherSumApplyIteration Fri, 08 Dec, 09:23
Stefan Richter   Re: Problem with runGatherSumApplyIteration Fri, 08 Dec, 13:21
rost...@informatik.uni-leipzig.de     Re: Problem with runGatherSumApplyIteration Mon, 11 Dec, 08:41
Sendoh TableException: GenericTypeInfo<Row> cannot be converted to Table Fri, 08 Dec, 10:19
Sendoh   Re: TableException: GenericTypeInfo<Row> cannot be converted to Table Fri, 08 Dec, 10:29
Fabian Hueske   Re: TableException: GenericTypeInfo<Row> cannot be converted to Table Fri, 08 Dec, 10:29
Fabian Hueske     Re: TableException: GenericTypeInfo<Row> cannot be converted to Table Fri, 08 Dec, 10:30
Sendoh     Re: TableException: GenericTypeInfo<Row> cannot be converted to Table Fri, 08 Dec, 11:30
Bernd.Winterst...@Dev.Helaba.de Manual Classloading on the job does not work Fri, 08 Dec, 10:38
Stefan Richter   Re: Manual Classloading on the job does not work Fri, 08 Dec, 13:38
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
May 2019361
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