flink-user mailing list archives: October 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
wpb How can I set the Flink Job Id to enable flink checkpoint Wed, 03 Oct, 06:10
张炜 link on yarn error “Yarn only has -1 virtual cores available” Tue, 23 Oct, 04:52
曹建华 Gelly Scatter-Gather Iteration, In a single superstep, GatherFunction.updateVertex invoked more then once Mon, 22 Oct, 08:33
远远 cannot resolve constructor when invoke FlinkKafkaProducer011 constructor in scala Wed, 10 Oct, 09:51
远远 Re: cannot resolve constructor when invoke FlinkKafkaProducer011 constructor in scala Wed, 10 Oct, 10:00
Zhang, Xuefu [DISCUSS] Integrate Flink SQL well with Hive ecosystem Tue, 09 Oct, 17:22
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Thu, 11 Oct, 03:01
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Thu, 11 Oct, 17:31
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Thu, 11 Oct, 20:44
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Thu, 11 Oct, 21:04
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Fri, 12 Oct, 04:43
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Mon, 15 Oct, 19:10
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Mon, 15 Oct, 19:40
Zhang, Xuefu Re: Java Table API and external catalog bug? Mon, 22 Oct, 17:26
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Wed, 24 Oct, 17:08
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Tue, 30 Oct, 18:32
Zhang, Xuefu Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Wed, 31 Oct, 19:15
Zhijiang(wangzhijiang999) 回复:Memory Allocate/Deallocate related Thread Deadlock encountered when running a large job > 10k tasks Mon, 08 Oct, 08:08
Zhijiang(wangzhijiang999) 回复:Small checkpoint data takes too much time Wed, 10 Oct, 05:26
Zhijiang(wangzhijiang999) 回复:What are channels mapped to? Thu, 11 Oct, 09:13
Zhijiang(wangzhijiang999) 回复:Need help to understand memory consumption Wed, 17 Oct, 05:39
Zhijiang(wangzhijiang999) 回复:Need help to understand memory consumption Wed, 17 Oct, 06:53
Bariša Wondering how to check if taskmanager is registered with the jobmanager, without asking job manager Tue, 09 Oct, 10:21
Bariša Re: Wondering how to check if taskmanager is registered with the jobmanager, without asking job manager Wed, 10 Oct, 08:28
Dominik Wosiński Re: Duplicates in self join Mon, 08 Oct, 07:35
Dominik Wosiński Re: Making calls to external API wit Data Streams Fri, 12 Oct, 14:21
Dominik Wosiński Re: Making calls to external API wit Data Streams Fri, 12 Oct, 14:37
Dominik Wosiński Re: Mapstatedescriptor Sat, 13 Oct, 08:30
Dominik Wosiński Re: KafkaException or ExecutionStateChange failure on job startup Tue, 23 Oct, 13:41
Dominik Wosiński Re: Kafka connector error: This server does not host this topic-partition Tue, 23 Oct, 13:47
Dominik Wosiński Re: Manual trigger the window in fold operator or incremental aggregation Wed, 24 Oct, 07:53
Gyula Fóra Re: Ship compiled code with broadcast stream ? Tue, 09 Oct, 08:03
Gyula Fóra Re: Ship compiled code with broadcast stream ? Tue, 09 Oct, 13:29
Gyula Fóra Re: Take RocksDB state dump Wed, 17 Oct, 20:29
徐涛 Small checkpoint data takes too much time Wed, 10 Oct, 05:13
徐涛 Re: Small checkpoint data takes too much time Thu, 11 Oct, 11:22
徐涛 Questions in sink exactly once implementation Fri, 12 Oct, 09:20
徐涛 Re: Questions in sink exactly once implementation Sat, 13 Oct, 12:49
徐涛 Checkpoint acknowledge takes too long Wed, 24 Oct, 09:02
徐涛 Task manager count goes the expand then converge process when running flink on YARN Wed, 24 Oct, 15:26
徐涛 Task manager count goes the expand then converge process when running flink on YARN Wed, 24 Oct, 15:26
徐涛 Re: Checkpoint acknowledge takes too long Thu, 25 Oct, 11:34
徐涛 How to tune Hadoop version in flink shaded jar to Hadoop version actually used? Thu, 25 Oct, 14:27
徐涛 Re: How to tune Hadoop version in flink shaded jar to Hadoop version actually used? Mon, 29 Oct, 15:23
徐涛 Re: How to tune Hadoop version in flink shaded jar to Hadoop version actually used? Wed, 31 Oct, 01:24
徐涛 Re: "405 HTTP method POST is not supported by this URL" is returned when POST a REST url on Flink on yarn Wed, 31 Oct, 01:30
徐涛 Re: Savepoint failed with error "Checkpoint expired before completing" Wed, 31 Oct, 06:06
徐涛 Re: "405 HTTP method POST is not supported by this URL" is returned when POST a REST url on Flink on yarn Wed, 31 Oct, 06:16
徐涛 Wired behavior of DATE_FORMAT UDF in Flink SQL Wed, 31 Oct, 06:44
徐涛 Flink SQL string literal does not support double quotation? Wed, 31 Oct, 11:51
徐涛 Flink SQL string literal does not support double quotation? Wed, 31 Oct, 11:53
郑舒力 Cancel with savepoint on yarn-cluster mode can't retrieve savepointDir. Fri, 19 Oct, 06:32
潘 功森 答复: No data issued by flink window after a few hours Wed, 10 Oct, 03:02
潘 功森 答复: No data issued by flink window after a few hours Wed, 10 Oct, 06:44
潘 功森 答复: No data issued by flink window after a few hours Thu, 11 Oct, 04:12
潘 功森 答复: No data issued by flink window after a few hours Fri, 12 Oct, 02:54
潘 功森 答复: 答复: No data issued by flink window after a few hours Fri, 12 Oct, 02:54
潘 功森 答复: No data issued by flink window after a few hours Fri, 12 Oct, 03:05
潘 功森 答复: No data issued by flink window after a few hours Fri, 12 Oct, 03:10
潘 功森 答复: No data issued by flink window after a few hours Fri, 12 Oct, 05:49
潘 功森 答复: No data issued by flink window after a few hours Fri, 12 Oct, 06:05
潘 功森 答复: No data issued by flink window after a few hours Mon, 15 Oct, 06:30
bupt_ljy How do I initialize the window state on first run? Fri, 12 Oct, 05:59
bupt_ljy Re: How do I initialize the window state on first run? Fri, 12 Oct, 07:33
bupt_ljy Re: How do I initialize the window state on first run? Fri, 12 Oct, 13:50
bupt_ljy Re: How do I initialize the window state on first run? Fri, 19 Oct, 04:57
bupt_ljy Re: Queryable state when key is UUID - getting Kyro Exception Thu, 25 Oct, 08:43
bupt_ljy Re: Queryable state when key is UUID - getting Kyro Exception Thu, 25 Oct, 09:31
bupt_ljy Re: Queryable state when key is UUID - getting Kyro Exception Fri, 26 Oct, 02:48
bupt_ljy Re: Unbalanced Kafka consumer consumption Tue, 30 Oct, 08:36
bupt_ljy Re: Queryable state when key is UUID - getting Kyro Exception Tue, 30 Oct, 08:43
Jörn Franke Re: How to use a thin jar instead of a fat jar? Wed, 03 Oct, 12:22
Jörn Franke Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Thu, 11 Oct, 05:54
Jörn Franke Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem Fri, 12 Oct, 07:37
Jörn Franke Re: Flink 1.4: Queryable State Client Sun, 14 Oct, 07:46
Jörn Franke Re: Could not connect to flink on Amazon EC2 Tue, 23 Oct, 12:40
? ?? No data issued by flink window after a few hours Wed, 10 Oct, 02:37
Aaron Levin Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Fri, 19 Oct, 18:06
Aaron Levin Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Wed, 24 Oct, 14:42
Aaron Levin Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Fri, 26 Oct, 13:55
Abdul Qadeer Taskmanager times out continuously for registration with Jobmanager Thu, 11 Oct, 01:05
Abdul Qadeer Re: Taskmanager times out continuously for registration with Jobmanager Thu, 11 Oct, 18:15
Abdul Qadeer Re: Taskmanager times out continuously for registration with Jobmanager Fri, 12 Oct, 07:43
Abdul Qadeer Re: Taskmanager times out continuously for registration with Jobmanager Fri, 12 Oct, 21:27
Ahmad Hassan getRuntimeContext(): The runtime context has not been initialized. Tue, 09 Oct, 15:09
Ahmad Hassan Re: getRuntimeContext(): The runtime context has not been initialized. Thu, 11 Oct, 09:33
Ahmad Hassan Re: getRuntimeContext(): The runtime context has not been initialized. Thu, 11 Oct, 12:22
Ahmad Hassan Re: getRuntimeContext(): The runtime context has not been initialized. Fri, 12 Oct, 14:30
Ahmad Hassan Re: Manual trigger the window in fold operator or incremental aggregation Wed, 17 Oct, 12:18
Ahmad Hassan Initializing mapstate hangs Fri, 19 Oct, 15:32
Ahmad Hassan Re: Initializing mapstate hangs Sat, 20 Oct, 08:24
Ahmad Hassan Re: Initializing mapstate hangs Mon, 22 Oct, 12:48
Ahmad Hassan Re: Initializing mapstate hangs Tue, 23 Oct, 09:35
Alexander Smirnov Re: Initializing mapstate hangs Mon, 22 Oct, 13:15
Alexander Smirnov Kafka connector error: This server does not host this topic-partition Tue, 23 Oct, 13:04
Alexander Smirnov Re: Kafka connector error: This server does not host this topic-partition Tue, 23 Oct, 15:25
Alexey Trenikhun Event timers - metrics Tue, 02 Oct, 01:44
Alexey Trenikhun Re: Event timers - metrics Tue, 02 Oct, 15:40
Aljoscha Krettek Re: [DISCUSS] Dropping flink-storm? Tue, 02 Oct, 11:15
Aljoscha Krettek Re: How can I set the Flink Job Id to enable flink checkpoint Thu, 04 Oct, 11:50
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Box list
Aug 2019521
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