flink-user mailing list archives: January 2019

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