flink-user mailing list archives: November 2018

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