flink-user mailing list archives: November 2017

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Re: state size effects latency
Stefan Richter   Re: state size effects latency Wed, 01 Nov, 03:02
Re: Help on RowTypeInfo?
Fabian Hueske   Re: Help on RowTypeInfo? Wed, 01 Nov, 07:35
Re: Batch job per stream message?
Fabian Hueske   Re: Batch job per stream message? Wed, 01 Nov, 07:57
Tomas Mazukna     Re: Batch job per stream message? Wed, 01 Nov, 15:12
Fabian Hueske       Re: Batch job per stream message? Thu, 02 Nov, 15:27
Re: Reprocessing the data after config change
Fabian Hueske   Re: Reprocessing the data after config change Wed, 01 Nov, 08:03
Re: does flink support yarn/hdfs HA?
Till Rohrmann   Re: does flink support yarn/hdfs HA? Wed, 01 Nov, 08:31
邓俊华   回复:does flink support yarn/hdfs HA? Wed, 01 Nov, 08:58
Till Rohrmann     Re: does flink support yarn/hdfs HA? Wed, 01 Nov, 12:24
邓俊华     回复:does flink support yarn/hdfs HA? Wed, 01 Nov, 13:45
Till Rohrmann       Re: does flink support yarn/hdfs HA? Wed, 01 Nov, 14:40
邓俊华       回复:does flink support yarn/hdfs HA? Thu, 02 Nov, 02:53
Till Rohrmann         Re: does flink support yarn/hdfs HA? Thu, 02 Nov, 08:47
邓俊华         回复:does flink support yarn/hdfs HA? Thu, 02 Nov, 08:58
Till Rohrmann           Re: does flink support yarn/hdfs HA? Thu, 02 Nov, 11:31
Re: Job Manager Configuration
Chesnay Schepler   Re: Job Manager Configuration Wed, 01 Nov, 11:09
Newport, Billy     RE: Job Manager Configuration Thu, 02 Nov, 12:38
Chan, Regina     RE: Job Manager Configuration Thu, 02 Nov, 18:18
Till Rohrmann       Re: Job Manager Configuration Tue, 07 Nov, 15:38
Till Rohrmann         Re: Job Manager Configuration Wed, 08 Nov, 15:17
Chan, Regina           RE: Job Manager Configuration Wed, 08 Nov, 18:24
Till Rohrmann             Re: Job Manager Configuration Thu, 09 Nov, 09:35
Joshua Griffith   Re: Job Manager Configuration Thu, 16 Nov, 19:56
Chan, Regina     RE: Job Manager Configuration Sat, 18 Nov, 22:10
Joshua Griffith       Re: Job Manager Configuration Tue, 21 Nov, 17:54
Re: Using Flink Ml with DataStream
Chesnay Schepler   Re: Using Flink Ml with DataStream Wed, 01 Nov, 11:16
Adarsh Jain     Re: Using Flink Ml with DataStream Fri, 03 Nov, 15:21
Re: Flink send checkpointing message in IT
Chesnay Schepler   Re: Flink send checkpointing message in IT Wed, 01 Nov, 11:26
Rinat     Re: Flink send checkpointing message in IT Thu, 02 Nov, 18:11
Chesnay Schepler       Re: Flink send checkpointing message in IT Tue, 07 Nov, 10:54
Rinat         Re: Flink send checkpointing message in IT Tue, 07 Nov, 10:58
Chesnay Schepler           Re: Flink send checkpointing message in IT Tue, 07 Nov, 11:30
Re: JobManager web interface redirect strategy when running in HA
Chesnay Schepler   Re: JobManager web interface redirect strategy when running in HA Wed, 01 Nov, 11:34
Jürgen Thomann     Re: JobManager web interface redirect strategy when running in HA Sun, 05 Nov, 09:22
mrooding       Re: JobManager web interface redirect strategy when running in HA Mon, 06 Nov, 12:54
Re: Use keyBy to deterministically hash each record to a processor/task/slot
m@xi   Re: Use keyBy to deterministically hash each record to a processor/task/slot Thu, 02 Nov, 11:00
Dongwon Kim     Re: Use keyBy to deterministically hash each record to a processor/task/slot Thu, 02 Nov, 12:38
m@xi       Re: Use keyBy to deterministically hash each record to a processor/task/slot Thu, 02 Nov, 13:36
javalass Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Thu, 02 Nov, 13:44
Piotr Nowojski   Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Thu, 02 Nov, 14:26
Vergilio, Thalita     Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Fri, 03 Nov, 09:23
Piotr Nowojski       Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Mon, 06 Nov, 08:22
Till Rohrmann         Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Mon, 06 Nov, 12:40
Vergilio, Thalita           Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Mon, 06 Nov, 13:37
Till Rohrmann             Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Mon, 06 Nov, 13:48
Vergilio, Thalita               Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Thu, 09 Nov, 22:04
Vergilio, Thalita             Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Fri, 10 Nov, 10:47
Till Rohrmann               Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Fri, 10 Nov, 12:15
Vergilio, Thalita                 Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Fri, 10 Nov, 21:18
Till Rohrmann                   Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Sun, 12 Nov, 18:05
Vergilio, Thalita   Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Thu, 02 Nov, 18:31
Vergilio, Thalita   Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Thu, 02 Nov, 18:56
Sofer, Tovi Negative values using latency marker Thu, 02 Nov, 16:58
Nico Kruber   Re: Negative values using latency marker Fri, 03 Nov, 13:22
Sofer, Tovi   RE: Negative values using latency marker Sun, 05 Nov, 08:22
Nico Kruber     Re: Negative values using latency marker Mon, 06 Nov, 10:35
Maxim Parkachov Initialise side input state Thu, 02 Nov, 21:54
Maxim Parkachov   Fwd: Initialise side input state Fri, 03 Nov, 06:11
Xingcan Cui     Re: Initialise side input state Fri, 03 Nov, 16:28
Elias Levy Incremental checkpointing documentation Fri, 03 Nov, 00:11
Nico Kruber   Re: Incremental checkpointing documentation Fri, 03 Nov, 15:13
Elias Levy Global windows and purging Fri, 03 Nov, 01:04
Elias Levy   Re: Global windows and purging Fri, 03 Nov, 03:59
Ron Crocker Making external calls from a FlinkKafkaPartitioner Fri, 03 Nov, 03:06
Nico Kruber   Re: Making external calls from a FlinkKafkaPartitioner Fri, 03 Nov, 14:48
Ron Crocker     Re: Making external calls from a FlinkKafkaPartitioner Fri, 03 Nov, 15:58
Federico D'Ambrosio FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 14:12
Federico D'Ambrosio   Re: FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 14:18
Kostas Kloudas   Re: FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 14:21
Federico D'Ambrosio     Re: FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 14:23
Kostas Kloudas       Re: FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 14:25
Federico D'Ambrosio         Re: FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 15:22
Kostas Kloudas           Re: FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 15:26
Federico D'Ambrosio             Re: FlinkCEP, circular references and checkpointing failures Fri, 03 Nov, 19:04
AndreaKinn Flink memory usage Fri, 03 Nov, 20:15
Kien Truong   Re: Flink memory usage Sat, 04 Nov, 12:56
AndreaKinn     Re: Flink memory usage Sat, 04 Nov, 15:05
AndreaKinn       Re: Flink memory usage Sat, 04 Nov, 15:19
Jürgen Thomann         Re: Flink memory usage Sun, 05 Nov, 09:40
Greg Hogan           Re: Flink memory usage Tue, 07 Nov, 17:13
Ashish Pokharel Kafka Consumer fetch-size/rate and Producer queue timeout Sun, 05 Nov, 15:24
Fabian Hueske   Re: Kafka Consumer fetch-size/rate and Producer queue timeout Tue, 07 Nov, 08:53
ashish pok     Re: Kafka Consumer fetch-size/rate and Producer queue timeout Tue, 07 Nov, 17:52
Tzu-Li (Gordon) Tai   Re: Kafka Consumer fetch-size/rate and Producer queue timeout Wed, 08 Nov, 10:09
Ashish Pokharel     Re: Kafka Consumer fetch-size/rate and Producer queue timeout Thu, 09 Nov, 02:35
Ashish Pokharel       Re: Kafka Consumer fetch-size/rate and Producer queue timeout Sat, 11 Nov, 14:57
XiangWei Huang ExecutionGraph not serializable Mon, 06 Nov, 02:27
Fabian Hueske   Re: ExecutionGraph not serializable Tue, 07 Nov, 08:58
Till Rohrmann     Re: ExecutionGraph not serializable Tue, 07 Nov, 09:16
XiangWei Huang       Re: ExecutionGraph not serializable Tue, 07 Nov, 13:47
Till Rohrmann         Re: ExecutionGraph not serializable Tue, 07 Nov, 15:07
Re: How can I handle backpressure with event time.
yunfan123   Re: How can I handle backpressure with event time. Mon, 06 Nov, 04:15
Re: Facing issues with Logback
Fabian Hueske   Re: Facing issues with Logback Mon, 06 Nov, 10:16
Federico D'Ambrosio FlinkCEP behaviour with time constraints not as expected Mon, 06 Nov, 11:06
Ufuk Celebi   Re: FlinkCEP behaviour with time constraints not as expected Tue, 07 Nov, 10:29
Dawid Wysakowicz     Re: FlinkCEP behaviour with time constraints not as expected Tue, 07 Nov, 15:34
Federico D'Ambrosio       Re: FlinkCEP behaviour with time constraints not as expected Wed, 08 Nov, 11:18
Dawid Wysakowicz         Re: FlinkCEP behaviour with time constraints not as expected Wed, 08 Nov, 12:51
Federico D'Ambrosio           Re: FlinkCEP behaviour with time constraints not as expected Wed, 08 Nov, 13:59
Seth Wiesman DataStream to Table Api idioms Mon, 06 Nov, 13:56
Fabian Hueske   Re: DataStream to Table Api idioms Mon, 06 Nov, 14:14
Seth Wiesman     Re: DataStream to Table Api idioms Mon, 06 Nov, 16:16
Re: Savepoints and migrating value state data types
mrooding   Re: Savepoints and migrating value state data types Mon, 06 Nov, 14:13
Aljoscha Krettek     Re: Savepoints and migrating value state data types Mon, 06 Nov, 15:26
Re: MODERATE for dev@flink.apache.org
Jordan Kuan   Re: MODERATE for dev@flink.apache.org Tue, 07 Nov, 02:34
Ufuk Celebi     Re: MODERATE for dev@flink.apache.org Tue, 07 Nov, 10:36
Jordan Kuan       Re: MODERATE for dev@flink.apache.org Tue, 07 Nov, 10:44
Ufuk Celebi         Re: MODERATE for dev@flink.apache.org Tue, 07 Nov, 10:49
Jordan Kuan           Re: MODERATE for dev@flink.apache.org Tue, 07 Nov, 11:36
Chesnay Schepler             Re: MODERATE for dev@flink.apache.org Tue, 07 Nov, 11:57
ÇETİNKAYA EBRU ÇETİNKAYA EBRU Flink memory leak Tue, 07 Nov, 09:27
Ufuk Celebi   Re: Flink memory leak Tue, 07 Nov, 10:34
Fwd: Flink memory leak
ebru   Fwd: Flink memory leak Tue, 07 Nov, 11:43
Ufuk Celebi     Re: Flink memory leak Tue, 07 Nov, 13:23
ebru       Re: Flink memory leak Tue, 07 Nov, 13:35
Ufuk Celebi         Re: Flink memory leak Tue, 07 Nov, 13:53
Aljoscha Krettek           Re: Flink memory leak Tue, 07 Nov, 14:08
ÇETİNKAYA EBRU ÇETİNKAYA EBRU           Re: Flink memory leak Wed, 08 Nov, 08:51
Flavio Pompermaier             Re: Flink memory leak Wed, 08 Nov, 09:25
Aljoscha Krettek               Re: Flink memory leak Wed, 08 Nov, 10:20
Javier Lopez                 Re: Flink memory leak Wed, 08 Nov, 11:43
ebru                   Re: Flink memory leak Wed, 08 Nov, 11:54
Piotr Nowojski                     Re: Flink memory leak Wed, 08 Nov, 12:20
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                       Re: Flink memory leak Wed, 08 Nov, 12:26
Javier Lopez                         Re: Flink memory leak Wed, 08 Nov, 13:08
Piotr Nowojski                           Re: Flink memory leak Wed, 08 Nov, 13:54
Javier Lopez                             Re: Flink memory leak Wed, 08 Nov, 13:57
Piotr Nowojski                               Re: Flink memory leak Wed, 08 Nov, 14:27
Javier Lopez                                 Re: Flink memory leak Wed, 08 Nov, 14:28
Piotr Nowojski                                   Re: Flink memory leak Wed, 08 Nov, 14:48
Piotr Nowojski                                     Re: Flink memory leak Wed, 08 Nov, 15:30
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                                       Re: Flink memory leak Thu, 09 Nov, 16:36
Piotr Nowojski                                         Re: Flink memory leak Thu, 09 Nov, 17:08
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                                           Re: Flink memory leak Fri, 10 Nov, 07:42
Piotr Nowojski                                             Re: Flink memory leak Fri, 10 Nov, 08:04
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                                               Re: Flink memory leak Fri, 10 Nov, 08:35
Piotr Nowojski                                                 Re: Flink memory leak Fri, 10 Nov, 10:14
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                                                   Re: Flink memory leak Fri, 10 Nov, 14:08
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                                                   Re: Flink memory leak Fri, 10 Nov, 14:12
Piotr Nowojski                                                     Re: Flink memory leak Tue, 14 Nov, 15:02
Flavio Pompermaier                                                       Re: Flink memory leak Tue, 14 Nov, 15:08
Piotr Nowojski                                                         Re: Flink memory leak Tue, 14 Nov, 16:29
ebru                                                           Re: Flink memory leak Thu, 16 Nov, 13:26
Piotr Nowojski                                                             Re: Flink memory leak Fri, 17 Nov, 10:11
Piotr Nowojski                                                   Re: Flink memory leak Fri, 10 Nov, 14:50
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                                                     Re: Flink memory leak Fri, 10 Nov, 15:01
ÇETİNKAYA EBRU ÇETİNKAYA EBRU                                                       Re: Flink memory leak Fri, 10 Nov, 15:05
Piotr Nowojski                                                         Re: Flink memory leak Fri, 10 Nov, 16:17
Shankara Getting java.lang.ClassNotFoundException: for protobuf generated class Tue, 07 Nov, 14:34
Nico Kruber   Re: Getting java.lang.ClassNotFoundException: for protobuf generated class Mon, 13 Nov, 10:33
Shankara     Re: Getting java.lang.ClassNotFoundException: for protobuf generated class Tue, 14 Nov, 13:54
Nico Kruber   Re: Getting java.lang.ClassNotFoundException: for protobuf generated class Tue, 21 Nov, 09:28
Gordon Weakliem     Re: Getting java.lang.ClassNotFoundException: for protobuf generated class Tue, 21 Nov, 19:31
Nico Kruber       Re: Getting java.lang.ClassNotFoundException: for protobuf generated class Wed, 22 Nov, 09:25
Jared Stehler         Re: Getting java.lang.ClassNotFoundException: for protobuf generated class Wed, 22 Nov, 14:54
Gordon Weakliem           Re: Getting java.lang.ClassNotFoundException: for protobuf generated class Wed, 22 Nov, 15:37
Till Rohrmann Call for responses: Apache Flink user survey 2017 Tue, 07 Nov, 15:04
Till Rohrmann   Re: Call for responses: Apache Flink user survey 2017 Mon, 27 Nov, 13:02
Ivan Budincevic AvroParquetWriter may cause task managers to get lost Tue, 07 Nov, 18:51
Fabian Hueske   Re: AvroParquetWriter may cause task managers to get lost Mon, 13 Nov, 10:49
Nico Kruber   Re: AvroParquetWriter may cause task managers to get lost Mon, 13 Nov, 10:58
vijayakumar palaniappan REST Endpoint for Triggering Savepoint Tue, 07 Nov, 19:01
Chesnay Schepler   Re: REST Endpoint for Triggering Savepoint Tue, 07 Nov, 20:37
Sathya Hariesh Prakash (sathypra) Flink HA Zookeeper Connection Timeout Wed, 08 Nov, 03:02
Nico Kruber   Re: Flink HA Zookeeper Connection Timeout Mon, 13 Nov, 11:08
Patrick Lucas   Re: Flink HA Zookeeper Connection Timeout Tue, 14 Nov, 11:13
马庆祥 Remove the HDFS directory in org.apache.flink.util.FileUtils.deletePathIfEmpty Wed, 08 Nov, 04:25
Aljoscha Krettek   Re: Remove the HDFS directory in org.apache.flink.util.FileUtils.deletePathIfEmpty Wed, 08 Nov, 09:47
yunfan123 What happened if my parallelism more than kafka partitions. Wed, 08 Nov, 07:35
Tzu-Li (Gordon) Tai   Re: What happened if my parallelism more than kafka partitions. Wed, 08 Nov, 09:37
yunfan123     Re: What happened if my parallelism more than kafka partitions. Wed, 08 Nov, 10:38
Tzu-Li (Gordon) Tai       Re: What happened if my parallelism more than kafka partitions. Wed, 08 Nov, 10:57
m@xi Weird performance on custom Hashjoin w.r.t. parallelism Wed, 08 Nov, 14:19
m@xi   Re: Weird performance on custom Hashjoin w.r.t. parallelism Thu, 09 Nov, 06:53
Piotr Nowojski     Re: Weird performance on custom Hashjoin w.r.t. parallelism Thu, 09 Nov, 14:39
Shailesh Jain Generate watermarks per key in a KeyedStream Wed, 08 Nov, 15:48
Xingcan Cui   Re: Generate watermarks per key in a KeyedStream Wed, 08 Nov, 17:12
Shailesh Jain     Re: Generate watermarks per key in a KeyedStream Thu, 09 Nov, 10:52
Derek VerLee       Re: Generate watermarks per key in a KeyedStream Thu, 09 Nov, 21:06
Re: ResultPartitionMetrics
Nico Kruber   Re: ResultPartitionMetrics Wed, 08 Nov, 16:40
Derek VerLee Do timestamps and watermarks exist after window evaluation? Wed, 08 Nov, 17:54
Aljoscha Krettek   Re: Do timestamps and watermarks exist after window evaluation? Thu, 09 Nov, 14:32
Derek VerLee     Re: Do timestamps and watermarks exist after window evaluation? Thu, 09 Nov, 21:02
Vishal Santoshi How to best create a bounded session window ? Wed, 08 Nov, 20:43
Piotr Nowojski   Re: How to best create a bounded session window ? Thu, 09 Nov, 13:24
Vishal Santoshi     Re: How to best create a bounded session window ? Thu, 09 Nov, 14:27
Piotr Nowojski       Re: How to best create a bounded session window ? Thu, 09 Nov, 15:55
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
Dec 2019119
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