flink-user mailing list archives: July 2019

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Re:Re: About "Flink 1.7.0 HA based on zookeepers "
Alex.Hu   Re:Re: About "Flink 1.7.0 HA based on zookeepers " Mon, 01 Jul, 02:17
Re: Calculate a 4 hour time window for sum,count with sum and count output every 5 mins
Felipe Gutierrez   Re: Calculate a 4 hour time window for sum,count with sum and count output every 5 mins Mon, 01 Jul, 06:45
Re:Re: Re:Flink batch job memory/disk leak when invoking set method on a static Configuration object.
Haibo Sun   Re:Re: Re:Flink batch job memory/disk leak when invoking set method on a static Configuration object. Mon, 01 Jul, 07:19
Alex.Hu Fw:Re:Re: About "Flink 1.7.0 HA based on zookeepers " Mon, 01 Jul, 09:36
Till Rohrmann   Re: Fw:Re:Re: About "Flink 1.7.0 HA based on zookeepers " Tue, 02 Jul, 13:46
Alex.Hu     Re:Re: Fw:Re:Re: About "Flink 1.7.0 HA based on zookeepers " Wed, 03 Jul, 02:20
Re: Batch mode with Flink 1.8 unstable?
Till Rohrmann   Re: Batch mode with Flink 1.8 unstable? Mon, 01 Jul, 09:57
Till Rohrmann     Re: Batch mode with Flink 1.8 unstable? Mon, 01 Jul, 14:20
Ken Krugler       Re: Batch mode with Flink 1.8 unstable? Mon, 01 Jul, 22:23
Ken Krugler   Re: Batch mode with Flink 1.8 unstable? Tue, 02 Jul, 00:21
Till Rohrmann     Re: Batch mode with Flink 1.8 unstable? Tue, 02 Jul, 09:26
Apache Flink - Multiple Kinesis stream consumers
M Singh   Apache Flink - Multiple Kinesis stream consumers Mon, 01 Jul, 10:28
Konstantin Knauf     Re: Apache Flink - Multiple Kinesis stream consumers Sun, 07 Jul, 20:24
Re: Apache Flink - Running application with different flink configurations (flink-conf.yml) on EMR
M Singh   Re: Apache Flink - Running application with different flink configurations (flink-conf.yml) on EMR Mon, 01 Jul, 10:30
Re: LookupableTableSource question
Flavio Pompermaier   Re: LookupableTableSource question Mon, 01 Jul, 13:26
JingsongLee   Re: LookupableTableSource question Tue, 02 Jul, 10:02
Re: [FLINK-10868] the job cannot be exited immediately if job manager is timed out
Till Rohrmann   Re: [FLINK-10868] the job cannot be exited immediately if job manager is timed out Mon, 01 Jul, 14:48
Re: [FLINK-10868] job cannot be exited immediately if job manager is timed out for some reason
Till Rohrmann   Re: [FLINK-10868] job cannot be exited immediately if job manager is timed out for some reason Mon, 01 Jul, 14:49
Peter Huang     Re: [FLINK-10868] job cannot be exited immediately if job manager is timed out for some reason Mon, 01 Jul, 18:43
Anyang Hu       Re: [FLINK-10868] job cannot be exited immediately if job manager is timed out for some reason Thu, 04 Jul, 07:45
[No Subject]
wang xuchen   [No Subject] Mon, 01 Jul, 19:38
Konstantin Knauf     Re: Sun, 07 Jul, 20:19
Bowen Li       Re: Mon, 08 Jul, 22:35
tangkailin   [No Subject] Thu, 18 Jul, 02:36
Rong Rong     Re: Thu, 18 Jul, 15:46
wang xuchen How does Flink recovers uncommited Kafka offset in AsyncIO? Mon, 01 Jul, 19:40
Fabian Hueske   Re: How does Flink recovers uncommited Kafka offset in AsyncIO? Mon, 08 Jul, 15:13
Hailu, Andreas File Naming Pattern from HadoopOutputFormat Mon, 01 Jul, 20:15
Haibo Sun   Re:File Naming Pattern from HadoopOutputFormat Tue, 02 Jul, 03:18
Yitzchak Lieberman     Re: File Naming Pattern from HadoopOutputFormat Tue, 02 Jul, 08:33
Haibo Sun       Re:Re: File Naming Pattern from HadoopOutputFormat Tue, 02 Jul, 09:56
Hailu, Andreas         RE: Re:Re: File Naming Pattern from HadoopOutputFormat Wed, 03 Jul, 13:11
Haibo Sun           Re:RE: Re:Re: File Naming Pattern from HadoopOutputFormat Thu, 04 Jul, 01:37
Hailu, Andreas             RE: Re:RE: Re:Re: File Naming Pattern from HadoopOutputFormat Thu, 04 Jul, 15:53
Ken Krugler Random errors reading binary files in batch workflow Tue, 02 Jul, 00:13
Ever Job tasks are not balance among taskmanagers Tue, 02 Jul, 03:42
Haibo Sun   Re:Job tasks are not balance among taskmanagers Tue, 02 Jul, 04:23
Ken Krugler     Re: Job tasks are not balance among taskmanagers Tue, 02 Jul, 14:30
Avi Levi Setting consumer offset Tue, 02 Jul, 07:11
Paul Lam   Re: Setting consumer offset Tue, 02 Jul, 07:24
Patro, Samya Flink not able to load native rocksdb library Tue, 02 Jul, 08:23
Re: RE: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component
vino yang   Re: RE: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component Tue, 02 Jul, 08:45
Re: Maybe a flink bug. Job keeps in FAILING state
Till Rohrmann   Re: Maybe a flink bug. Job keeps in FAILING state Tue, 02 Jul, 08:56
Re: Flink Kafka ordered offset commit & unordered processing
Piotr Nowojski   Re: Flink Kafka ordered offset commit & unordered processing Tue, 02 Jul, 09:05
Piotr Nowojski   Re: Flink Kafka ordered offset commit & unordered processing Wed, 03 Jul, 13:59
Re: Connection refused while trying to query state
Kostas Kloudas   Re: Connection refused while trying to query state Tue, 02 Jul, 09:16
Avi Levi     Re: Connection refused while trying to query state Tue, 02 Jul, 10:11
Kostas Kloudas       Re: Connection refused while trying to query state Tue, 02 Jul, 11:13
Patro, Samya Could not load the native RocksDB library Tue, 02 Jul, 09:16
Haibo Sun   Re:Could not load the native RocksDB library Wed, 03 Jul, 03:20
Andrey Zagrebin     Re: Could not load the native RocksDB library Wed, 03 Jul, 15:08
Soheil Pourbafrani Can Flink infers the table columns type Tue, 02 Jul, 18:36
Dawid Wysakowicz   Re: Can Flink infers the table columns type Thu, 04 Jul, 11:44
jincheng sun [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 01:39
Hequn Cheng   Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 01:47
jincheng sun     Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 02:08
Dian Fu       Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 02:15
Tzu-Li (Gordon) Tai         Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 02:19
Kurt Young           Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 02:20
Jark Wu         Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 02:22
Congxian Qiu           Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 06:35
JingsongLee             Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 06:38
Dawid Wysakowicz               Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 08:23
jincheng sun                 Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 13:25
Halfon, Roey Flink Application JAR Wed, 03 Jul, 10:38
Timothy Victor   Re: Flink Application JAR Wed, 03 Jul, 11:30
Halfon, Roey     RE: Flink Application JAR Wed, 03 Jul, 11:49
Timothy Victor       Re: Flink Application JAR Wed, 03 Jul, 12:32
RE: Flink error handling
Halfon, Roey   RE: Flink error handling Wed, 03 Jul, 11:02
Steven Nelson     Re: Flink error handling Wed, 03 Jul, 12:34
Re: Job recovers from an old dangling CheckPoint in case of Job Cluster based Flink pipeline
Vishal Santoshi   Re: Job recovers from an old dangling CheckPoint in case of Job Cluster based Flink pipeline Wed, 03 Jul, 12:26
Avi Levi Queryable state and TTL Wed, 03 Jul, 13:17
Andrey Zagrebin   Re: Queryable state and TTL Wed, 03 Jul, 15:13
Yu Li     Re: Queryable state and TTL Thu, 04 Jul, 04:13
Avi Levi       Re: Queryable state and TTL Thu, 04 Jul, 06:20
Eron Wright         Re: Queryable state and TTL Sun, 07 Jul, 02:40
Avi Levi           Re: Queryable state and TTL Sun, 07 Jul, 04:05
Juan Gentile Watermarks and Kafka Wed, 03 Jul, 16:04
Konstantin Knauf   Re: Watermarks and Kafka Sun, 07 Jul, 20:13
Juan Gentile     Re: Watermarks and Kafka Mon, 08 Jul, 09:10
Soheil Pourbafrani Load database table with many columns Wed, 03 Jul, 19:20
Haibo Sun   Re:Load database table with many columns Thu, 04 Jul, 03:15
Re: Source Kafka and Sink Hive managed tables via Flink Job
Bowen Li   Re: Source Kafka and Sink Hive managed tables via Flink Job Wed, 03 Jul, 19:39
Youssef Achbany     Re: Source Kafka and Sink Hive managed tables via Flink Job Thu, 04 Jul, 13:50
Bowen Li       Re: Source Kafka and Sink Hive managed tables via Flink Job Thu, 04 Jul, 16:58
Eduardo Winpenny Tejedor Migrating existing application to Flink Wed, 03 Jul, 22:38
Konstantin Knauf   Re: Migrating existing application to Flink Sun, 07 Jul, 08:33
Eduardo Winpenny Tejedor     Re: Migrating existing application to Flink Fri, 12 Jul, 07:48
Oytun Tez     Re: Migrating existing application to Flink Fri, 12 Jul, 15:42
vino yang [DISCUSS] Make window state queryable Thu, 04 Jul, 03:41
Andrea Spina Providing Custom Serializer for Generic Type Thu, 04 Jul, 06:37
JingsongLee   Re: Providing Custom Serializer for Generic Type Thu, 04 Jul, 06:46
Andrea Spina     Re: Providing Custom Serializer for Generic Type Thu, 04 Jul, 09:08
Tzu-Li (Gordon) Tai       Re: Providing Custom Serializer for Generic Type Thu, 04 Jul, 09:23
Andrea Spina         Re: Providing Custom Serializer for Generic Type Fri, 05 Jul, 07:09
Re: Debug Kryo.Serialization Exception
Flavio Pompermaier   Re: Debug Kryo.Serialization Exception Thu, 04 Jul, 09:25
Fabian Wollert     Re: Debug Kryo.Serialization Exception Thu, 04 Jul, 09:28
Tzu-Li (Gordon) Tai       Re: Debug Kryo.Serialization Exception Thu, 04 Jul, 09:51
Fabian Wollert         Re: Debug Kryo.Serialization Exception Thu, 04 Jul, 09:55
Halfon, Roey Tracking message processing in my application Thu, 04 Jul, 12:29
Haibo Sun   Re:Tracking message processing in my application Fri, 05 Jul, 03:34
Rauch, Jochen UnsupportedOperationException from org.apache.flink.shaded.asm6.org.objectweb.asm.ClassVisitor.visitNestHostExperimental using Java 11 Thu, 04 Jul, 13:34
Chesnay Schepler   Re: UnsupportedOperationException from org.apache.flink.shaded.asm6.org.objectweb.asm.ClassVisitor.visitNestHostExperimental using Java 11 Thu, 04 Jul, 13:38
Apache Flink - How to find the number of window instances in an application
M Singh   Apache Flink - How to find the number of window instances in an application Thu, 04 Jul, 17:40
Chesnay Schepler     Re: Apache Flink - How to find the number of window instances in an application Thu, 04 Jul, 17:51
Xingcan Cui [VOTE] How to Deal with Split/Select in DataStream API Thu, 04 Jul, 18:19
Hao Sun   Re: [VOTE] How to Deal with Split/Select in DataStream API Thu, 04 Jul, 21:19
Xingcan Cui   Re: [VOTE] How to Deal with Split/Select in DataStream API Mon, 08 Jul, 04:39
Aljoscha Krettek     Re: [VOTE] How to Deal with Split/Select in DataStream API Mon, 08 Jul, 14:17
Xingcan Cui       Re: [VOTE] How to Deal with Split/Select in DataStream API Tue, 09 Jul, 03:38
liu ze does mapFunction need to implement CheckpointedFunction? Fri, 05 Jul, 06:34
Biao Liu   Re: does mapFunction need to implement CheckpointedFunction? Fri, 05 Jul, 09:29
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Oct 2019268
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