flink-user mailing list archives: September 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Re: Low Performance in High Cardinality Big Window Application
Ning Shi   Re: Low Performance in High Cardinality Big Window Application Sat, 01 Sep, 01:55
陈梓立 Does Flink plan to support JDK 9 recently? Sat, 01 Sep, 02:50
Chesnay Schepler   Re: Does Flink plan to support JDK 9 recently? Sun, 02 Sep, 12:58
Eric L Goodman multiple input streams Sat, 01 Sep, 03:46
Hequn Cheng   Re: multiple input streams Sat, 01 Sep, 15:00
Re: API for delayed/scheduled interval input source for integration tests
Yee-Ning Cheng   Re: API for delayed/scheduled interval input source for integration tests Sat, 01 Sep, 04:20
Hequn Cheng     Re: API for delayed/scheduled interval input source for integration tests Sat, 01 Sep, 15:17
Dominik Wosiński       ODP: API for delayed/scheduled interval input source for integrationtests Sat, 01 Sep, 16:01
Yee-Ning Cheng         Re: ODP: API for delayed/scheduled interval input source for integrationtests Sat, 01 Sep, 19:45
Nicos Maris           Re: ODP: API for delayed/scheduled interval input source for integrationtests Sat, 01 Sep, 21:15
Ahmed RocksDB Number of Keys Metric Sat, 01 Sep, 18:31
vino yang   Re: RocksDB Number of Keys Metric Tue, 04 Sep, 03:49
Andrey Zagrebin     Re: RocksDB Number of Keys Metric Thu, 06 Sep, 09:45
Re: WriteTimeoutException in Cassandra sink kill the job
Yee-Ning Cheng   Re: WriteTimeoutException in Cassandra sink kill the job Sat, 01 Sep, 19:56
Jayant Ameta   Re: WriteTimeoutException in Cassandra sink kill the job Tue, 11 Sep, 04:45
HarshithBolar     Re: WriteTimeoutException in Cassandra sink kill the job Tue, 11 Sep, 09:50
Jayant Ameta     Re: WriteTimeoutException in Cassandra sink kill the job Thu, 20 Sep, 05:16
Re: FoldFunction accumulator checkpointing
Mar_zieh   Re: FoldFunction accumulator checkpointing Sun, 02 Sep, 05:56
Rong Rong     Re: Cannot compile Wikipedia Edit Stream example Sun, 02 Sep, 15:49
Hequn Cheng     Re: FoldFunction accumulator checkpointing Mon, 03 Sep, 01:39
何春平 flink use hdfs DistributedCache Sun, 02 Sep, 09:07
Rong Rong   Re: flink use hdfs DistributedCache Sun, 02 Sep, 16:02
何春平     回复: flink use hdfs DistributedCache Mon, 03 Sep, 02:34
Yee-Ning Cheng KafkaTopicPartition internal class treated as generic type serialization Sun, 02 Sep, 22:00
Averell Promethus - custom metrics at job level Mon, 03 Sep, 06:22
Reza Sameei   Re: Promethus - custom metrics at job level Mon, 03 Sep, 07:57
Averell     Re: Promethus - custom metrics at job level Mon, 03 Sep, 12:10
James (Jian Wu) [FDS Data Platform] Flink on Yarn, restart job will not destroy original task manager Mon, 03 Sep, 07:20
Gary Yao   Re: Flink on Yarn, restart job will not destroy original task manager Mon, 03 Sep, 07:57
James (Jian Wu) [FDS Data Platform]     Re: Flink on Yarn, restart job will not destroy original task manager Mon, 03 Sep, 08:13
James (Jian Wu) [FDS Data Platform]       Re: Flink on Yarn, restart job will not destroy original task manager Tue, 04 Sep, 03:42
Gary Yao         Re: Flink on Yarn, restart job will not destroy original task manager Tue, 04 Sep, 05:22
clay4444 Rolling File Sink Exception Mon, 03 Sep, 07:30
Chesnay Schepler   Re: Rolling File Sink Exception Mon, 03 Sep, 08:10
祁明良 Flink on kubernetes Mon, 03 Sep, 08:08
Lasse Nedergaard   Re: Flink on kubernetes Mon, 03 Sep, 09:42
祁明良     Re: Flink on kubernetes Mon, 03 Sep, 09:46
Lasse Nedergaard       Re: Flink on kubernetes Mon, 03 Sep, 09:54
Re: CompletedCheckpoints are getting Stale ( Flink 1.4.2 )
Stephan Ewen   Re: CompletedCheckpoints are getting Stale ( Flink 1.4.2 ) Mon, 03 Sep, 09:37
Re: Can't access Flink Dashboard at 8081, running Flink program using Eclipse
Mar_zieh   Re: Can't access Flink Dashboard at 8081, running Flink program using Eclipse Mon, 03 Sep, 10:12
Chesnay Schepler     Re: Can't access Flink Dashboard at 8081, running Flink program using Eclipse Mon, 03 Sep, 11:01
Parth Sarathy Flink 1.5.2 query Mon, 03 Sep, 12:37
Chesnay Schepler   Re: Flink 1.5.2 query Mon, 03 Sep, 13:02
Sarathy, Parth     RE: Flink 1.5.2 query Mon, 03 Sep, 13:21
Chesnay Schepler       Re: Flink 1.5.2 query Wed, 05 Sep, 07:34
Julio Biason Why FlinkKafkaConsumer doesn't subscribe to topics? Mon, 03 Sep, 19:08
Renjie Liu   Re: Why FlinkKafkaConsumer doesn't subscribe to topics? Tue, 04 Sep, 03:47
Julio Biason     Re: Why FlinkKafkaConsumer doesn't subscribe to topics? Tue, 04 Sep, 12:25
Tzu-Li (Gordon) Tai       Re: Why FlinkKafkaConsumer doesn't subscribe to topics? Tue, 04 Sep, 15:43
Renjie Liu         Re: Why FlinkKafkaConsumer doesn't subscribe to topics? Thu, 06 Sep, 23:04
Sameer W JAXB Classloading errors when using PMML Library (AWS EMR Flink 1.4.2) Tue, 04 Sep, 01:24
Gary Yao   Re: JAXB Classloading errors when using PMML Library (AWS EMR Flink 1.4.2) Tue, 11 Sep, 11:30
Re: Get stream of rejected data from Elasticsearch6 sink
vino yang   Re: Get stream of rejected data from Elasticsearch6 sink Tue, 04 Sep, 03:42
Re: This server is not the leader for that topic-partition
Jayant Ameta   Re: This server is not the leader for that topic-partition Tue, 04 Sep, 04:32
vino yang     Re: This server is not the leader for that topic-partition Tue, 04 Sep, 04:46
Jayant Ameta       Re: This server is not the leader for that topic-partition Tue, 04 Sep, 05:19
vino yang         Re: This server is not the leader for that topic-partition Tue, 04 Sep, 06:28
Darshan Singh Queryable State Tue, 04 Sep, 08:44
Darshan Singh   Queryable State Wed, 05 Sep, 11:26
Sameer Wadkar     Re: Queryable State Wed, 05 Sep, 13:13
Paul Lam Failed to trigger savepoint Tue, 04 Sep, 10:02
Chesnay Schepler   Re: Failed to trigger savepoint Tue, 04 Sep, 10:13
devinduan(段丁瑞) Cancel flink job occur exception. Tue, 04 Sep, 12:18
rileyli(李瑞亮) Cancel flink job occur exception Tue, 04 Sep, 12:21
Gary Yao   Re: Cancel flink job occur exception Sun, 09 Sep, 05:18
Ask about running multiple jars for different stream jobs
Rad Rad   Ask about running multiple jars for different stream jobs Tue, 04 Sep, 13:11
Rad Rad   Ask about running multiple jars for different stream jobs Tue, 04 Sep, 13:13
Chesnay Schepler     Re: Ask about running multiple jars for different stream jobs Wed, 05 Sep, 07:26
Rad Rad       Re: Ask about running multiple jars for different stream jobs Thu, 06 Sep, 14:56
Rad Rad   Ask about running multiple jars for different stream jobs Tue, 04 Sep, 14:07
vino yang     Re: Ask about running multiple jars for different stream jobs Wed, 05 Sep, 02:40
Rad Rad     Re: Ask about running multiple jars for different stream jobs Thu, 06 Sep, 14:57
Chang Liu org.apache.flink.util.FlinkException: Could not cancel job Tue, 04 Sep, 13:48
Chesnay Schepler   Re: org.apache.flink.util.FlinkException: Could not cancel job Tue, 04 Sep, 16:06
Chang Liu     Re: org.apache.flink.util.FlinkException: Could not cancel job Thu, 06 Sep, 06:55
? ?? Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Tue, 04 Sep, 14:06
vino yang   Re: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Wed, 05 Sep, 02:35
潘 功森     答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Wed, 05 Sep, 05:27
Chesnay Schepler       Re: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Wed, 05 Sep, 07:23
潘 功森       答复: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Wed, 05 Sep, 08:00
Till Rohrmann         Re: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error Fri, 07 Sep, 15:52
Re: akka.ask.timeout setting not honored
Greg Finch   Re: akka.ask.timeout setting not honored Tue, 04 Sep, 21:47
flink list and flink run commands timeout
Jason Kania   flink list and flink run commands timeout Tue, 04 Sep, 22:53
Chesnay Schepler     Re: flink list and flink run commands timeout Wed, 05 Sep, 07:41
Jason Kania       Re: flink list and flink run commands timeout Wed, 05 Sep, 15:35
Gary Yao         Re: flink list and flink run commands timeout Thu, 06 Sep, 05:15
孙森 cannot catch flink runtime exception Wed, 05 Sep, 03:56
Chesnay Schepler   Re: cannot catch flink runtime exception Wed, 05 Sep, 07:43
孙森     Re: cannot catch flink runtime exception Thu, 06 Sep, 02:38
Rong Rong   Re: cannot catch flink runtime exception Wed, 05 Sep, 23:12
孙森     Re: cannot catch flink runtime exception Thu, 06 Sep, 02:42
Re: Taskmanager process memory increasing always
Yan Zhou [FDS Science]   Re: Taskmanager process memory increasing always Wed, 05 Sep, 05:22
YennieChen88     Re: Taskmanager process memory increasing always Thu, 06 Sep, 05:57
HarshithBolar Does Flink support keyed watermarks? If not, is there any plan of implementing it soon? What are my alternatives? Wed, 05 Sep, 07:50
HarshithBolar Does Flink support keyed watermarks? If not, is there any plan of implementing it in future versions? What are my alternatives? Wed, 05 Sep, 07:57
HarshithBolar Does Flink support keyed watermarks? Wed, 05 Sep, 08:06
zpp How to add jvm Options when using Flink dashboard? Wed, 05 Sep, 09:41
Chesnay Schepler   Re: How to add jvm Options when using Flink dashboard? Wed, 05 Sep, 09:43
Dominik Wosiński     ODP: How to add jvm Options when using Flink dashboard? Wed, 05 Sep, 09:45
françois lacombe Missing Calcite SQL functions in table API Wed, 05 Sep, 10:22
Fabian Hueske   Re: Missing Calcite SQL functions in table API Wed, 05 Sep, 10:30
françois lacombe     Re: Missing Calcite SQL functions in table API Thu, 06 Sep, 12:41
jelmer AskTimeoutException when canceling job with savepoint on flink 1.6.0 Wed, 05 Sep, 12:48
vino yang   Re: AskTimeoutException when canceling job with savepoint on flink 1.6.0 Thu, 06 Sep, 02:24
Gary Yao     Re: AskTimeoutException when canceling job with savepoint on flink 1.6.0 Thu, 06 Sep, 04:58
Re: Flink parquet read.write performance
clay4444   Re: Flink parquet read.write performance Wed, 05 Sep, 14:06
Miguel Coimbra REST: reading completed jobs' details Wed, 05 Sep, 15:39
Chesnay Schepler   Re: REST: reading completed jobs' details Wed, 05 Sep, 17:40
Miguel Coimbra     Re: REST: reading completed jobs' details Wed, 05 Sep, 18:59
Chesnay Schepler       Re: REST: reading completed jobs' details Wed, 05 Sep, 19:18
Miguel Coimbra         Re: REST: reading completed jobs' details Thu, 06 Sep, 16:24
Chesnay Schepler           Re: REST: reading completed jobs' details Thu, 06 Sep, 16:57
Miguel Coimbra             Re: REST: reading completed jobs' details Thu, 06 Sep, 17:35
Bryant Baltes numRunningJobs metric Wed, 05 Sep, 17:58
Chesnay Schepler   Re: numRunningJobs metric Wed, 05 Sep, 19:11
Bryant Baltes     Re: numRunningJobs metric Wed, 05 Sep, 19:17
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
May 2019354
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