flink-user mailing list archives: August 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · Next »Thread · Author · Date
杨光 HA setting for per-job YARN session Mon, 06 Aug, 04:25
杨力 Flink 1.6 ExecutionJobVertex.getTaskInformationOrBlobKey OutOfMemoryError Mon, 13 Aug, 14:25
杨力 Re: Flink 1.6 ExecutionJobVertex.getTaskInformationOrBlobKey OutOfMemoryError Tue, 14 Aug, 01:54
苗元君 ProcessWindowFunction Thu, 09 Aug, 02:10
苗元君 How to compare two window ? Thu, 16 Aug, 06:26
远远 kafka consumer can not auto commit Wed, 22 Aug, 10:37
Zhijiang(wangzhijiang999) 回复:Kryo Serialization Issue Tue, 28 Aug, 10:01
Zhijiang(wangzhijiang999) 回复:Backpressure? for Batches Wed, 29 Aug, 09:03
Zhijiang(wangzhijiang999) 回复:Backpressure? for Batches Wed, 29 Aug, 10:40
Zhijiang(wangzhijiang999) 回复:Backpressure? for Batches Wed, 29 Aug, 16:11
Dominik Wosiński Re: Initial value of ValueStates of primitive types Fri, 17 Aug, 09:57
Dominik Wosiński Re: Flink Jobmanager Failover in HA mode Fri, 17 Aug, 18:04
Dominik Wosiński Re: Flink not rolling log files Fri, 17 Aug, 18:15
Dominik Wosiński Re: Cluster die when one of the TM killed Mon, 20 Aug, 14:34
Dominik Wosiński Re: Flink checkpointing to Google Cloud Storage Tue, 21 Aug, 07:45
Dominik Wosiński Fwd: would you join a Slack workspace for Flink? Sun, 26 Aug, 13:13
Dominik Wosiński Dealing with Not Serializable classes in Java Sun, 26 Aug, 15:58
Dominik Wosiński Re: Dealing with Not Serializable classes in Java Mon, 27 Aug, 08:28
Dominik Wosiński Re: Dealing with Not Serializable classes in Java Mon, 27 Aug, 09:02
Gyula Fóra Re: Some questions about the StreamingFileSink Wed, 22 Aug, 08:48
Laura Uzcátegui CompletedCheckpoints are getting Stale ( Flink 1.4.2 ) Thu, 30 Aug, 14:52
Laura Uzcátegui Re: CompletedCheckpoints are getting Stale ( Flink 1.4.2 ) Fri, 31 Aug, 07:50
françois lacombe [1.6.0] Read content of Csv file with new table connectors Mon, 13 Aug, 17:29
françois lacombe AvroSchemaConverter and Tuple<T> classes Thu, 23 Aug, 16:54
françois lacombe Re: AvroSchemaConverter and Tuple<T> classes Fri, 24 Aug, 15:03
françois lacombe Re: AvroSchemaConverter and Tuple<T> classes Mon, 27 Aug, 14:22
françois lacombe withFormat(Csv) is undefined for the type BatchTableEnvironment Mon, 27 Aug, 14:26
françois lacombe Re: withFormat(Csv) is undefined for the type BatchTableEnvironment Wed, 29 Aug, 14:54
françois lacombe Re: withFormat(Csv) is undefined for the type BatchTableEnvironment Thu, 30 Aug, 15:19
françois lacombe Table API: get Schema from TableSchema, TypeInformation<?>[] or Avro Fri, 31 Aug, 05:40
françois lacombe Re: Table API: get Schema from TableSchema, TypeInformation<?>[] or Avro Fri, 31 Aug, 06:36
françois lacombe Re: Table API: get Schema from TableSchema, TypeInformation<?>[] or Avro Fri, 31 Aug, 08:30
徐涛 flink requires table key when insert into upsert table sink Fri, 10 Aug, 15:06
徐涛 Re: flink requires table key when insert into upsert table sink Fri, 10 Aug, 22:02
徐涛 Flink SQL does not support rename after cast type Tue, 14 Aug, 04:51
徐涛 Re: Flink SQL does not support rename after cast type Thu, 16 Aug, 10:38
徐涛 How does flink know which data is modified in dynamic table? Mon, 20 Aug, 10:43
徐涛 How does flink know which data is modified in dynamic table? Mon, 20 Aug, 10:43
徐涛 How does flink know which data is modified in dynamic table? Mon, 20 Aug, 10:44
徐涛 Re: How does flink know which data is modified in dynamic table? Tue, 21 Aug, 01:44
徐涛 Re: How does flink know which data is modified in dynamic table? Tue, 21 Aug, 02:21
徐涛 Re: How does flink know which data is modified in dynamic table? Tue, 21 Aug, 04:34
徐涛 Will idle state retention trigger retract in dynamic table? Tue, 21 Aug, 08:04
徐涛 Re: Will idle state retention trigger retract in dynamic table? Tue, 21 Aug, 08:52
徐涛 Re: Will idle state retention trigger retract in dynamic table? Tue, 21 Aug, 10:03
徐涛 Semantic when table joins table from window Tue, 21 Aug, 10:19
徐涛 Re: Semantic when table joins table from window Tue, 21 Aug, 12:52
徐涛 Re: Semantic when table joins table from window Tue, 21 Aug, 14:07
徐涛 Re: Semantic when table joins table from window Wed, 22 Aug, 06:50
徐涛 lack of function and low usability of provided function Thu, 23 Aug, 07:11
徐涛 Can I only use checkpoints instead of savepoints in production? Fri, 24 Aug, 06:54
徐涛 Re: Semantic when table joins table from window Tue, 28 Aug, 09:42
徐涛 Re: Semantic when table joins table from window Tue, 28 Aug, 13:47
祁明良 Window state with rocksdb backend Thu, 09 Aug, 08:36
祁明良 Tuning checkpoint Sun, 12 Aug, 16:36
祁明良 flink on kubernetes Mon, 13 Aug, 03:55
祁明良 Re: Tuning checkpoint Tue, 14 Aug, 02:16
祁明良 Stream collector serialization performance Wed, 15 Aug, 07:06
祁明良 Batch expired in FlinkKafkaProducer09 Wed, 22 Aug, 09:08
네이버 Re: Running SQL to print to Std Out Tue, 07 Aug, 22:43
네이버 unsubcscribe Tue, 07 Aug, 23:51
네이버 unsubscribtion Wed, 08 Aug, 06:18
Dominik Wosiński ODP: docker, error NoResourceAvailableException.. Wed, 15 Aug, 10:10
Jörn Franke Re: Converting a DataStream into a Table throws error Thu, 02 Aug, 05:19
Jörn Franke Re: Working out through individual messages in Flink Tue, 07 Aug, 22:29
Jörn Franke Re: Working out through individual messages in Flink Tue, 07 Aug, 22:30
Jörn Franke Re: Small-files source - partitioning based on prefix of file Fri, 10 Aug, 07:10
Jörn Franke Re: Limit on number of files to read for Dataset Tue, 14 Aug, 06:19
Jörn Franke Re: Low Performance in High Cardinality Big Window Application Mon, 27 Aug, 05:47
Aaron Levin Scala 2.12 Support Wed, 15 Aug, 15:59
Aaron Levin Re: Scala 2.12 Support Thu, 16 Aug, 15:08
Aarti Gupta Grok and Flink Thu, 30 Aug, 11:45
Aarti Gupta Re: Grok and Flink Thu, 30 Aug, 12:44
Addison Higham Using a ProcessFunction as a "Source" Fri, 24 Aug, 16:46
Alex Vinnik Why checkpoint took so long Thu, 16 Aug, 19:03
Alex Vinnik Re: Why checkpoint took so long Fri, 17 Aug, 03:50
Alex Vinnik Re: Why checkpoint took so long Mon, 20 Aug, 15:51
Alexander Smirnov Flink log and out files Wed, 01 Aug, 15:19
Alexander Smirnov Re: Flink log and out files Wed, 01 Aug, 19:27
Alexander Smirnov High CPU usage Fri, 17 Aug, 12:13
Alexander Smirnov How do I investigate checkpoints failures Tue, 21 Aug, 07:10
Alexander Smirnov Kryo exception Wed, 29 Aug, 14:18
Alexander Smirnov Re: Kryo exception Thu, 30 Aug, 05:49
Alexey Trenikhun Managed Keyed state update Mon, 13 Aug, 20:58
Alexey Trenikhun Re: Managed Keyed state update Tue, 14 Aug, 00:07
Alexis Sarda JDBCInputFormat and SplitDataProperties Tue, 07 Aug, 20:32
Alexis Sarda Re: JDBCInputFormat and SplitDataProperties Wed, 08 Aug, 12:10
Alexis Sarda Re: JDBCInputFormat and SplitDataProperties Thu, 09 Aug, 09:22
Alexis Sarda Re: JDBCInputFormat and SplitDataProperties Fri, 10 Aug, 10:04
Alexis Sarda Re: JDBCInputFormat and SplitDataProperties Fri, 10 Aug, 13:35
Aljoscha Krettek Re: Access to Kafka Event Time Tue, 07 Aug, 08:19
Aljoscha Krettek Re: Window state with rocksdb backend Thu, 09 Aug, 11:54
Aljoscha Krettek Re: classloading strangeness with Avro in Flink Tue, 21 Aug, 09:11
Aljoscha Krettek Re: State TTL in Flink 1.6.0 Wed, 22 Aug, 09:57
Aljoscha Krettek Re: Using a ProcessFunction as a "Source" Thu, 30 Aug, 10:07
Andrew Roberts ProcessingTimeSessionWindows and many other windowing pieces are built around Object Fri, 17 Aug, 11:49
Andrey Zagrebin Re: Could not retrieve the redirect address - No REST endpoint has been started Wed, 01 Aug, 14:59
Andrey Zagrebin Re: Flink log and out files Wed, 01 Aug, 15:59
Andrey Zagrebin Re: A litte doubt about the usage of checkpointLock Tue, 14 Aug, 17:21
Andrey Zagrebin Re: State TTL in Flink 1.6.0 Fri, 24 Aug, 09:15
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · Next »Thread · Author · Date
Box list
Aug 2019384
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