flink-user mailing list archives: November 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
wpb How can I configure logback for TaskManager in LocalStreamEnvironment Fri, 09 Nov, 02:59
杨力 Re: Job xxx not found exception when starting Flink program in Local Sun, 18 Nov, 07:01
远远 Re: Any examples on invoke the Flink REST API post method ? Mon, 12 Nov, 10:14
远远 The flink checkpoint time interval is not normal Fri, 16 Nov, 10:28
Dominik Wosiński Re: Field could not be resolved by the field mapping when using kafka connector Thu, 15 Nov, 09:52
Dominik Wosiński Re: Flink with parallelism 3 is running locally but not on cluster Thu, 15 Nov, 10:04
Dominik Wosiński Re: Flink with parallelism 3 is running locally but not on cluster Thu, 15 Nov, 10:05
Dominik Wosiński Re: Field could not be resolved by the field mapping when using kafka connector Thu, 15 Nov, 10:06
Dominik Wosiński Re: Kinesis Connector - NoClassDefFoundError Tue, 20 Nov, 10:23
Dominik Wosiński Re: Store Predicate or any lambda in MapState Wed, 21 Nov, 09:47
Dominik Wosiński Re: Can JDBCSinkFunction support exectly once? Wed, 21 Nov, 10:27
Dominik Wosiński Re: Changes in Flink 1.6.2 Wed, 28 Nov, 20:47
Dominik Wosiński Re: Flink SQL Fri, 30 Nov, 10:20
Dominik Wosiński Re: Changes in Flink 1.6.2 Fri, 30 Nov, 15:10
Gyula Fóra State processing and testing utilities (Bravo) Wed, 07 Nov, 13:23
Laura Uzcátegui Flink auth against Zookeeper with MD5-Digest Mon, 12 Nov, 15:41
wpb How to get the ActorSystem in custom operator Fri, 09 Nov, 06:31
wpb 回复: How to get the ActorSystem in custom operator Wed, 14 Nov, 02:24
徐涛 Any examples on invoke the Flink REST API post method ? Mon, 12 Nov, 04:45
徐涛 Job xxx not found exception when starting Flink program in Local Tue, 13 Nov, 06:51
徐涛 ***UNCHECKED*** Job xxx not found exception when starting Flink program in Local Tue, 13 Nov, 06:53
徐涛 Job xxx not found exception when starting Flink program in Local Tue, 13 Nov, 07:01
徐涛 Re: Job xxx not found exception when starting Flink program in Local Tue, 13 Nov, 07:47
徐涛 Last batch of stream data could not be sinked when data comes very slow Tue, 13 Nov, 09:07
徐涛 Re: Job xxx not found exception when starting Flink program in Local Sun, 18 Nov, 00:11
徐涛 Re: Last batch of stream data could not be sinked when data comes very slow Sun, 18 Nov, 00:27
徐涛 Deadlock happens when sink to mysql Mon, 19 Nov, 13:38
devinduan(段丁瑞) 回复: What if not to keep containers across attempts in HA setup?(Internet mail) Tue, 13 Nov, 09:27
devinduan(段丁瑞) 回复: Re: What if not to keep containers across attempts in HA setup?(Internet mail) Thu, 15 Nov, 03:59
罗齐 Re: Auto/Dynamic scaling in Flink Fri, 16 Nov, 03:53
罗齐 Re: Flink Exception - assigned slot container was removed Mon, 26 Nov, 02:56
bupt_ljy Re: Queryable state when key is UUID - getting Kyro Exception Tue, 13 Nov, 06:05
bupt_ljy Re: Queryable state when key is UUID - getting Kyro Exception Tue, 13 Nov, 08:57
bupt_ljy Re: Flink operator UUID and serialVersionUID Wed, 28 Nov, 07:22
bupt_ljy Re: Flink operator UUID and serialVersionUID Wed, 28 Nov, 07:55
bupt_ljy Re: Flink operator UUID and serialVersionUID Wed, 28 Nov, 09:38
bupt_ljy Re: Flink operator UUID and serialVersionUID Wed, 28 Nov, 10:01
Aaron Levin Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Thu, 01 Nov, 14:30
Aaron Levin Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Thu, 01 Nov, 15:50
Aaron Levin Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Mon, 12 Nov, 15:32
Aarti Gupta Ingesting data from an API Mon, 12 Nov, 07:15
Abhijeet Kumar Flink Streaming sink to InfluxDB Tue, 13 Nov, 08:06
Abhijeet Kumar Kafka: Unable to retrieve any partitions with KafkaTopicsDescriptor Wed, 21 Nov, 08:49
Abhijeet Kumar error while joining two datastream Fri, 23 Nov, 06:54
Abhijeet Kumar Re: error while joining two datastream Fri, 23 Nov, 07:50
Abhijeet Kumar Window is not working in streaming Mon, 26 Nov, 07:35
Abhijeet Kumar Re: Window is not working in streaming Mon, 26 Nov, 08:15
Abhijeet Kumar Flink join stream where one stream is coming 5 minutes late Mon, 26 Nov, 12:13
Abhijeet Kumar Re: Flink join stream where one stream is coming 5 minutes late Mon, 26 Nov, 17:44
Abhijeet Kumar Re: Flink join stream where one stream is coming 5 minutes late Mon, 26 Nov, 18:51
Addison Higham Re: Using a ProcessFunction as a "Source" Thu, 01 Nov, 19:47
Addison Higham Re: Flink Kafka to BucketingSink to S3 - S3Exception Mon, 05 Nov, 16:23
Akshay Mendole OutOfMemoryError while doing join operation in flink Thu, 22 Nov, 05:43
Akshay Mendole Re: OutOfMemoryError while doing join operation in flink Thu, 22 Nov, 12:07
Akshay Mendole Re: OutOfMemoryError while doing join operation in flink Thu, 22 Nov, 18:54
Akshay Mendole Re: OutOfMemoryError while doing join operation in flink Wed, 28 Nov, 06:43
Alexander Smirnov Re: FileNotFoundException on starting the job Fri, 02 Nov, 09:23
Alexey Trenikhun Re: flink build error Wed, 14 Nov, 17:55
Alexey Trenikhun MapState - TypeSerializer Wed, 28 Nov, 03:56
Ali, Kasif Flink restart strategy on specific exception Thu, 22 Nov, 06:10
Ali, Kasif how to stop hung job manager Thu, 29 Nov, 08:25
Aljoscha Krettek Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Thu, 01 Nov, 14:41
Aljoscha Krettek Re: Using a ProcessFunction as a "Source" Fri, 02 Nov, 09:55
Aljoscha Krettek Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Fri, 09 Nov, 10:01
Andrea Sella Flink Serialization and case class fields limit Fri, 16 Nov, 12:10
Andrea Sella Re: Flink Serialization and case class fields limit Fri, 16 Nov, 19:05
Andrey Zagrebin Re: Continue batch job with streaming job Thu, 01 Nov, 12:20
Andrey Zagrebin Re: How to get Kafka record's timestamp using Flink's KeyedDeserializationSchema? Fri, 16 Nov, 17:59
Andrey Zagrebin Re: Flink Serialization and case class fields limit Fri, 16 Nov, 18:34
Andrey Zagrebin Re: BucketingSink vs StreamingFileSink Fri, 16 Nov, 18:54
Andrey Zagrebin Re: Enabling Flink’s checkpointing Mon, 19 Nov, 10:39
Andrey Zagrebin Re: Flink Exception - assigned slot container was removed Tue, 27 Nov, 13:56
Andrey Zagrebin Re: how to override s3 key config in flink job Tue, 27 Nov, 14:43
Andrey Zagrebin Re: Store Predicate or any lambda in MapState Tue, 27 Nov, 16:14
Andrey Zagrebin Re: Store Predicate or any lambda in MapState Wed, 28 Nov, 10:21
Andrey Zagrebin Re: MapState - TypeSerializer Wed, 28 Nov, 10:23
Andrey Zagrebin Re: number of files in checkpoint directory grows endlessly Thu, 29 Nov, 09:38
Andrey Zagrebin Re: number of files in checkpoint directory grows endlessly Thu, 29 Nov, 10:00
Andrey Zagrebin Re: number of files in checkpoint directory grows endlessly Thu, 29 Nov, 14:37
Anil Re: InterruptedException when async function is cancelled Wed, 07 Nov, 16:41
Anil Re: akka timeout exception Fri, 09 Nov, 03:39
Anil Counter Implementation in Flink Sat, 24 Nov, 15:36
Austin Cawley-Edwards Re: Flink CEP Watermark Exception Thu, 01 Nov, 13:24
Austin Cawley-Edwards Re: Flink CEP Watermark Exception Tue, 06 Nov, 14:40
Avi Levi ClassNotFoundException: org.apache.kafka.common.metrics.stats.Rate$1 Tue, 20 Nov, 13:32
Avi Levi Could not extract key Exception only on runtime not in dev environment Tue, 20 Nov, 15:26
Avi Levi Re: Could not extract key Exception only on runtime not in dev environment Tue, 20 Nov, 15:37
Avi Levi your advice please regarding state Wed, 21 Nov, 11:36
Avi Levi Re: your advice please regarding state Thu, 22 Nov, 03:58
Avi Levi where can I see logs from code Sun, 25 Nov, 10:11
Avi Levi Re: where can I see logs from code Sun, 25 Nov, 16:48
Avi Levi understadning kafka connector - rebalance Mon, 26 Nov, 06:03
Avi Levi Re: understadning kafka connector - rebalance Mon, 26 Nov, 08:55
Avi Levi Re: understadning kafka connector - rebalance Mon, 26 Nov, 11:40
Avi Levi Re: your advice please regarding state Tue, 27 Nov, 14:33
Avi Levi Stream in loop and not getting to sink (Parquet writer ) Wed, 28 Nov, 19:21
Avi Levi Re: Stream in loop and not getting to sink (Parquet writer ) Thu, 29 Nov, 03:33
Avi Levi Re: Stream in loop and not getting to sink (Parquet writer ) Thu, 29 Nov, 06:03
Avi Levi Re: Stream in loop and not getting to sink (Parquet writer ) Thu, 29 Nov, 11:25
Avi Levi Re: Stream in loop and not getting to sink (Parquet writer ) Thu, 29 Nov, 17:57
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Box list
May 2019331
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