flink-user mailing list archives: September 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · Next »Thread · Author · Date
廖嘉逸 Can rocksDBBackend handle rescaling? Thu, 13 Sep, 17:50
杨光 How to get the location of keytab when using flink on yarn Thu, 20 Sep, 09:20
杨光 Re: How to get the location of keytab when using flink on yarn Wed, 26 Sep, 02:31
杨力 Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed. Fri, 07 Sep, 05:08
杨力 Re: Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed. Fri, 07 Sep, 13:27
杨力 Re: Can rocksDBBackend handle rescaling? Thu, 13 Sep, 18:03
杨力 Re: CombinableGroupReducer says The Iterable can be iterated over only once Fri, 14 Sep, 15:29
杨力 Re: JMX Configuration: Missing Job Related Beans Mon, 24 Sep, 10:53
朱翥 Re: JobManager in HA with a single node loses leadership Fri, 28 Sep, 02:06
远远 why same Sliding ProcessTime TimeWindow triggered twice Sun, 16 Sep, 07:19
远远 Fwd: why same Sliding ProcessTime TimeWindow triggered twice Sun, 16 Sep, 08:23
远远 Re: [DISCUSS] Dropping flink-storm? Sat, 29 Sep, 06:16
陈梓立 Does Flink plan to support JDK 9 recently? Sat, 01 Sep, 02:50
陈梓立 How to simulate a blocking (sink) node? Thu, 06 Sep, 02:30
陈梓立 Re: Setting Flink Monitoring API Port on YARN Cluster Thu, 06 Sep, 22:59
陈梓立 How to customize schedule mode and result partition type? Fri, 07 Sep, 00:59
陈梓立 Re: How to customize schedule mode and result partition type? Fri, 07 Sep, 10:25
陈梓立 Re: Question about akka configuration for FLIP-6 Mon, 10 Sep, 06:20
陈梓立 Re: Which mode to choose flink on Yarn. Thu, 20 Sep, 06:23
陈梓立 Re: Which mode to choose flink on Yarn. Thu, 20 Sep, 06:35
Zhijiang(wangzhijiang999) 回复:Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed. Fri, 07 Sep, 07:22
Zhijiang(wangzhijiang999) 回复:Flink application down due to RpcTimeout exception Thu, 13 Sep, 06:37
Zhijiang(wangzhijiang999) 回复:InpoolUsage & InpoolBuffers inconsistence Tue, 18 Sep, 06:29
Zhijiang(wangzhijiang999) 回复:回复:InpoolUsage & InpoolBuffers inconsistence Tue, 18 Sep, 09:39
Zhijiang(wangzhijiang999) 回复:[DISCUSS] Dropping flink-storm? Sat, 29 Sep, 05:53
Björn Ebbinghaus twitter source is shutting down after successfull connect Sun, 16 Sep, 15:43
Gyula Fóra Re: 1.5 Checkpoint metadata location Tue, 25 Sep, 15:24
françois lacombe Missing Calcite SQL functions in table API Wed, 05 Sep, 10:22
françois lacombe Re: Missing Calcite SQL functions in table API Thu, 06 Sep, 12:41
何春平 flink use hdfs DistributedCache Sun, 02 Sep, 09:07
何春平 回复: flink use hdfs DistributedCache Mon, 03 Sep, 02:34
徐涛 Flink application down due to RpcTimeout exception Thu, 13 Sep, 06:10
徐涛 In which case the StreamNode has multiple output edges? Tue, 18 Sep, 02:34
徐涛 Why FlinkKafkaConsumer08 does not support exactly once or at least once semantic? Thu, 20 Sep, 08:48
徐涛 Re: In which case the StreamNode has multiple output edges? Thu, 20 Sep, 08:53
徐涛 Re: Why FlinkKafkaConsumer08 does not support exactly once or at least once semantic? Thu, 20 Sep, 09:57
徐涛 How to join stream and batch data in Flink? Fri, 21 Sep, 08:43
徐涛 When should the RETAIN_ON_CANCELLATION option be used? Tue, 25 Sep, 02:41
徐涛 Re: When should the RETAIN_ON_CANCELLATION option be used? Tue, 25 Sep, 03:06
徐涛 Re: When should the RETAIN_ON_CANCELLATION option be used? Tue, 25 Sep, 04:56
徐涛 Strange behavior of FsStateBackend checkpoint when local executing Tue, 25 Sep, 06:43
徐涛 Re: When should the RETAIN_ON_CANCELLATION option be used? Tue, 25 Sep, 06:59
徐涛 "405 HTTP method POST is not supported by this URL" is returned when POST a REST url on Flink on yarn Tue, 25 Sep, 07:43
徐涛 Re: How to join stream and batch data in Flink? Tue, 25 Sep, 09:10
徐涛 Re: How to join stream and batch data in Flink? Tue, 25 Sep, 09:48
徐涛 Re: "405 HTTP method POST is not supported by this URL" is returned when POST a REST url on Flink on yarn Wed, 26 Sep, 01:23
徐涛 LIMIT and ORDER BY in hop window is not supported? Thu, 27 Sep, 13:05
徐涛 Re: LIMIT and ORDER BY in hop window is not supported? Fri, 28 Sep, 01:38
徐涛 Does Flink SQL "in" operation has length limit? Fri, 28 Sep, 08:22
郑舒力 How to get taskmanager hostname and port on runtime Thu, 13 Sep, 04:07
郑舒力 Re: How to get taskmanager hostname and port on runtime Mon, 17 Sep, 09:40
devinduan(段丁瑞) Cancel flink job occur exception. Tue, 04 Sep, 12:18
devinduan(段丁瑞) 回复: Client failed to get cancel with savepoint response(Internet mail) Fri, 14 Sep, 02:49
rileyli(李瑞亮) Cancel flink job occur exception Tue, 04 Sep, 12:21
潘 功森 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Wed, 05 Sep, 05:27
潘 功森 答复: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Wed, 05 Sep, 08:00
孙森 cannot catch flink runtime exception Wed, 05 Sep, 03:56
孙森 Re: cannot catch flink runtime exception Thu, 06 Sep, 02:38
孙森 Re: cannot catch flink runtime exception Thu, 06 Sep, 02:42
祁明良 Flink on kubernetes Mon, 03 Sep, 08:08
祁明良 Re: Flink on kubernetes Mon, 03 Sep, 09:46
bupt_ljy Cannot set classpath which can be used before job is submitted to yarn. Thu, 06 Sep, 15:01
bupt_ljy Re: Cannot set classpath which can be used before job is submitted to yarn. Fri, 07 Sep, 03:31
bupt_ljy Deadlock in SafetyNetCloseableRegistry? Tue, 11 Sep, 14:22
bupt_ljy Re: Deadlock in SafetyNetCloseableRegistry? Tue, 11 Sep, 15:50
bupt_ljy What is the right way to add classpath? Wed, 12 Sep, 08:34
bupt_ljy Re: What is the right way to add classpath? Wed, 12 Sep, 09:57
bupt_ljy Re: Can rocksDBBackend handle rescaling? Thu, 13 Sep, 18:29
Dominik Wosiński ODP: API for delayed/scheduled interval input source for integrationtests Sat, 01 Sep, 16:01
Dominik Wosiński ODP: How to add jvm Options when using Flink dashboard? Wed, 05 Sep, 09:45
Jörn Franke Re: Checkpointing not working Wed, 19 Sep, 06:37
? ?? Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Tue, 04 Sep, 14:06
Ahmad Hassan Flink Checkpointing in production Wed, 12 Sep, 08:38
Ahmed RocksDB Number of Keys Metric Sat, 01 Sep, 18:31
Alejandro Compute Symmetrical Uncertainty in parallel Fri, 14 Sep, 10:55
Alejandro Re: CombinableGroupReducer says The Iterable can be iterated over only once Fri, 14 Sep, 16:52
Alejandro Measure task execution time Wed, 26 Sep, 08:16
Alejandro Alcalde CombinableGroupReducer says The Iterable can be iterated over only once Fri, 14 Sep, 14:53
Alejandro Alcalde Get last element of a DataSe Tue, 25 Sep, 10:55
Alejandro Alcalde Re: Get last element of a DataSe Tue, 25 Sep, 14:06
Alexander Smirnov ArrayIndexOutOfBoundsException Tue, 25 Sep, 14:37
Alexander Smirnov Re: ArrayIndexOutOfBoundsException Tue, 25 Sep, 14:53
Alexander Smirnov Re: ArrayIndexOutOfBoundsException Tue, 25 Sep, 15:50
Alexey Trenikhun ListState<T> - elements order Thu, 06 Sep, 02:55
Alexey Trenikhun Re: ListState<T> - elements order Fri, 14 Sep, 11:05
Aljoscha Krettek Re: StreamingFileSink with PrestoFS? Thu, 13 Sep, 12:53
Aljoscha Krettek Re: Test harness for validating proper checkpointing of custom SourceFunction Thu, 13 Sep, 12:56
Aljoscha Krettek Re: [Kerberos] JAAS module content not generated? javax.security.auth.callback.UnsupportedCallbackException: Could not login: the client is being asked for a password, but the Kafka client code does not currently support obtaining a password from the user. Thu, 13 Sep, 14:17
Aljoscha Krettek Re: ListState<T> - elements order Thu, 13 Sep, 14:42
Aljoscha Krettek Re: How to get the location of keytab when using flink on yarn Thu, 20 Sep, 13:44
Ananth Durai Flink Scheduler Customization Sat, 29 Sep, 19:11
Andrea Spina Flink 1.3.2 RocksDB map segment fail if configured as state backend Mon, 17 Sep, 09:37
Andrea Spina Re: Flink 1.3.2 RocksDB map segment fail if configured as state backend Tue, 18 Sep, 16:33
Andrew Kowpak Should Queryable State Server be listening on 127.0.1.1? Tue, 25 Sep, 12:13
Andrey Zagrebin Re: RocksDB Number of Keys Metric Thu, 06 Sep, 09:45
Andrey Zagrebin Re: Aggregator State in Keyed Windowed Stream Mon, 10 Sep, 13:40
Andrey Zagrebin Re: Can rocksDBBackend handle rescaling? Fri, 14 Sep, 13:01
Andrey Zagrebin Re: Window operator schema evolution - savepoint deserialization fail Fri, 14 Sep, 13:45
Andrey Zagrebin Re: Window operator schema evolution - savepoint deserialization fail Mon, 17 Sep, 09:22
Andrey Zagrebin Re: Data loss when restoring from savepoint Fri, 21 Sep, 12:29
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · Next »Thread · Author · Date
Box list
May 2019362
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