flink-user mailing list archives: July 2019

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Alex.Hu Re:Re: About "Flink 1.7.0 HA based on zookeepers " Mon, 01 Jul, 02:17
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
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: Batch mode with Flink 1.8 unstable? Mon, 01 Jul, 09:57
M Singh Apache Flink - Multiple Kinesis stream consumers Mon, 01 Jul, 10:28
M Singh Re: Apache Flink - Running application with different flink configurations (flink-conf.yml) on EMR Mon, 01 Jul, 10:30
Flavio Pompermaier Re: LookupableTableSource question Mon, 01 Jul, 13:26
Till Rohrmann Re: Batch mode with Flink 1.8 unstable? Mon, 01 Jul, 14:20
Till Rohrmann Re: [FLINK-10868] the job cannot be exited immediately if job manager is timed out Mon, 01 Jul, 14:48
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
wang xuchen [No Subject] Mon, 01 Jul, 19:38
wang xuchen How does Flink recovers uncommited Kafka offset in AsyncIO? Mon, 01 Jul, 19:40
Hailu, Andreas File Naming Pattern from HadoopOutputFormat Mon, 01 Jul, 20:15
Ken Krugler Re: Batch mode with Flink 1.8 unstable? Mon, 01 Jul, 22:23
Ken Krugler Random errors reading binary files in batch workflow Tue, 02 Jul, 00:13
Ken Krugler Re: Batch mode with Flink 1.8 unstable? Tue, 02 Jul, 00:21
Haibo Sun Re:File Naming Pattern from HadoopOutputFormat Tue, 02 Jul, 03:18
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
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
Yitzchak Lieberman Re: File Naming Pattern from HadoopOutputFormat Tue, 02 Jul, 08:33
vino yang Re: RE: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component Tue, 02 Jul, 08:45
Till Rohrmann Re: Maybe a flink bug. Job keeps in FAILING state Tue, 02 Jul, 08:56
Piotr Nowojski Re: Flink Kafka ordered offset commit & unordered processing Tue, 02 Jul, 09:05
Kostas Kloudas Re: Connection refused while trying to query state Tue, 02 Jul, 09:16
Patro, Samya Could not load the native RocksDB library Tue, 02 Jul, 09:16
Till Rohrmann Re: Batch mode with Flink 1.8 unstable? Tue, 02 Jul, 09:26
Haibo Sun Re:Re: File Naming Pattern from HadoopOutputFormat Tue, 02 Jul, 09:56
JingsongLee Re: LookupableTableSource question Tue, 02 Jul, 10:02
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
Till Rohrmann Re: Fw:Re:Re: About "Flink 1.7.0 HA based on zookeepers " Tue, 02 Jul, 13:46
Ken Krugler Re: Job tasks are not balance among taskmanagers Tue, 02 Jul, 14:30
Soheil Pourbafrani Can Flink infers the table columns type Tue, 02 Jul, 18:36
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
Alex.Hu Re:Re: Fw:Re:Re: About "Flink 1.7.0 HA based on zookeepers " Wed, 03 Jul, 02:20
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
Haibo Sun Re:Could not load the native RocksDB library Wed, 03 Jul, 03:20
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
Halfon, Roey Flink Application JAR Wed, 03 Jul, 10:38
Halfon, Roey RE: Flink error handling Wed, 03 Jul, 11:02
Timothy Victor Re: Flink Application JAR Wed, 03 Jul, 11:30
Halfon, Roey RE: Flink Application JAR Wed, 03 Jul, 11:49
Vishal Santoshi Re: Job recovers from an old dangling CheckPoint in case of Job Cluster based Flink pipeline Wed, 03 Jul, 12:26
Timothy Victor Re: Flink Application JAR Wed, 03 Jul, 12:32
Steven Nelson Re: Flink error handling Wed, 03 Jul, 12:34
Hailu, Andreas RE: Re:Re: File Naming Pattern from HadoopOutputFormat Wed, 03 Jul, 13:11
Avi Levi Queryable state and TTL Wed, 03 Jul, 13:17
jincheng sun Re: [ANNOUNCE] Apache Flink 1.8.1 released Wed, 03 Jul, 13:25
Piotr Nowojski Re: Flink Kafka ordered offset commit & unordered processing Wed, 03 Jul, 13:59
Andrey Zagrebin Re: Could not load the native RocksDB library Wed, 03 Jul, 15:08
Andrey Zagrebin Re: Queryable state and TTL Wed, 03 Jul, 15:13
Juan Gentile Watermarks and Kafka Wed, 03 Jul, 16:04
Soheil Pourbafrani Load database table with many columns Wed, 03 Jul, 19:20
Bowen Li Re: Source Kafka and Sink Hive managed tables via Flink Job Wed, 03 Jul, 19:39
Eduardo Winpenny Tejedor Migrating existing application to Flink Wed, 03 Jul, 22:38
Haibo Sun Re:RE: Re:Re: File Naming Pattern from HadoopOutputFormat Thu, 04 Jul, 01:37
Haibo Sun Re:Load database table with many columns Thu, 04 Jul, 03:15
vino yang [DISCUSS] Make window state queryable Thu, 04 Jul, 03:41
Yu Li Re: Queryable state and TTL Thu, 04 Jul, 04:13
Avi Levi Re: Queryable state and TTL Thu, 04 Jul, 06:20
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
Anyang Hu Re: [FLINK-10868] job cannot be exited immediately if job manager is timed out for some reason Thu, 04 Jul, 07:45
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
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
Dawid Wysakowicz Re: Can Flink infers the table columns type Thu, 04 Jul, 11:44
Halfon, Roey Tracking message processing in my application Thu, 04 Jul, 12:29
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
Youssef Achbany Re: Source Kafka and Sink Hive managed tables via Flink Job Thu, 04 Jul, 13:50
Hailu, Andreas RE: Re:RE: Re:Re: File Naming Pattern from HadoopOutputFormat Thu, 04 Jul, 15:53
Bowen Li Re: Source Kafka and Sink Hive managed tables via Flink Job Thu, 04 Jul, 16:58
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
Haibo Sun Re:Tracking message processing in my application Fri, 05 Jul, 03:34
liu ze does mapFunction need to implement CheckpointedFunction? Fri, 05 Jul, 06:34
Andrea Spina Re: Providing Custom Serializer for Generic Type Fri, 05 Jul, 07:09
Biao Liu Re: does mapFunction need to implement CheckpointedFunction? Fri, 05 Jul, 09:29
Flavio Pompermaier Flink Table API and Date fields Fri, 05 Jul, 14:51
Juan Gentile FlinkKafkaConsumer - Save watermark assigner in the state Fri, 05 Jul, 15:07
John Smith How are kafka consumer offsets handled if sink fails? Fri, 05 Jul, 18:36
Soheil Pourbafrani Cannot write DataSet<Row> as csv file Sat, 06 Jul, 13:48
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · Next »Thread · Author · Date
Box list
Sep 2019233
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