flink-user mailing list archives: April 2018

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Fabian Hueske Re: Tracking deserialization errors Mon, 16 Apr, 11:42
Fabian Hueske Re: Kafka consumer to sync topics by event time? Mon, 16 Apr, 12:14
Fabian Hueske Re: Unable to launch job with 100 SQL queries in yarn cluster Mon, 16 Apr, 12:33
Fabian Hueske Re: How to rebalance a table without converting to dataset Mon, 16 Apr, 12:41
Fabian Hueske Re: User-defined aggregation function and parallelism Mon, 16 Apr, 12:54
Fabian Hueske Re: Kafka consumer to sync topics by event time? Mon, 16 Apr, 13:48
Fabian Hueske Re: Annotation in UDF dropped Mon, 16 Apr, 16:22
Fabian Hueske Re: Question about parallelism Mon, 16 Apr, 20:11
Fabian Hueske Re: State-machine-based search logic in Flink ? Tue, 17 Apr, 10:40
Fabian Hueske Re: assign time attribute after first window group when using Flink SQL Wed, 18 Apr, 07:44
Fabian Hueske Re: why doesn't the over-window-aggregation sort the element(considering watermark) before processing? Wed, 18 Apr, 08:04
Fabian Hueske Re: State-machine-based search logic in Flink ? Wed, 18 Apr, 14:18
Fabian Hueske Re: Efficiency with different approaches of aggregation in Flink Thu, 19 Apr, 07:44
Fabian Hueske Re: debug for Flink Thu, 19 Apr, 13:29
Fabian Hueske Re: gonna need more logs when task manager is shutting down Fri, 20 Apr, 09:54
Fabian Hueske Re: 1.4.3 release/roadmap Fri, 20 Apr, 13:29
Fabian Hueske Re: Join two data streams on a given key and diffrent common window size. Mon, 23 Apr, 11:03
Fabian Hueske Re: data enrichment with SQL use case Mon, 23 Apr, 11:13
Fabian Hueske Re: Unsure how to further debug - operator threads stuck on java.lang.Thread.State: WAITING Mon, 23 Apr, 12:15
Fabian Hueske Re: Building a Flink Connector Mon, 23 Apr, 13:12
Fabian Hueske Re: Flink and spatial data Mon, 23 Apr, 13:17
Fabian Hueske Re: Checkpointing barriers Tue, 24 Apr, 09:48
Fabian Hueske Re: data enrichment with SQL use case Tue, 24 Apr, 10:01
Fabian Hueske Re: KafkaJsonTableSource purpose Tue, 24 Apr, 10:18
Fabian Hueske Re: Use gradle with flink Tue, 24 Apr, 12:13
Fabian Hueske Re: Why assignTimestampsAndWatermarks parallelism same as map,it will not fired? Wed, 25 Apr, 10:56
Fabian Hueske Re: Multiple Streams Connect Watermark Thu, 26 Apr, 10:05
Fabian Hueske Re: Help with OneInputStreamOperatorTestHarness Thu, 26 Apr, 10:07
Fabian Hueske Re: data enrichment with SQL use case Thu, 26 Apr, 10:23
Fabian Hueske Re: Multiple Streams Connect Watermark Thu, 26 Apr, 20:02
Felipe Gutierrez Operators in Flink Fri, 20 Apr, 09:58
Felipe Gutierrez Re: Operators in Flink Wed, 25 Apr, 13:38
Filipe Couto Watermark and multiple streams Tue, 10 Apr, 16:32
Flavio Pompermaier Consumed input splits Thu, 26 Apr, 12:54
Ganesh Manal How to configure the reporting interval for the flink metric monitoring. Tue, 17 Apr, 11:40
Ganesh Manal Counter and guage metric are not populated consistently. Fri, 27 Apr, 07:49
Gary Yao Re: State management and heap usage Thu, 12 Apr, 08:45
Gary Yao Re: Access logs for a running Flink app in YARN cluster Fri, 13 Apr, 19:13
Gary Yao Re: Old Flink jobs restarting on Job Manager failover Sun, 15 Apr, 19:57
Gary Yao Re: Testing on Flink 1.5 Tue, 17 Apr, 15:40
Gary Yao Re: rest.port is reset to 0 by YarnEntrypointUtils Wed, 18 Apr, 09:40
Gary Yao Re: Testing on Flink 1.5 Thu, 19 Apr, 15:47
Gary Yao Re: Testing on Flink 1.5 Thu, 19 Apr, 21:21
Gary Yao Re: masters file only needed when using start-cluster.sh script? Fri, 20 Apr, 07:22
Gary Yao Re: How to run flip-6 on mesos Tue, 24 Apr, 06:42
Gary Yao Re: akka.remote.OversizedPayloadException Tue, 24 Apr, 06:54
Gary Yao Re: How to run flip-6 on mesos Tue, 24 Apr, 07:06
Gary Yao Re: Testing on Flink 1.5 Tue, 24 Apr, 07:29
Gary Yao Re: How to run flip-6 on mesos Tue, 24 Apr, 07:39
Gary Yao Re: How to run flip-6 on mesos Wed, 25 Apr, 08:08
Georgi Stoyanov Use gradle with flink Tue, 24 Apr, 09:17
Hao Sun Re: Flink and Docker ? Tue, 03 Apr, 13:23
Hao Sun Re: Temporary failure in name resolution Tue, 03 Apr, 13:28
Hao Sun Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 20:47
Hao Sun Re: keyBy and parallelism Wed, 11 Apr, 21:29
Hequn Cheng Re: How to output a Table to Kafka? Tue, 10 Apr, 01:55
Hung Re: Apache Flink Examples Fri, 27 Apr, 11:47
Ivan Wang assign time attribute after first window group when using Flink SQL Mon, 09 Apr, 05:25
Ivan Wang Is Flink able to do real time stock market analysis? Wed, 11 Apr, 00:40
Ivan Wang Re: Is Flink able to do real time stock market analysis? Thu, 12 Apr, 13:52
Ivan Wang Re: assign time attribute after first window group when using Flink SQL Wed, 18 Apr, 01:03
JP de Vooght Re: logging question Sat, 07 Apr, 12:46
JP de Vooght Re: logging question Sat, 07 Apr, 16:31
JP de Vooght WordCount with Flink Docker Sat, 21 Apr, 22:15
JP de Vooght Re: WordCount with Flink Docker Sun, 22 Apr, 08:33
JP de Vooght Re: WordCount with Flink Docker Sun, 22 Apr, 13:14
James Yu Two questions on Flink externalized checkpoints Sat, 07 Apr, 23:05
James Yu Re: Unsure how to further debug - operator threads stuck on java.lang.Thread.State: WAITING Tue, 17 Apr, 23:59
Javier Lopez Re: Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 09:23
Javier Lopez Re: Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 14:01
JaxonTheGamer AndCooker Question regarding refreshing KafkaConsumer in FlinkKafkaConnector Thu, 26 Apr, 15:18
Jeroen Steggink | knowsy Jars uploaded to taskmanager are deleted but not free'ed by OS Wed, 18 Apr, 13:44
Jeroen Steggink | knowsy Jars uploaded to jobmanager are deleted but not free'ed by OS Wed, 18 Apr, 13:58
Josh Lemer Bucketing Sink does not complete files, when source is from a collection Wed, 04 Apr, 18:50
Josh Lemer Get get file name when reading from files? Or assign timestamps from file creation time? Fri, 06 Apr, 15:46
Juan Gentile Externalized checkpoints and metadata Wed, 25 Apr, 13:07
Juan Gentile Re: Externalized checkpoints and metadata Thu, 26 Apr, 08:35
Juho Autio Re: cancel-with-savepoint: 404 Not Found Wed, 04 Apr, 10:03
Juho Autio REST API "broken" on YARN because POST is not allowed via YARN proxy Wed, 04 Apr, 13:02
Juho Autio Re: Kafka Consumers Partition Discovery doesn't work Thu, 05 Apr, 10:26
Juho Autio Re: REST API "broken" on YARN because POST is not allowed via YARN proxy Thu, 05 Apr, 14:45
Juho Autio Re: Kafka Consumers Partition Discovery doesn't work Tue, 10 Apr, 15:44
Juho Autio Allowed lateness + side output late data, what's included? Wed, 11 Apr, 09:12
Juho Autio Re: Allowed lateness + side output late data, what's included? Wed, 11 Apr, 10:22
Juho Autio Re: Kafka consumer to sync topics by event time? Thu, 12 Apr, 07:32
Juho Autio Re: Kafka consumer to sync topics by event time? Mon, 16 Apr, 13:38
Juho Autio Re: Kafka topic partition skewness causes watermark not being emitted Tue, 17 Apr, 06:41
Juho Autio Re: Flink State monitoring Fri, 20 Apr, 09:36
Juho Autio Re: Flink State monitoring Fri, 20 Apr, 09:59
Juho Autio Re: Flink State monitoring Tue, 24 Apr, 13:47
Juho Autio Application logs missing from jobmanager log Fri, 27 Apr, 09:13
Juho Autio Re: Application logs missing from jobmanager log Fri, 27 Apr, 09:27
Julio Biason Side outputs never getting consumed Mon, 02 Apr, 19:53
Julio Biason Re: Side outputs never getting consumed Wed, 04 Apr, 14:35
Julio Biason Trying to understand KafkaConsumer_records_lag_max Fri, 13 Apr, 18:06
Julio Biason Re: Trying to understand KafkaConsumer_records_lag_max Mon, 16 Apr, 16:40
Julio Biason Testing Metrics Tue, 24 Apr, 17:59
Ken Krugler Re: Multiple Async IO Tue, 03 Apr, 17:39
Ken Krugler Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 21:52
Ken Krugler Re: java.lang.Exception: TaskManager was lost/killed Wed, 11 Apr, 14:27
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Box list
Sep 2019269
Aug 2019627
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