flink-user mailing list archives: April 2018

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Re: Checkpoints very slow with high backpressure
Edward   Re: Checkpoints very slow with high backpressure Thu, 05 Apr, 13:10
Piotr Nowojski     Re: Checkpoints very slow with high backpressure Thu, 05 Apr, 14:31
Edward       Re: Checkpoints very slow with high backpressure Thu, 05 Apr, 15:13
Piotr Nowojski         Re: Checkpoints very slow with high backpressure Thu, 05 Apr, 16:06
Zhijiang(wangzhijiang999)         回复:Checkpoints very slow with high backpressure Sun, 08 Apr, 03:08
Sampath Bhat Flink Client job submission through SSL Fri, 06 Apr, 06:37
Shuyi Chen   Re: Flink Client job submission through SSL Fri, 06 Apr, 07:26
Sampath Bhat     Re: Flink Client job submission through SSL Fri, 06 Apr, 11:22
Shuyi Chen       Re: Flink Client job submission through SSL Fri, 06 Apr, 18:24
Data Engineer Reg. the checkpointing mechanism Fri, 06 Apr, 11:47
Nico Kruber   Re: Reg. the checkpointing mechanism Fri, 06 Apr, 12:20
Dipl.-Inf. Rico Bergmann Flink 1.4.2 in Zeppelin Notebook Fri, 06 Apr, 12:51
kedar mhaswade   Re: Flink 1.4.2 in Zeppelin Notebook Fri, 06 Apr, 16:44
Rico Bergmann     Re: Flink 1.4.2 in Zeppelin Notebook Mon, 09 Apr, 07:50
kedar mhaswade       Re: Flink 1.4.2 in Zeppelin Notebook Mon, 09 Apr, 12:12
Rico Bergmann         Re: Flink 1.4.2 in Zeppelin Notebook Mon, 09 Apr, 12:43
Rico Bergmann           Re: Flink 1.4.2 in Zeppelin Notebook Tue, 10 Apr, 06:37
Josh Lemer Get get file name when reading from files? Or assign timestamps from file creation time? Fri, 06 Apr, 15:46
Fabian Hueske   Re: Get get file name when reading from files? Or assign timestamps from file creation time? Fri, 06 Apr, 15:56
Ashish Attarde Lot of data generated in out file Fri, 06 Apr, 18:09
Tzu-Li (Gordon) Tai   Re: Lot of data generated in out file Mon, 16 Apr, 05:09
Ashish Attarde     Re: Lot of data generated in out file Mon, 16 Apr, 05:13
Elias Levy Tracking deserialization errors Fri, 06 Apr, 18:12
Alexander Smirnov   Re: Tracking deserialization errors Sun, 08 Apr, 15:53
Fabian Hueske     Re: Tracking deserialization errors Mon, 16 Apr, 11:42
Tzu-Li (Gordon) Tai       Re: Tracking deserialization errors Wed, 18 Apr, 12:32
Alexander Smirnov         Re: Tracking deserialization errors Wed, 18 Apr, 13:10
Elias Levy       Re: Tracking deserialization errors Wed, 18 Apr, 18:00
Tzu-Li (Gordon) Tai         Re: Tracking deserialization errors Thu, 19 Apr, 13:56
Alexander Smirnov           Re: Tracking deserialization errors Mon, 23 Apr, 09:59
Michael Latta Multi-stream question Sat, 07 Apr, 00:04
Puneet Kinra   Re: Multi-stream question Sat, 07 Apr, 08:58
Re: logging question
JP de Vooght   Re: logging question Sat, 07 Apr, 12:46
JP de Vooght     Re: logging question Sat, 07 Apr, 16:31
TechnoMage Volume question Sat, 07 Apr, 17:57
Fabian Hueske   Re: Volume question Mon, 16 Apr, 07:59
James Yu Two questions on Flink externalized checkpoints Sat, 07 Apr, 23:05
王凯 java.lang.Exception: TaskManager was lost/killed Sun, 08 Apr, 08:36
TechnoMage   Re: java.lang.Exception: TaskManager was lost/killed Sun, 08 Apr, 16:06
王凯     Re:Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 08:36
Alexander Smirnov       Re: Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 08:41
Javier Lopez         Re: Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 09:23
miki haiat           Re: Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 13:37
Javier Lopez             Re: Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 14:01
Chesnay Schepler               Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 19:48
Lasse Nedergaard                 Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 20:41
Hao Sun                   Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 20:47
Ken Krugler                 Re: java.lang.Exception: TaskManager was lost/killed Mon, 09 Apr, 21:52
Lasse Nedergaard                   Re: java.lang.Exception: TaskManager was lost/killed Tue, 10 Apr, 06:52
Lasse Nedergaard                     Re: java.lang.Exception: TaskManager was lost/killed Tue, 10 Apr, 07:25
Ted Yu                       Re: java.lang.Exception: TaskManager was lost/killed Tue, 10 Apr, 08:41
Lasse Nedergaard                         Re: java.lang.Exception: TaskManager was lost/killed Tue, 10 Apr, 09:43
Ted Yu                       Re: java.lang.Exception: TaskManager was lost/killed Wed, 11 Apr, 01:55
周思华                         Re: java.lang.Exception: TaskManager was lost/killed Wed, 11 Apr, 03:03
Lasse Nedergaard                           Re: java.lang.Exception: TaskManager was lost/killed Wed, 11 Apr, 09:38
Ken Krugler                             Re: java.lang.Exception: TaskManager was lost/killed Wed, 11 Apr, 14:27
Lasse Nedergaard                               Re: java.lang.Exception: TaskManager was lost/killed Thu, 12 Apr, 11:56
Lasse Nedergaard                                 Re: java.lang.Exception: TaskManager was lost/killed Thu, 12 Apr, 12:54
Ivan Wang assign time attribute after first window group when using Flink SQL Mon, 09 Apr, 05:25
Fabian Hueske   Re: assign time attribute after first window group when using Flink SQL Mon, 16 Apr, 08:01
Ivan Wang     Re: assign time attribute after first window group when using Flink SQL Wed, 18 Apr, 01:03
Fabian Hueske       Re: assign time attribute after first window group when using Flink SQL Wed, 18 Apr, 07:44
chi ma How to output a Table to Kafka? Mon, 09 Apr, 06:43
Hequn Cheng   Re: How to output a Table to Kafka? Tue, 10 Apr, 01:55
Pavel Ciorba Flink override config params (Docker) Mon, 09 Apr, 11:04
miki haiat   Re: Flink override config params (Docker) Mon, 09 Apr, 11:11
Pavel Ciorba     Re: Flink override config params (Docker) Mon, 09 Apr, 12:47
NEKRASSOV, ALEXEI RocksDBMapState example? Mon, 09 Apr, 15:41
Ted Yu   Re: RocksDBMapState example? Mon, 09 Apr, 15:47
NEKRASSOV, ALEXEI     RE: RocksDBMapState example? Tue, 10 Apr, 12:21
Dawid Wysakowicz   Re: RocksDBMapState example? Tue, 10 Apr, 12:53
NEKRASSOV, ALEXEI     RE: RocksDBMapState example? Tue, 10 Apr, 14:24
Ted Yu       Re: RocksDBMapState example? Tue, 10 Apr, 15:24
Pavel Ciorba Flink Uploaded JAR Filename Mon, 09 Apr, 16:49
Jörn Franke   Re: Flink Uploaded JAR Filename Mon, 09 Apr, 16:55
Petter Arvidsson Recovering snapshot state saved with TypeInformation generated by the implicit macro from the scala API Tue, 10 Apr, 16:06
Gábor Gévay   Re: Recovering snapshot state saved with TypeInformation generated by the implicit macro from the scala API Fri, 13 Apr, 17:14
Filipe Couto Watermark and multiple streams Tue, 10 Apr, 16:32
Tzu-Li (Gordon) Tai   Re: Watermark and multiple streams Mon, 16 Apr, 04:58
Ivan Wang Is Flink able to do real time stock market analysis? Wed, 11 Apr, 00:40
TechnoMage   Re: Is Flink able to do real time stock market analysis? Wed, 11 Apr, 19:20
Ivan Wang     Re: Is Flink able to do real time stock market analysis? Thu, 12 Apr, 13:52
TechnoMage       Re: Is Flink able to do real time stock market analysis? Thu, 12 Apr, 21:13
Fabian Hueske         Re: Is Flink able to do real time stock market analysis? Fri, 13 Apr, 19:59
syed How to customize triggering of checkpoints? Wed, 11 Apr, 03:15
Chesnay Schepler   Re: How to customize triggering of checkpoints? Wed, 11 Apr, 08:35
Steven Wu     Re: How to customize triggering of checkpoints? Thu, 12 Apr, 17:03
Re: Window with recent messages
m@xi   Re: Window with recent messages Wed, 11 Apr, 07:30
Juho Autio Allowed lateness + side output late data, what's included? Wed, 11 Apr, 09:12
Chesnay Schepler   Re: Allowed lateness + side output late data, what's included? Wed, 11 Apr, 09:59
Juho Autio     Re: Allowed lateness + side output late data, what's included? Wed, 11 Apr, 10:22
chandresh pancholi How to add new Kafka topic to consumer Wed, 11 Apr, 12:33
Alexander Smirnov   Re: How to add new Kafka topic to consumer Wed, 11 Apr, 12:36
Chesnay Schepler   Re: How to add new Kafka topic to consumer Wed, 11 Apr, 12:40
Luigi Sgaglione Json KAFKA producer Wed, 11 Apr, 13:56
Fabian Hueske   Re: Json KAFKA producer Sat, 14 Apr, 10:00
Derek VerLee Clarification on slots and efficiency Wed, 11 Apr, 18:22
Steven Wu Old JobManager lost its leadership in zk Wed, 11 Apr, 20:31
Steven Wu   Re: Old JobManager lost its leadership in zk Wed, 11 Apr, 20:39
Steven Wu     Re: Old JobManager lost its leadership in zk Wed, 11 Apr, 21:00
Steven Wu       Re: Old JobManager lost its leadership in zk Wed, 11 Apr, 21:14
Steven Wu         Re: Old JobManager lost its leadership in zk Thu, 12 Apr, 16:43
TechnoMage State management and heap usage Wed, 11 Apr, 21:04
Gary Yao   Re: State management and heap usage Thu, 12 Apr, 08:45
TechnoMage     Re: State management and heap usage Thu, 12 Apr, 21:15
Christophe Jolif keyBy and parallelism Wed, 11 Apr, 21:16
Hao Sun   Re: keyBy and parallelism Wed, 11 Apr, 21:29
Chesnay Schepler     Re: keyBy and parallelism Thu, 12 Apr, 07:31
Christophe Jolif       Re: keyBy and parallelism Thu, 12 Apr, 07:44
周思华         Re: keyBy and parallelism Thu, 12 Apr, 08:04
Christophe Jolif           Re: keyBy and parallelism Thu, 12 Apr, 09:44
Ken Krugler             Re: keyBy and parallelism Thu, 12 Apr, 14:50
Re: Kafka consumer to sync topics by event time?
Juho Autio   Re: Kafka consumer to sync topics by event time? Thu, 12 Apr, 07:32
Fabian Hueske     Re: Kafka consumer to sync topics by event time? Mon, 16 Apr, 12:14
Juho Autio       Re: Kafka consumer to sync topics by event time? Mon, 16 Apr, 13:38
Fabian Hueske         Re: Kafka consumer to sync topics by event time? Mon, 16 Apr, 13:48
RE: Old Flink jobs restarting on Job Manager failover
Stephen.Hesk...@natwestmarkets.com   RE: Old Flink jobs restarting on Job Manager failover Thu, 12 Apr, 16:01
Gary Yao     Re: Old Flink jobs restarting on Job Manager failover Sun, 15 Apr, 19:57
Tao Xia Access logs for a running Flink app in YARN cluster Fri, 13 Apr, 00:09
杨力   Re: Access logs for a running Flink app in YARN cluster Fri, 13 Apr, 03:06
Gary Yao   Re: Access logs for a running Flink app in YARN cluster Fri, 13 Apr, 19:13
Tao Xia     Re: Access logs for a running Flink app in YARN cluster Fri, 13 Apr, 19:58
TechnoMage Question about parallelism Fri, 13 Apr, 02:30
Fabian Hueske   Re: Question about parallelism Mon, 16 Apr, 08:05
TechnoMage     Re: Question about parallelism Mon, 16 Apr, 16:37
Fabian Hueske       Re: Question about parallelism Mon, 16 Apr, 20:11
TechnoMage         Re: Question about parallelism Mon, 16 Apr, 22:36
Adrian Hains Unable to launch job with 100 SQL queries in yarn cluster Fri, 13 Apr, 06:59
Fabian Hueske   Re: Unable to launch job with 100 SQL queries in yarn cluster Mon, 16 Apr, 12:33
makeyang heartbeat.timeout in 1.4 document Fri, 13 Apr, 09:02
eSKa Classloading issues after changing to 1.4 Fri, 13 Apr, 09:28
Ken Krugler   Re: Classloading issues after changing to 1.4 Sat, 14 Apr, 14:37
m@xi Simulating Time-based and Count-based Custom Windows with ProcessFunction Fri, 13 Apr, 09:35
Tzu-Li (Gordon) Tai   Re: Simulating Time-based and Count-based Custom Windows with ProcessFunction Mon, 16 Apr, 04:42
Lehuede sebastien Flink - Kafka Connector Fri, 13 Apr, 12:12
Alexandru Gutan   Re: Flink - Kafka Connector Fri, 13 Apr, 12:27
Darshan Singh How to rebalance a table without converting to dataset Fri, 13 Apr, 12:33
Fabian Hueske   Re: How to rebalance a table without converting to dataset Mon, 16 Apr, 12:41
Shuyi Chen     Re: How to rebalance a table without converting to dataset Tue, 17 Apr, 07:53
Darshan Singh Any metrics to get the shuffled and intermediate data in flink Fri, 13 Apr, 12:37
TechnoMage   Re: Any metrics to get the shuffled and intermediate data in flink Fri, 13 Apr, 14:12
Darshan Singh     Re: Any metrics to get the shuffled and intermediate data in flink Fri, 13 Apr, 14:24
Message list« Previous · 1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Sep 2020563
Aug 2020723
Jul 2020840
Jun 2020653
May 2020766
Apr 2020849
Mar 2020795
Feb 2020690
Jan 2020652
Dec 2019530
Nov 2019527
Oct 2019542
Sep 2019534
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