flink-user mailing list archives: November 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
vino yang Re: Flink fails continuously: Couldn't retrieve the JobExecutionResult from the JobManager. Thu, 01 Nov, 01:22
Hequn Cheng Re: Ask about counting elements per window Thu, 01 Nov, 02:08
Paul Lam Re: Kafka offset behaviour when restarting job from savepoint Thu, 01 Nov, 02:17
madan Re: CsvInputFormat - read header line first Thu, 01 Nov, 04:47
Gagan Agrawal Re: Savepoint failed with error "Checkpoint expired before completing" Thu, 01 Nov, 05:38
Yun Tang Re: Savepoint failed with error "Checkpoint expired before completing" Thu, 01 Nov, 08:20
Dawid Wysakowicz Re: Flink CEP Watermark Exception Thu, 01 Nov, 08:43
Yun Tang Re: 1.6 UI issues Thu, 01 Nov, 11:31
Xingcan Cui Re: Flink SQL string literal does not support double quotation? Thu, 01 Nov, 11:59
Andrey Zagrebin Re: Continue batch job with streaming job Thu, 01 Nov, 12:20
Austin Cawley-Edwards Re: Flink CEP Watermark Exception Thu, 01 Nov, 13:24
Aaron Levin Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Thu, 01 Nov, 14:30
Aljoscha Krettek Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Thu, 01 Nov, 14:41
John Stone Re: TaskManagers cannot contact JobManager in Kubernetes when JobManager HA is enabled Thu, 01 Nov, 15:22
Aaron Levin Re: Error with custom `SourceFunction` wrapping `InputFormatSourceFunction` (Flink 1.6) Thu, 01 Nov, 15:50
Dmitry Minaev FileNotFoundException on starting the job Thu, 01 Nov, 17:50
Addison Higham Re: Using a ProcessFunction as a "Source" Thu, 01 Nov, 19:47
Vijay Balakrishnan Re: Parallelize an incoming stream into 5 streams with the same data Thu, 01 Nov, 22:20
Ly, The Anh Starting a seperate Java process within a Flink cluster Thu, 01 Nov, 22:33
TechnoMage Flink SQL questions Thu, 01 Nov, 23:46
Michael Latta Job manager UI improvement Fri, 02 Nov, 02:08
Hequn Cheng Re: Parallelize an incoming stream into 5 streams with the same data Fri, 02 Nov, 03:17
Hequn Cheng Re: Flink SQL questions Fri, 02 Nov, 03:22
Michael Latta Re: Flink SQL questions Fri, 02 Nov, 03:32
Yun Tang Re: Starting a seperate Java process within a Flink cluster Fri, 02 Nov, 03:47
Yun Tang Re: Job manager UI improvement Fri, 02 Nov, 03:55
Hao Sun java.io.IOException: NSS is already initialized Fri, 02 Nov, 04:22
Timo Walther Re: Flink SQL questions Fri, 02 Nov, 06:13
Dawid Wysakowicz Re: Flink CEP Watermark Exception Fri, 02 Nov, 09:02
Till Rohrmann Re: Why dont't have a csv formatter for kafka table source Fri, 02 Nov, 09:11
Timo Walther Re: Why dont't have a csv formatter for kafka table source Fri, 02 Nov, 09:18
Ly, The Anh Re: Starting a seperate Java process within a Flink cluster Fri, 02 Nov, 09:22
Alexander Smirnov Re: FileNotFoundException on starting the job Fri, 02 Nov, 09:23
Jeff Zhang Re: Starting a seperate Java process within a Flink cluster Fri, 02 Nov, 09:34
sohimankotia Question about slot and yarn vcores Fri, 02 Nov, 09:48
sohimankotia Re: Window State is not being store on check-pointing Fri, 02 Nov, 09:50
Aljoscha Krettek Re: Using a ProcessFunction as a "Source" Fri, 02 Nov, 09:55
Steve Bistline Kinesis Connector Fri, 02 Nov, 14:28
Juan Gentile Re: 1.6 UI issues Fri, 02 Nov, 16:26
Hequn Cheng Re: Kinesis Connector Fri, 02 Nov, 17:05
mina...@gmail.com Re: FileNotFoundException on starting the job Fri, 02 Nov, 17:33
Gagan Agrawal Re: Savepoint failed with error "Checkpoint expired before completing" Sat, 03 Nov, 01:37
Hao Sun Re: java.io.IOException: NSS is already initialized Sat, 03 Nov, 02:09
Flink Developer Re: Flink Kafka to BucketingSink to S3 - S3Exception Sat, 03 Nov, 08:24
Ravi Bhushan Ratnakar Re: Flink Kafka to BucketingSink to S3 - S3Exception Sat, 03 Nov, 14:18
Rad Rad Re: Ask about counting elements per window Sat, 03 Nov, 20:23
Hao Sun Flink 1.6 job cluster mode, job_id is always 00000000000000000000000000000000 Sun, 04 Nov, 02:39
Flink Developer Re: Flink Kafka to BucketingSink to S3 - S3Exception Sun, 04 Nov, 10:09
Ufuk Celebi Re: Flink 1.6 job cluster mode, job_id is always 00000000000000000000000000000000 Sun, 04 Nov, 11:34
Hao Sun Re: Flink 1.6 job cluster mode, job_id is always 00000000000000000000000000000000 Sun, 04 Nov, 21:35
Flink Developer Recommendation for BucketingSink to GZIP compress files to S3 Sun, 04 Nov, 23:29
Ning Shi Questions about Savepoints Mon, 05 Nov, 00:28
vino yang Re: Flink 1.6 job cluster mode, job_id is always 00000000000000000000000000000000 Mon, 05 Nov, 01:44
Steven Wu Re: Savepoint failed with error "Checkpoint expired before completing" Mon, 05 Nov, 04:36
Tony Wei sys.exist(1) led to standalonesession daemon closed Mon, 05 Nov, 05:38
wangziyu "org.apache.flink.client.program.ProgramInvocationException: Unknown I/O error while extracting contained jar files Mon, 05 Nov, 08:19
yinhua.dai Always trigger calculation of a tumble window in Flink SQL Mon, 05 Nov, 09:17
Ufuk Celebi Re: Flink 1.6 job cluster mode, job_id is always 00000000000000000000000000000000 Mon, 05 Nov, 10:04
madan Split one dataset into multiple Mon, 05 Nov, 10:37
Yun Tang Re: Questions about Savepoints Mon, 05 Nov, 11:59
Flavio Pompermaier Re: Non deterministic result with Table API SQL Mon, 05 Nov, 13:38
Hao Sun Re: Flink 1.6 job cluster mode, job_id is always 00000000000000000000000000000000 Mon, 05 Nov, 13:54
Fabian Hueske Re: Non deterministic result with Table API SQL Mon, 05 Nov, 13:55
Addison Higham Re: Flink Kafka to BucketingSink to S3 - S3Exception Mon, 05 Nov, 16:23
Ravi Bhushan Ratnakar Re: Flink Kafka to BucketingSink to S3 - S3Exception Mon, 05 Nov, 17:41
PranjalChauhan Understanding checkpoint behavior Mon, 05 Nov, 17:52
PranjalChauhan Understanding checkpoint behavior Mon, 05 Nov, 20:33
Vijay Balakrishnan Never gets into ProcessWindowFunction.process() Tue, 06 Nov, 00:10
vino yang Re: Split one dataset into multiple Tue, 06 Nov, 06:33
madan Re: Split one dataset into multiple Tue, 06 Nov, 09:39
Fabian Hueske Re: Split one dataset into multiple Tue, 06 Nov, 10:24
madan Re: Split one dataset into multiple Tue, 06 Nov, 12:19
Fabian Hueske Re: Split one dataset into multiple Tue, 06 Nov, 12:38
LINZ, Arnaud Stopping a streaming app from its own code : behaviour change from 1.3 to 1.6 Tue, 06 Nov, 13:23
Flavio Pompermaier Re: Report failed job submission Tue, 06 Nov, 13:33
Ning Shi Live configuration change Tue, 06 Nov, 14:19
Austin Cawley-Edwards Re: Flink CEP Watermark Exception Tue, 06 Nov, 14:40
Flavio Pompermaier Run a Flink job: REST/ binary client Tue, 06 Nov, 15:55
Piotr Nowojski Re: Live configuration change Tue, 06 Nov, 16:19
Piotr Nowojski Re: Understanding checkpoint behavior Tue, 06 Nov, 16:33
Thad Truman Kubernetes Job Cluster - Checkpointing with Parallelism > 1 Tue, 06 Nov, 16:37
Till Rohrmann [ANNOUNCE] Weekly community update #45 Tue, 06 Nov, 16:39
Piotr Nowojski Re: Always trigger calculation of a tumble window in Flink SQL Tue, 06 Nov, 16:44
Vijay Balakrishnan Re: Parallelize an incoming stream into 5 streams with the same data Tue, 06 Nov, 17:15
Vijay Balakrishnan Re: Using FlinkKinesisConsumer through a proxy Tue, 06 Nov, 17:18
PranjalChauhan Re: Understanding checkpoint behavior Tue, 06 Nov, 17:22
Nicos Maris Re: Live configuration change Tue, 06 Nov, 17:44
Luis Gustavo Oliveira Silva Flink Web UI does not show specific exception messages when job submission fails Tue, 06 Nov, 17:49
Ning Shi Re: Live configuration change Tue, 06 Nov, 18:29
Steven Wu Re: Live configuration change Tue, 06 Nov, 20:26
Ning Shi Re: Live configuration change Tue, 06 Nov, 20:45
Elias Levy Re: Live configuration change Tue, 06 Nov, 21:22
yinhua.dai Re: Always trigger calculation of a tumble window in Flink SQL Wed, 07 Nov, 01:55
Paul Lam Per job cluster doesn't shut down after the job is canceled Wed, 07 Nov, 02:27
Vinay Patil Re: AvroInputFormat Serialisation Issue Wed, 07 Nov, 04:41
Ning Shi Re: Live configuration change Wed, 07 Nov, 04:44
vino yang Re: Flink Task Allocation on Yarn Wed, 07 Nov, 04:50
Flink Developer Re: Flink Kafka to BucketingSink to S3 - S3Exception Wed, 07 Nov, 08:33
Piotr Nowojski Re: Always trigger calculation of a tumble window in Flink SQL Wed, 07 Nov, 08:48
Chang Liu flink job restarts when flink cluster restarts? Wed, 07 Nov, 09:14
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 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