flink-user mailing list archives: January 2019

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Re: RuntimeException with valve output watermark when using CoGroup
Taneli Saastamoinen   Re: RuntimeException with valve output watermark when using CoGroup Tue, 01 Jan, 14:01
Till Rohrmann     Re: RuntimeException with valve output watermark when using CoGroup Wed, 02 Jan, 14:23
Avi Levi using updating shared data Tue, 01 Jan, 16:29
miki haiat   Re: using updating shared data Tue, 01 Jan, 17:49
Till Rohrmann     Re: using updating shared data Wed, 02 Jan, 14:27
Avi Levi       Re: using updating shared data Wed, 02 Jan, 16:42
Till Rohrmann         Re: using updating shared data Wed, 02 Jan, 18:19
Elias Levy         Re: using updating shared data Wed, 02 Jan, 19:44
Avi Levi           Re: using updating shared data Thu, 03 Jan, 20:18
David Anderson             Re: using updating shared data Fri, 04 Jan, 09:12
Avi Levi               Re: using updating shared data Sun, 06 Jan, 08:35
Elias Levy                 Re: using updating shared data Sun, 06 Jan, 19:46
Kaibo Zhou Problem when use kafka sink with EXACTLY_ONCE in IDEA Wed, 02 Jan, 04:02
Till Rohrmann   Re: Problem when use kafka sink with EXACTLY_ONCE in IDEA Wed, 02 Jan, 14:41
varuy322 same parallelism with different taskmanager and slots, skew occurs Wed, 02 Jan, 05:05
Till Rohrmann   Re: same parallelism with different taskmanager and slots, skew occurs Wed, 02 Jan, 14:50
varuy322     Re: same parallelism with different taskmanager and slots, skew occurs Thu, 03 Jan, 01:37
Till Rohrmann       Re: same parallelism with different taskmanager and slots, skew occurs Fri, 04 Jan, 13:08
Re: Data loss when restoring from savepoint
Juho Autio   Re: Data loss when restoring from savepoint Wed, 02 Jan, 09:24
Juho Autio     Re: Data loss when restoring from savepoint Fri, 11 Jan, 06:14
Juho Autio       Re: Data loss when restoring from savepoint Thu, 31 Jan, 09:46
Re: How to migrate Kafka Producer ?
Piotr Nowojski   Re: How to migrate Kafka Producer ? Wed, 02 Jan, 09:51
Edward Rojas     Re: How to migrate Kafka Producer ? Mon, 07 Jan, 18:26
Re: 1.6 UI issues
Oleksandr Nitavskyi   Re: 1.6 UI issues Wed, 02 Jan, 09:58
Till Rohrmann     Re: 1.6 UI issues Wed, 02 Jan, 13:34
Oleksandr Nitavskyi       Re: 1.6 UI issues Thu, 10 Jan, 09:08
Till Rohrmann         Re: 1.6 UI issues Thu, 10 Jan, 17:27
Oleksandr Nitavskyi         Re: 1.6 UI issues Sat, 19 Jan, 10:02
Re: Can't list logs or stdout through web console on Flink 1.7 Kubernetes
Joshua Fan   Re: Can't list logs or stdout through web console on Flink 1.7 Kubernetes Wed, 02 Jan, 11:15
Patrick Fial Maintaining message input order in streams with keyBy/filter/connect Wed, 02 Jan, 11:51
张馨予 Are Jobs allowed to be pending when slots are not enough Wed, 02 Jan, 12:59
Till Rohrmann   Re: Are Jobs allowed to be pending when slots are not enough Wed, 02 Jan, 14:57
张馨予     RE: Are Jobs allowed to be pending when slots are not enough Thu, 03 Jan, 06:50
Re: no log exists in JM and TM when updated to Flink 1.7
Till Rohrmann   Re: no log exists in JM and TM when updated to Flink 1.7 Wed, 02 Jan, 14:08
Joshua Fan     Re: no log exists in JM and TM when updated to Flink 1.7 Thu, 03 Jan, 07:36
Re: How to shut down Flink Web Dashboard in detached Yarn session?
Till Rohrmann   Re: How to shut down Flink Web Dashboard in detached Yarn session? Wed, 02 Jan, 14:13
Sai Inampudi     Re: How to shut down Flink Web Dashboard in detached Yarn session? Wed, 02 Jan, 17:31
Till Rohrmann       Re: How to shut down Flink Web Dashboard in detached Yarn session? Wed, 02 Jan, 18:22
Steven Nelson Problem with metrics inside Kubernetes Wed, 02 Jan, 16:19
Derek VerLee   Re: Problem with metrics inside Kubernetes Wed, 02 Jan, 16:37
Re: Flink 1.7 jobmanager tries to lookup taskmanager by its hostname in k8s environment
Derek VerLee   Re: Flink 1.7 jobmanager tries to lookup taskmanager by its hostname in k8s environment Wed, 02 Jan, 16:36
Cliff Resnick Problem building 1.7.1 with scala-2.12 Wed, 02 Jan, 16:48
Chesnay Schepler   Re: Problem building 1.7.1 with scala-2.12 Thu, 03 Jan, 09:45
Cliff Resnick     Re: Problem building 1.7.1 with scala-2.12 Thu, 03 Jan, 17:23
Re: Running Flink on Yarn
Anil   Re: Running Flink on Yarn Wed, 02 Jan, 19:57
Hao Sun Is there a better way to debug ClassNotFoundException from FlinkUserCodeClassLoaders? Wed, 02 Jan, 23:01
qi luo   Re: Is there a better way to debug ClassNotFoundException from FlinkUserCodeClassLoaders? Thu, 03 Jan, 02:04
Hao Sun     Re: Is there a better way to debug ClassNotFoundException from FlinkUserCodeClassLoaders? Thu, 03 Jan, 06:13
Timo Walther       Re: Is there a better way to debug ClassNotFoundException from FlinkUserCodeClassLoaders? Thu, 03 Jan, 09:08
Hao Sun         Re: Is there a better way to debug ClassNotFoundException from FlinkUserCodeClassLoaders? Thu, 03 Jan, 13:58
Congxian Qiu           Re: Is there a better way to debug ClassNotFoundException from FlinkUserCodeClassLoaders? Sat, 05 Jan, 01:42
Hao Sun             Re: Is there a better way to debug ClassNotFoundException from FlinkUserCodeClassLoaders? Sat, 05 Jan, 04:50
Rad Rad Change Window Size during runtime Wed, 02 Jan, 23:54
Chesnay Schepler   Re: Change Window Size during runtime Thu, 03 Jan, 10:29
Congxian Qiu   Re: Change Window Size during runtime Sat, 05 Jan, 01:49
Martin, Nick S3 StreamingFileSink never completes multipart uploads Thu, 03 Jan, 00:00
Addison Higham   Re: S3 StreamingFileSink never completes multipart uploads Fri, 04 Jan, 20:09
Kostas Kloudas     Re: S3 StreamingFileSink never completes multipart uploads Sat, 05 Jan, 06:23
Addison Higham       Re: S3 StreamingFileSink never completes multipart uploads Mon, 07 Jan, 17:13
Kostas Kloudas         Re: S3 StreamingFileSink never completes multipart uploads Mon, 07 Jan, 18:38
miki haiat Flink error reading file over network (Windows) Thu, 03 Jan, 07:26
Chesnay Schepler   Re: Flink error reading file over network (Windows) Thu, 03 Jan, 10:27
Re: Using port ranges to connect with the Flink Client
Joshua Fan   Re: Using port ranges to connect with the Flink Client Thu, 03 Jan, 07:32
Chesnay Schepler     Re: Using port ranges to connect with the Flink Client Fri, 04 Jan, 09:26
Gyula Fóra       Re: Using port ranges to connect with the Flink Client Fri, 04 Jan, 09:28
Joshua Fan         Re: Using port ranges to connect with the Flink Client Mon, 07 Jan, 03:37
Re: Question about Flink optimizer on Stream API
Till Rohrmann   Re: Question about Flink optimizer on Stream API Thu, 03 Jan, 12:28
Wenrui Meng ConnectTimeoutException when createPartitionRequestClient Thu, 03 Jan, 13:59
Till Rohrmann   Re: ConnectTimeoutException when createPartitionRequestClient Fri, 04 Jan, 13:26
Wenrui Meng     Re: ConnectTimeoutException when createPartitionRequestClient Sat, 05 Jan, 01:22
Till Rohrmann       Re: ConnectTimeoutException when createPartitionRequestClient Mon, 07 Jan, 10:37
Wenrui Meng         Re: ConnectTimeoutException when createPartitionRequestClient Tue, 08 Jan, 13:50
Till Rohrmann           Re: ConnectTimeoutException when createPartitionRequestClient Tue, 08 Jan, 15:05
Wenrui Meng             Re: ConnectTimeoutException when createPartitionRequestClient Wed, 09 Jan, 09:40
Till Rohrmann               Re: ConnectTimeoutException when createPartitionRequestClient Wed, 09 Jan, 10:05
Wenrui Meng                 Re: ConnectTimeoutException when createPartitionRequestClient Thu, 10 Jan, 04:33
zhijiang               Re: ConnectTimeoutException when createPartitionRequestClient Thu, 10 Jan, 03:48
Wenrui Meng                 Re: ConnectTimeoutException when createPartitionRequestClient Thu, 10 Jan, 06:28
Re: Flink SQL client always cost 2 minutes to submit job to a local cluster
Fabian Hueske   Re: Flink SQL client always cost 2 minutes to submit job to a local cluster Thu, 03 Jan, 15:11
yinhua.dai     Re: Flink SQL client always cost 2 minutes to submit job to a local cluster Fri, 04 Jan, 03:37
Hequn Cheng       Re: Flink SQL client always cost 2 minutes to submit job to a local cluster Fri, 04 Jan, 07:25
Re: Is there an example of flink cluster "as a job" deployment on k8s ?
Vishal Santoshi   Re: Is there an example of flink cluster "as a job" deployment on k8s ? Thu, 03 Jan, 19:10
Chesnay Schepler     Re: Is there an example of flink cluster "as a job" deployment on k8s ? Thu, 03 Jan, 21:46
Vishal Santoshi       Re: Is there an example of flink cluster "as a job" deployment on k8s ? Fri, 04 Jan, 09:35
yinhua.dai The way to write a UDF with generic type Fri, 04 Jan, 04:18
Chesnay Schepler   Re: The way to write a UDF with generic type Fri, 04 Jan, 09:18
yinhua.dai     Re: The way to write a UDF with generic type Fri, 04 Jan, 09:28
Timo Walther       Re: The way to write a UDF with generic type Fri, 04 Jan, 10:23
yinhua.dai         Re: The way to write a UDF with generic type Mon, 07 Jan, 01:27
Timo Walther           Re: The way to write a UDF with generic type Mon, 07 Jan, 15:34
yinhua.dai             Re: The way to write a UDF with generic type Tue, 08 Jan, 05:41
Timo Walther               Re: The way to write a UDF with generic type Tue, 08 Jan, 10:20
yinhua.dai                 Re: The way to write a UDF with generic type Wed, 09 Jan, 00:21
LINZ, Arnaud Kerberos error when restoring from HDFS backend after 24 hours Fri, 04 Jan, 10:32
LINZ, Arnaud   RE: Kerberos error when restoring from HDFS backend after 24 hours Wed, 09 Jan, 17:45
Puneet Kinra Unable to restore the checkpoint on restarting the application!! Fri, 04 Jan, 13:31
Till Rohrmann   Re: Unable to restore the checkpoint on restarting the application!! Fri, 04 Jan, 13:45
Puneet Kinra     Re: Unable to restore the checkpoint on restarting the application!! Fri, 04 Jan, 13:48
Till Rohrmann       Re: Unable to restore the checkpoint on restarting the application!! Fri, 04 Jan, 14:11
Puneet Kinra         Re: Unable to restore the checkpoint on restarting the application!! Mon, 07 Jan, 10:03
Till Rohrmann           Re: Unable to restore the checkpoint on restarting the application!! Mon, 07 Jan, 10:40
Jeff Zhang Why UDF can not be non-static inner class ? Mon, 07 Jan, 01:22
Timo Walther   Re: Why UDF can not be non-static inner class ? Mon, 07 Jan, 09:33
Jeff Zhang     Re: Why UDF can not be non-static inner class ? Mon, 07 Jan, 09:38
Stephan Ewen       Re: Why UDF can not be non-static inner class ? Mon, 07 Jan, 09:45
Timo Walther         Re: Why UDF can not be non-static inner class ? Mon, 07 Jan, 11:55
jincheng sun       Re: Why UDF can not be non-static inner class ? Wed, 09 Jan, 00:21
Jeff Zhang         Re: Why UDF can not be non-static inner class ? Thu, 10 Jan, 03:07
Gagan Agrawal Buffer stats when Back Pressure is high Mon, 07 Jan, 04:05
zhijiang   Re: Buffer stats when Back Pressure is high Mon, 07 Jan, 09:54
Gagan Agrawal     Re: Buffer stats when Back Pressure is high Mon, 07 Jan, 13:45
Timo Walther       Re: Buffer stats when Back Pressure is high Mon, 07 Jan, 16:51
Gagan Agrawal         Re: Buffer stats when Back Pressure is high Tue, 08 Jan, 09:09
Avi Levi Passing vm options Mon, 07 Jan, 08:01
Dominik Wosiński   Re: Passing vm options Mon, 07 Jan, 15:32
Avi Levi     Re: Passing vm options Wed, 09 Jan, 07:40
Wei Sun Building Flink from source according to vendor-specific version but causes protobuf conflict Mon, 07 Jan, 09:33
Timo Walther   Re: Building Flink from source according to vendor-specific version but causes protobuf conflict Mon, 07 Jan, 17:15
Wei Sun     Re: Building Flink from source according to vendor-specific versionbut causes protobuf conflict Tue, 08 Jan, 04:17
Gary Yao       Re: Building Flink from source according to vendor-specific versionbut causes protobuf conflict Fri, 11 Jan, 08:37
Puneet Kinra onTimer function is not getting executed and job is marked as finished. Mon, 07 Jan, 09:50
Hequn Cheng   Re: onTimer function is not getting executed and job is marked as finished. Mon, 07 Jan, 12:20
Puneet Kinra     Re: onTimer function is not getting executed and job is marked as finished. Mon, 07 Jan, 13:15
Timo Walther       Re: onTimer function is not getting executed and job is marked as finished. Mon, 07 Jan, 16:57
Puneet Kinra         Re: onTimer function is not getting executed and job is marked as finished. Mon, 07 Jan, 17:30
Hequn Cheng           Re: onTimer function is not getting executed and job is marked as finished. Tue, 08 Jan, 01:06
Puneet Kinra             Re: onTimer function is not getting executed and job is marked as finished. Tue, 08 Jan, 03:44
Hequn Cheng               Re: onTimer function is not getting executed and job is marked as finished. Tue, 08 Jan, 13:55
Puneet Kinra                 Re: onTimer function is not getting executed and job is marked as finished. Tue, 08 Jan, 15:28
Niklas Teichmann Reducing runtime of Flink planner Mon, 07 Jan, 13:05
Timo Walther   Re: Reducing runtime of Flink planner Mon, 07 Jan, 16:35
Fabian Hueske     Re: Reducing runtime of Flink planner Thu, 10 Jan, 10:16
Niklas Teichmann       Re: Reducing runtime of Flink planner Thu, 10 Jan, 19:45
徐涛 How to get the temp result of each dynamic table when executing Flink-SQL? Mon, 07 Jan, 15:19
Timo Walther   Re: How to get the temp result of each dynamic table when executing Flink-SQL? Mon, 07 Jan, 15:51
yinhua.dai   Re: How to get the temp result of each dynamic table when executing Flink-SQL? Tue, 08 Jan, 05:45
Hequn Cheng     Re: How to get the temp result of each dynamic table when executing Flink-SQL? Tue, 08 Jan, 14:02
Vishal Santoshi Kafka 2.0 quotas Mon, 07 Jan, 19:17
Vishal Santoshi   Re: Kafka 2.0 quotas Mon, 07 Jan, 19:26
Bruno Aranda Subtask much slower than the others when creating checkpoints Tue, 08 Jan, 11:51
Till Rohrmann   Re: Subtask much slower than the others when creating checkpoints Tue, 08 Jan, 17:35
Pasquale Vazzana     RE: Subtask much slower than the others when creating checkpoints Mon, 14 Jan, 15:07
Till Rohrmann       Re: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 10:32
Bruno Aranda         Re: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 10:42
Stefan Richter           Re: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 11:03
Bruno Aranda             Re: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 11:15
Pasquale Vazzana         RE: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 12:08
Till Rohrmann           Re: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 13:04
Pasquale Vazzana             RE: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 16:05
Jamie Grier               Re: Subtask much slower than the others when creating checkpoints Tue, 15 Jan, 18:58
Pasquale Vazzana                 RE: Subtask much slower than the others when creating checkpoints Wed, 16 Jan, 08:56
Steven Wu                   Re: Subtask much slower than the others when creating checkpoints Wed, 16 Jan, 14:23
Pasquale Vazzana                     RE: Subtask much slower than the others when creating checkpoints Wed, 16 Jan, 17:07
Gaurav Luthra Counter Metrics not getting removed from Flink GUI after close() Tue, 08 Jan, 16:08
Chesnay Schepler   Re: Counter Metrics not getting removed from Flink GUI after close() Tue, 08 Jan, 16:11
Gaurav Luthra     Re: Counter Metrics not getting removed from Flink GUI after close() Tue, 08 Jan, 16:24
Chesnay Schepler       Re: Counter Metrics not getting removed from Flink GUI after close() Tue, 08 Jan, 17:31
Gaurav Luthra         Re: Counter Metrics not getting removed from Flink GUI after close() Wed, 09 Jan, 01:12
sohimankotia Flink Streaming Job Task is getting cancelled silently and causing job to restart Wed, 09 Jan, 11:02
Stefan Richter   Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Wed, 09 Jan, 14:56
sohimankotia     Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Wed, 09 Jan, 16:33
sohimankotia       Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Tue, 15 Jan, 06:49
Andrey Zagrebin         Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Wed, 16 Jan, 11:11
sohimankotia           Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Wed, 16 Jan, 12:37
Andrey Zagrebin             Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Wed, 16 Jan, 18:03
sohimankotia               Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Thu, 17 Jan, 03:20
sohimankotia                 Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Mon, 21 Jan, 07:24
sohimankotia                   Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Sun, 27 Jan, 09:13
Erik van Oosten                     Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart Sun, 27 Jan, 09:30
Robert Schmidtke Long wait / block times for buffer builder Wed, 09 Jan, 11:12
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
May 2019331
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