flink-user mailing list archives: April 2019

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Re: kafka corrupt record exception
Congxian Qiu   Re: kafka corrupt record exception Mon, 01 Apr, 02:04
Sushant Sawant     Re: kafka corrupt record exception Mon, 01 Apr, 15:19
Ilya Karpov       Re: kafka corrupt record exception Tue, 02 Apr, 07:36
Dominik Wosiński         Re: kafka corrupt record exception Tue, 02 Apr, 14:16
Sushant Sawant           Re: kafka corrupt record exception Mon, 08 Apr, 18:45
Dominik Wosiński             Re: kafka corrupt record exception Thu, 25 Apr, 10:46
alaa Reading csv file Mon, 01 Apr, 06:33
Zili Chen   Re: Reading csv file Mon, 01 Apr, 06:36
alaa     Re: Reading csv file Mon, 01 Apr, 06:42
Zili Chen       Re: Reading csv file Mon, 01 Apr, 06:49
alaa         Re: Reading csv file Mon, 01 Apr, 07:04
alaa     Re: Reading csv file Mon, 01 Apr, 06:45
Re: End-to-end exactly-once semantics in simple streaming app
Patrick Fial   Re: End-to-end exactly-once semantics in simple streaming app Mon, 01 Apr, 06:56
Fabian Hueske     Re: End-to-end exactly-once semantics in simple streaming app Mon, 08 Apr, 10:16
Piotr Nowojski       Re: End-to-end exactly-once semantics in simple streaming app Mon, 08 Apr, 11:20
sora Flink: How to use zookeeper when deployed in k8s? Mon, 01 Apr, 07:28
Ufuk Celebi   Re: Flink: How to use zookeeper when deployed in k8s? Mon, 01 Apr, 14:08
孙森 subscribe Mon, 01 Apr, 07:54
peibin wang How can I get the right TaskExecutor in ProcessFunction Mon, 01 Apr, 09:33
Andrey Zagrebin   Re: How can I get the right TaskExecutor in ProcessFunction Tue, 02 Apr, 08:14
huang🙃 How can I get timestamp message when restore from savepoint? Mon, 01 Apr, 10:00
Yun Tang   Re: How can I get timestamp message when restore from savepoint? Mon, 01 Apr, 11:13
huang🙃     回复: How can I get timestamp message when restore from savepoint? Mon, 01 Apr, 12:52
Re: Does flink configuration support configed by environment variables?
Stephen Connolly   Re: Does flink configuration support configed by environment variables? Mon, 01 Apr, 14:23
Lifei Chen     Re: Does flink configuration support configed by environment variables? Mon, 01 Apr, 15:24
Re: Do we have an example of setting up Queryable state ( proxies, client etc ) on k8s ?
Vishal Santoshi   Re: Do we have an example of setting up Queryable state ( proxies, client etc ) on k8s ? Mon, 01 Apr, 14:39
BucketAssigner - Confusion
Jeff Crane   BucketAssigner - Confusion Mon, 01 Apr, 18:33
Jeff Crane     Re: BucketAssigner - Confusion Tue, 02 Apr, 18:18
Chesnay Schepler       Re: BucketAssigner - Confusion Wed, 03 Apr, 10:18
Metrics for received records per TaskManager
Benjamin Burkhardt   Metrics for received records per TaskManager Tue, 02 Apr, 07:00
Yun Tang     Re: Metrics for received records per TaskManager Tue, 02 Apr, 08:28
Benjamin Burkhardt       Re: Metrics for received records per TaskManager Tue, 02 Apr, 13:56
Yun Tang         Re: Metrics for received records per TaskManager Tue, 02 Apr, 16:17
Benjamin Burkhardt           Re: Metrics for received records per TaskManager Tue, 02 Apr, 16:21
Yun Tang           Re: Metrics for received records per TaskManager Tue, 02 Apr, 18:22
徐涛 Any suggestions about which GC collector to use in Flink? Tue, 02 Apr, 07:26
qi luo   Re: Any suggestions about which GC collector to use in Flink? Tue, 02 Apr, 12:43
Re: How to run a job with job cluster mode on top of mesos?
Jacky Yin 殷传旺   Re: How to run a job with job cluster mode on top of mesos? Tue, 02 Apr, 09:17
Till Rohrmann     Re: How to run a job with job cluster mode on top of mesos? Tue, 02 Apr, 14:47
Till Rohrmann       Re: How to run a job with job cluster mode on top of mesos? Tue, 02 Apr, 14:49
Jacky Yin 殷传旺         Re: How to run a job with job cluster mode on top of mesos? Tue, 02 Apr, 14:55
Papadopoulos, Konstantinos InvalidProgramException when trying to sort a group within a dataset Tue, 02 Apr, 10:31
Chesnay Schepler   Re: InvalidProgramException when trying to sort a group within a dataset Wed, 03 Apr, 09:59
Papadopoulos, Konstantinos     RE: InvalidProgramException when trying to sort a group within a dataset Wed, 03 Apr, 11:21
Fabian Hueske       Re: InvalidProgramException when trying to sort a group within a dataset Fri, 05 Apr, 23:25
Papadopoulos, Konstantinos         RE: InvalidProgramException when trying to sort a group within a dataset Mon, 08 Apr, 07:13
Fabian Hueske           Re: InvalidProgramException when trying to sort a group within a dataset Mon, 08 Apr, 08:36
Papadopoulos, Konstantinos             RE: InvalidProgramException when trying to sort a group within a dataset Mon, 08 Apr, 14:37
WILSON Frank End to End Performance Testing Tue, 02 Apr, 10:49
Yu Li   Re: End to End Performance Testing Thu, 04 Apr, 05:00
Marke Builder Use different functions for different signal values Tue, 02 Apr, 15:41
Ken Krugler   Re: Use different functions for different signal values Tue, 02 Apr, 23:17
Hequn Cheng     Re: Use different functions for different signal values Wed, 03 Apr, 05:15
Re: long lived standalone job session cluster in kubernetes
Till Rohrmann   Re: long lived standalone job session cluster in kubernetes Tue, 02 Apr, 18:41
Vijay Balakrishnan Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple Wed, 03 Apr, 00:02
Timothy Victor   Re: Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple Wed, 03 Apr, 01:06
Vijay Balakrishnan     Re: Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple Wed, 03 Apr, 15:36
Chesnay Schepler       Re: Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple Fri, 05 Apr, 12:53
Timothy Victor         Re: Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple Sun, 07 Apr, 01:02
abhishek sharma           Re: Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple Mon, 08 Apr, 00:40
Vijay Balakrishnan             Re: Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple Thu, 11 Apr, 15:35
Re:Consume only a few of kafka topic partitions
shengjk1   Re:Consume only a few of kafka topic partitions Wed, 03 Apr, 06:44
Re: Reserving Kafka offset in Flink after modifying app
shengjk1   Re: Reserving Kafka offset in Flink after modifying app Wed, 03 Apr, 06:52
徐涛 Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded Wed, 03 Apr, 10:34
Fabian Hueske   Re: Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded Mon, 08 Apr, 10:25
徐涛     Re: Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded Mon, 08 Apr, 11:51
Chesnay Schepler [DISCUSS] Drop Elasticssearch 1 connector Wed, 03 Apr, 12:09
Bowen Li   Re: [DISCUSS] Drop Elasticssearch 1 connector Fri, 05 Apr, 18:11
Stephan Ewen     Re: [DISCUSS] Drop Elasticssearch 1 connector Fri, 05 Apr, 22:51
vino yang       Re: [DISCUSS] Drop Elasticssearch 1 connector Tue, 09 Apr, 07:06
Reminia Scarlet Install flink-1.7.2 on Azure with Hadoop 2.7 failed Wed, 03 Apr, 17:56
Guowei Ma   Re: Install flink-1.7.2 on Azure with Hadoop 2.7 failed Thu, 04 Apr, 03:34
Re: Source reinterpretAsKeyedStream
Konstantin Knauf   Re: Source reinterpretAsKeyedStream Wed, 03 Apr, 18:08
Adrienne Kole     Re: Source reinterpretAsKeyedStream Thu, 04 Apr, 18:25
Fabian Hueske       Re: Source reinterpretAsKeyedStream Fri, 05 Apr, 23:12
Re: TUMBLE function with MONTH/YEAR intervals produce milliseconds window unexpectedly
Vinod Mehra   Re: TUMBLE function with MONTH/YEAR intervals produce milliseconds window unexpectedly Wed, 03 Apr, 20:39
Re: Data loss when restoring from savepoint
Konstantin Knauf   Re: Data loss when restoring from savepoint Wed, 03 Apr, 21:31
Juho Autio     Re: Data loss when restoring from savepoint Thu, 04 Apr, 07:03
Konstantin Knauf       Re: Data loss when restoring from savepoint Wed, 10 Apr, 11:02
Konstantin Knauf         Re: Data loss when restoring from savepoint Wed, 10 Apr, 13:46
Juho Autio           Re: Data loss when restoring from savepoint Thu, 11 Apr, 08:32
Till Rohrmann             Re: Data loss when restoring from savepoint Thu, 11 Apr, 11:53
Juho Autio               Re: Data loss when restoring from savepoint Thu, 11 Apr, 12:30
Stefan Richter                 Re: Data loss when restoring from savepoint Thu, 11 Apr, 12:38
Konstantin Knauf                   Re: Data loss when restoring from savepoint Thu, 11 Apr, 13:01
Juho Autio                     Re: Data loss when restoring from savepoint Thu, 11 Apr, 13:21
Juho Autio                       Re: Data loss when restoring from savepoint Mon, 15 Apr, 07:49
Konstantin Knauf                         Re: Data loss when restoring from savepoint Mon, 15 Apr, 08:27
Juho Autio                           Re: Data loss when restoring from savepoint Tue, 16 Apr, 11:35
Juho Autio                             Re: Data loss when restoring from savepoint Thu, 18 Apr, 12:25
Oytun Tez                               Re: Data loss when restoring from savepoint Thu, 18 Apr, 14:05
Konstantin Knauf                                 Re: Data loss when restoring from savepoint Fri, 26 Apr, 14:05
Juho Autio         Re: Data loss when restoring from savepoint Thu, 11 Apr, 08:22
Son Mai How is Collector<T> out element processed? Thu, 04 Apr, 02:14
Zili Chen   Re: How is Collector<T> out element processed? Thu, 04 Apr, 02:45
Son Mai     Re: How is Collector<T> out element processed? Thu, 04 Apr, 04:11
Zili Chen       Re: How is Collector<T> out element processed? Thu, 04 Apr, 04:18
Aljoscha Krettek [ANNOUNCE] Release 1.8.0, release candidate #5 Thu, 04 Apr, 06:23
Esa Heikkinen (TAU) FlinkCEP and SQL? Thu, 04 Apr, 08:37
jincheng sun   Re: FlinkCEP and SQL? Thu, 04 Apr, 10:04
Esa Heikkinen (TAU)     RE: FlinkCEP and SQL? Thu, 04 Apr, 11:11
Dian Fu       Re: FlinkCEP and SQL? Thu, 04 Apr, 11:36
Esa Heikkinen (TAU)         RE: FlinkCEP and SQL? Thu, 11 Apr, 08:22
Fabian Hueske           Re: FlinkCEP and SQL? Thu, 11 Apr, 08:32
Esa Heikkinen (TAU)             RE: FlinkCEP and SQL? Thu, 11 Apr, 08:52
Dawid Wysakowicz               Re: FlinkCEP and SQL? Thu, 11 Apr, 09:59
Esa Heikkinen (TAU)                 RE: FlinkCEP and SQL? Thu, 11 Apr, 10:40
Dawid Wysakowicz                   Re: FlinkCEP and SQL? Thu, 11 Apr, 10:59
徐涛 How to submit Flink program to Yarn without upload the fat jar? Thu, 04 Apr, 09:35
Chesnay Schepler   Re: How to submit Flink program to Yarn without upload the fat jar? Fri, 05 Apr, 12:58
Andrey Zagrebin [Discuss] Semantics of event time for state TTL Thu, 04 Apr, 14:55
Elias Levy   Re: [Discuss] Semantics of event time for state TTL Thu, 04 Apr, 17:49
Konstantin Knauf     Re: [Discuss] Semantics of event time for state TTL Fri, 05 Apr, 23:30
Aljoscha Krettek       Re: [Discuss] Semantics of event time for state TTL Mon, 08 Apr, 09:12
Kostas Kloudas         Re: [Discuss] Semantics of event time for state TTL Mon, 08 Apr, 10:03
Aljoscha Krettek           Re: [Discuss] Semantics of event time for state TTL Mon, 08 Apr, 14:11
Elias Levy             Re: [Discuss] Semantics of event time for state TTL Mon, 08 Apr, 20:56
Aljoscha Krettek               Re: [Discuss] Semantics of event time for state TTL Tue, 09 Apr, 07:03
aitozi                 Re: [Discuss] Semantics of event time for state TTL Tue, 09 Apr, 15:11
Andrey Zagrebin                   Re: [Discuss] Semantics of event time for state TTL Mon, 15 Apr, 13:58
Yu Li                     Re: [Discuss] Semantics of event time for state TTL Tue, 16 Apr, 06:52
Felipe Gutierrez print() method does not always print on the taskmanager.out file Thu, 04 Apr, 16:04
Chesnay Schepler   Re: print() method does not always print on the taskmanager.out file Fri, 05 Apr, 12:50
Felipe Gutierrez     Re: print() method does not always print on the taskmanager.out file Fri, 05 Apr, 15:10
Felipe Gutierrez       Re: print() method does not always print on the taskmanager.out file Fri, 05 Apr, 16:01
Felipe Gutierrez         Re: print() method does not always print on the taskmanager.out file Mon, 08 Apr, 15:02
Yan Yan Cannot download Jars from S3 due to resource timestamp changed Thu, 04 Apr, 21:22
yangtao.yt   Re: Cannot download Jars from S3 due to resource timestamp changed Fri, 05 Apr, 00:45
Yan Yan     Re: Cannot download Jars from S3 due to resource timestamp changed Fri, 05 Apr, 21:23
Till Rohrmann       Re: Cannot download Jars from S3 due to resource timestamp changed Mon, 08 Apr, 08:04
Davood Rafiei Partitioning key range Thu, 04 Apr, 22:35
Congxian Qiu   Re: Partitioning key range Sat, 06 Apr, 09:27
Fabian Hueske     Re: Partitioning key range Mon, 08 Apr, 08:01
Ken Krugler       Re: Partitioning key range Mon, 08 Apr, 15:15
Davood Rafiei         Re: Partitioning key range Mon, 08 Apr, 16:10
Default Kafka producers pool size for FlinkKafkaProducer.Semantic.EXACTLY_ONCE
min....@ubs.com   Default Kafka producers pool size for FlinkKafkaProducer.Semantic.EXACTLY_ONCE Fri, 05 Apr, 07:52
min....@ubs.com   Default Kafka producers pool size for FlinkKafkaProducer.Semantic.EXACTLY_ONCE Mon, 08 Apr, 12:34
Fabian Hueske     Re: Default Kafka producers pool size for FlinkKafkaProducer.Semantic.EXACTLY_ONCE Thu, 11 Apr, 07:32
Piotr Nowojski       Re: Default Kafka producers pool size for FlinkKafkaProducer.Semantic.EXACTLY_ONCE Thu, 11 Apr, 13:00
min....@ubs.com         RE: Re: Default Kafka producers pool size for FlinkKafkaProducer.Semantic.EXACTLY_ONCE Thu, 11 Apr, 13:42
Juan Gentile Flink on Mesos Fri, 05 Apr, 12:33
Till Rohrmann   Re: Flink on Mesos Fri, 05 Apr, 14:45
Frank Wilson Enabling JMX Reporter on a Local Mini Cluster Fri, 05 Apr, 15:51
Frank Wilson   Re: Enabling JMX Reporter on a Local Mini Cluster Mon, 08 Apr, 10:19
anaray Flink 1.7.1 JobManager (docker) exits with status 0 - completed Fri, 05 Apr, 16:55
Boris Lublinsky HA and zookeeper Fri, 05 Apr, 23:28
Fabian Hueske   Re: HA and zookeeper Mon, 08 Apr, 10:29
Boris Lublinsky     Re: HA and zookeeper Mon, 08 Apr, 13:20
Konstantin Knauf       Re: HA and zookeeper Mon, 08 Apr, 13:35
min....@ubs.com Lantency caised Flink Checkpoint on EXACTLY_ONCE mode Sat, 06 Apr, 19:14
Guowei Ma   Re: Lantency caised Flink Checkpoint on EXACTLY_ONCE mode Sun, 07 Apr, 06:41
Fabian Hueske     Re: Lantency caised Flink Checkpoint on EXACTLY_ONCE mode Mon, 08 Apr, 08:10
min....@ubs.com     RE: Re: Lantency caised Flink Checkpoint on EXACTLY_ONCE mode Tue, 09 Apr, 09:27
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
May 2019361
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