flink-user mailing list archives: November 2016

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Re: watermark trigger doesn't check whether element's timestamp is passed
Manu Zhang   Re: watermark trigger doesn't check whether element's timestamp is passed Tue, 01 Nov, 01:26
Aljoscha Krettek     Re: watermark trigger doesn't check whether element's timestamp is passed Tue, 01 Nov, 17:07
Manu Zhang       Re: watermark trigger doesn't check whether element's timestamp is passed Tue, 01 Nov, 22:23
aj heller         Re: watermark trigger doesn't check whether element's timestamp is passed Tue, 01 Nov, 22:57
Aljoscha Krettek           Re: watermark trigger doesn't check whether element's timestamp is passed Wed, 02 Nov, 13:18
Ventura Del Monte             Re: watermark trigger doesn't check whether element's timestamp is passed Wed, 02 Nov, 15:08
Manu Zhang               Re: watermark trigger doesn't check whether element's timestamp is passed Wed, 02 Nov, 22:14
Li Wang Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 07:05
Till Rohrmann   Re: Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 12:56
Li Wang     Re: Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 14:03
Renjie Liu     Re: Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 14:29
Till Rohrmann       Re: Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 15:05
Renjie Liu         Re: Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 22:48
Till Rohrmann           Re: Question about the checkpoint mechanism in Flink. Wed, 02 Nov, 09:18
Renjie Liu             Re: Question about the checkpoint mechanism in Flink. Wed, 02 Nov, 09:39
Renjie Liu   Re: Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 14:21
Renjie Liu     Re: Question about the checkpoint mechanism in Flink. Tue, 01 Nov, 14:27
Re: Kinesis Connector Dependency Problems
Till Rohrmann   Re: Kinesis Connector Dependency Problems Tue, 01 Nov, 10:57
Justin Yan     Re: Kinesis Connector Dependency Problems Tue, 01 Nov, 17:27
Robert Metzger       Re: Kinesis Connector Dependency Problems Tue, 01 Nov, 18:44
Justin Yan         Re: Kinesis Connector Dependency Problems Wed, 02 Nov, 21:09
Robert Metzger           Re: Kinesis Connector Dependency Problems Fri, 04 Nov, 09:57
Foster, Craig             Re: Kinesis Connector Dependency Problems Mon, 07 Nov, 19:01
Till Rohrmann               Re: Kinesis Connector Dependency Problems Tue, 08 Nov, 10:05
Fabian Hueske                 Re: Kinesis Connector Dependency Problems Tue, 08 Nov, 10:11
Steffen Hausmann                   Re: Kinesis Connector Dependency Problems Tue, 08 Nov, 15:18
Foster, Craig                     Re: Kinesis Connector Dependency Problems Tue, 08 Nov, 22:38
Fabian Hueske                       Re: Kinesis Connector Dependency Problems Tue, 08 Nov, 22:42
Re: Elasticsearch sink: Java.lang.NoSuchMethodError: org.elasticsearch.common.settings.Settings.settingsBuilder
Till Rohrmann   Re: Elasticsearch sink: Java.lang.NoSuchMethodError: org.elasticsearch.common.settings.Settings.settingsBuilder Tue, 01 Nov, 13:05
Dominik Bruhn BoundedOutOfOrdernessTimestampExtractor and timestamps in the future Tue, 01 Nov, 14:05
Konstantin Knauf   Re: BoundedOutOfOrdernessTimestampExtractor and timestamps in the future Tue, 01 Nov, 21:02
Maximilian Michels     Re: BoundedOutOfOrdernessTimestampExtractor and timestamps in the future Thu, 03 Nov, 17:53
Re: Looping over a DataSet and accesing another DataSet
Greg Hogan   Re: Looping over a DataSet and accesing another DataSet Tue, 01 Nov, 16:13
otherwise777     Re: Looping over a DataSet and accesing another DataSet Wed, 02 Nov, 22:32
otherwise777     Re: Looping over a DataSet and accesing another DataSet Thu, 03 Nov, 08:37
Re: Can we do batch writes on cassandra using flink while leveraging the locality?
Stephan Ewen   Re: Can we do batch writes on cassandra using flink while leveraging the locality? Tue, 01 Nov, 19:29
Chesnay Schepler     Re: Can we do batch writes on cassandra using flink while leveraging the locality? Tue, 01 Nov, 20:15
Re: A custom FileInputFormat
Fabian Hueske   Re: A custom FileInputFormat Tue, 01 Nov, 20:59
Niklas Semmler     Re: A custom FileInputFormat Wed, 16 Nov, 19:13
Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation
Jamie Grier   Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Tue, 01 Nov, 21:43
Jamie Grier     Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Tue, 01 Nov, 21:51
Jamie Grier       Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Tue, 01 Nov, 22:08
Anchit Jatana         Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Tue, 01 Nov, 23:30
Jamie Grier           Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Wed, 02 Nov, 00:34
Anchit Jatana             Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Wed, 02 Nov, 00:48
Jamie Grier               Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Wed, 02 Nov, 14:04
Anchit Jatana                 Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Wed, 02 Nov, 17:33
Philipp Bussche                   Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation Thu, 03 Nov, 06:07
Re: Flink on YARN - Fault Tolerance | use case supported or not
Anchit Jatana   Re: Flink on YARN - Fault Tolerance | use case supported or not Tue, 01 Nov, 23:37
Ken Krugler TimelyFlatMapFunction and DataStream Wed, 02 Nov, 00:59
Stephan Ewen   Re: TimelyFlatMapFunction and DataStream Wed, 02 Nov, 10:04
Aljoscha Krettek     Re: TimelyFlatMapFunction and DataStream Wed, 02 Nov, 11:27
Ken Krugler     Re: TimelyFlatMapFunction and DataStream Wed, 02 Nov, 15:36
PedroMrChaves Best Practices/Advice - Execution of jobs Wed, 02 Nov, 09:16
Aljoscha Krettek   Re: Best Practices/Advice - Execution of jobs Thu, 03 Nov, 15:01
PedroMrChaves     Re: Best Practices/Advice - Execution of jobs Thu, 03 Nov, 16:32
Yassine MARZOUGUI Questions about FoldFunction and WindowFunction Wed, 02 Nov, 09:42
Aljoscha Krettek   Re: Questions about FoldFunction and WindowFunction Wed, 02 Nov, 11:30
Yassine MARZOUGUI     Re: Questions about FoldFunction and WindowFunction Wed, 02 Nov, 12:30
Aljoscha Krettek       Re: Questions about FoldFunction and WindowFunction Wed, 02 Nov, 13:07
Yassine MARZOUGUI         Re: Questions about FoldFunction and WindowFunction Wed, 02 Nov, 13:48
Aljoscha Krettek           Re: Questions about FoldFunction and WindowFunction Wed, 02 Nov, 14:37
Re: NotSerializableException: jdk.nashorn.api.scripting.NashornScriptEngine
PedroMrChaves   Re: NotSerializableException: jdk.nashorn.api.scripting.NashornScriptEngine Wed, 02 Nov, 14:47
Greg Hogan     Re: NotSerializableException: jdk.nashorn.api.scripting.NashornScriptEngine Thu, 03 Nov, 16:42
Juan Rodríguez Hortalá Testing DataStreams Wed, 02 Nov, 15:58
Maximilian Michels   Re: Testing DataStreams Thu, 03 Nov, 18:05
Juan Rodríguez Hortalá     Re: Testing DataStreams Fri, 04 Nov, 15:50
Anchit Jatana Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Wed, 02 Nov, 17:44
Maximilian Michels   Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Thu, 03 Nov, 18:08
Anchit Jatana     Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Thu, 03 Nov, 18:43
Maximilian Michels       Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Fri, 04 Nov, 10:06
Josh         Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Fri, 04 Nov, 13:27
Ufuk Celebi           Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Fri, 04 Nov, 13:52
Josh             Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Fri, 04 Nov, 14:28
Ufuk Celebi               Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Fri, 04 Nov, 14:33
Josh                 Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Fri, 04 Nov, 16:09
Ufuk Celebi                   Re: Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs Mon, 07 Nov, 10:46
Clifford Resnick Why are externalized checkpoints deleted on Job Manager exit? Wed, 02 Nov, 20:52
Aljoscha Krettek   Re: Why are externalized checkpoints deleted on Job Manager exit? Thu, 03 Nov, 13:04
Ufuk Celebi     Re: Why are externalized checkpoints deleted on Job Manager exit? Thu, 03 Nov, 14:00
Ufuk Celebi       Re: Why are externalized checkpoints deleted on Job Manager exit? Thu, 03 Nov, 14:23
Ufuk Celebi         Re: Why are externalized checkpoints deleted on Job Manager exit? Thu, 03 Nov, 14:56
Cliff Resnick           Re: Why are externalized checkpoints deleted on Job Manager exit? Tue, 15 Nov, 20:19
Sandeep Vakacharla Reg. custom sink for Flink streaming Wed, 02 Nov, 23:00
Will Du   Link read avro from Kafka Connect Issue Wed, 02 Nov, 23:31
Fabian Hueske   Re: Reg. custom sink for Flink streaming Thu, 03 Nov, 13:50
Re: Accessing StateBackend snapshots outside of Flink
bwong247   Re: Accessing StateBackend snapshots outside of Flink Thu, 03 Nov, 00:20
Aljoscha Krettek     Re: Accessing StateBackend snapshots outside of Flink Thu, 03 Nov, 12:59
Dominik Safaric Flink Kafka 0.10.0.0 connector Thu, 03 Nov, 07:05
Robert Metzger   Re: Flink Kafka 0.10.0.0 connector Thu, 03 Nov, 12:29
Dominik Safaric     Re: Flink Kafka 0.10.0.0 connector Thu, 03 Nov, 12:48
Robert Metzger       Re: Flink Kafka 0.10.0.0 connector Thu, 03 Nov, 12:59
Dominik Safaric         Re: Flink Kafka 0.10.0.0 connector Thu, 03 Nov, 17:14
Satish Chandra Gupta Best way of doing some global initialization Thu, 03 Nov, 08:26
Aljoscha Krettek   Re: Best way of doing some global initialization Thu, 03 Nov, 13:07
Satish Chandra Gupta     Re: Best way of doing some global initialization Thu, 03 Nov, 14:10
Aljoscha Krettek       Re: Best way of doing some global initialization Mon, 07 Nov, 17:44
Re: emit partial state in window (streaming)
Luis Mariano Guerra   Re: emit partial state in window (streaming) Thu, 03 Nov, 10:31
Kostas Kloudas     Re: emit partial state in window (streaming) Thu, 03 Nov, 13:06
Manu Zhang       Re: emit partial state in window (streaming) Thu, 03 Nov, 13:38
Luis Mariano Guerra       Re: emit partial state in window (streaming) Thu, 03 Nov, 14:29
Kostas Kloudas         Re: emit partial state in window (streaming) Thu, 03 Nov, 18:05
Luis Mariano Guerra           Re: emit partial state in window (streaming) Thu, 03 Nov, 18:08
Re: ExpiredIteratorException when reading from a Kinesis stream
Josh   Re: ExpiredIteratorException when reading from a Kinesis stream Thu, 03 Nov, 11:46
Tzu-Li (Gordon) Tai     Re: ExpiredIteratorException when reading from a Kinesis stream Thu, 03 Nov, 12:44
Josh       Re: ExpiredIteratorException when reading from a Kinesis stream Thu, 03 Nov, 14:08
Scott Kidder         Re: ExpiredIteratorException when reading from a Kinesis stream Thu, 03 Nov, 18:21
Stephan Ewen           Re: ExpiredIteratorException when reading from a Kinesis stream Thu, 03 Nov, 18:27
Josh             Re: ExpiredIteratorException when reading from a Kinesis stream Fri, 04 Nov, 11:19
Josh               Re: ExpiredIteratorException when reading from a Kinesis stream Sat, 05 Nov, 13:46
Oliver Swoboda Using Flink with Accumulo Thu, 03 Nov, 12:57
Josh Elser   Re: Using Flink with Accumulo Thu, 03 Nov, 16:03
Oliver Swoboda     Re: Using Flink with Accumulo Mon, 07 Nov, 14:34
Josh Elser       Re: Using Flink with Accumulo Mon, 07 Nov, 15:41
Yury Ruchin Freeing resources in SourceFunction Thu, 03 Nov, 13:45
Maximilian Michels   Re: Freeing resources in SourceFunction Thu, 03 Nov, 18:16
Re: What is the best way to load/add patterns dynamically (at runtime) with Flink?
PedroMrChaves   Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Thu, 03 Nov, 17:30
Aljoscha Krettek     Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Thu, 03 Nov, 18:11
PedroMrChaves       Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Thu, 03 Nov, 22:37
Aljoscha Krettek         Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Fri, 04 Nov, 09:42
kaelumania           Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Thu, 24 Nov, 15:17
Stephan Epping             Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Thu, 24 Nov, 15:44
PedroMrChaves               Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? Thu, 24 Nov, 15:58
Daniel Santos Flink Time Window State Thu, 03 Nov, 18:43
Aljoscha Krettek   Re: Flink Time Window State Fri, 04 Nov, 11:01
Daniel Santos     Re: Flink Time Window State Fri, 04 Nov, 15:39
Aljoscha Krettek       Re: Flink Time Window State Fri, 04 Nov, 17:54
Daniel Santos         Re: Flink Time Window State Mon, 07 Nov, 12:06
Ufuk Celebi           Re: Flink Time Window State Mon, 07 Nov, 12:45
Daniel Santos             Re: Flink Time Window State Mon, 07 Nov, 13:05
Ufuk Celebi               Re: Flink Time Window State Mon, 07 Nov, 13:39
Dominik Bruhn Release Process Thu, 03 Nov, 21:50
Fabian Hueske   Re: Release Process Thu, 03 Nov, 22:08
Chesnay Schepler   Re: Release Process Fri, 04 Nov, 21:21
Re: Retrieving a single element from a DataSet
otherwise777   Re: Retrieving a single element from a DataSet Fri, 04 Nov, 09:52
Greg Hogan     Re: Retrieving a single element from a DataSet Fri, 04 Nov, 11:57
Vasiliki Kalavri       Re: Retrieving a single element from a DataSet Sat, 05 Nov, 18:53
otherwise777         Re: Retrieving a single element from a DataSet Thu, 10 Nov, 13:41
Janardhan Reddy Flink Kafka Connector behaviour on leader change and broker upgrade Fri, 04 Nov, 10:19
Robert Metzger   Re: Flink Kafka Connector behaviour on leader change and broker upgrade Sun, 06 Nov, 12:21
Renjie Liu Flink stream job change and recovery Fri, 04 Nov, 10:24
Fabian Hueske   Re: Flink stream job change and recovery Fri, 04 Nov, 10:46
Renjie Liu     Re: Flink stream job change and recovery Fri, 04 Nov, 11:26
Fabian Hueske       Re: Flink stream job change and recovery Mon, 07 Nov, 09:00
Daniel Suo Parallelizing DataStream operations on Array elements Fri, 04 Nov, 16:45
Till Rohrmann   Re: Parallelizing DataStream operations on Array elements Fri, 04 Nov, 17:59
danielsuo     Re: Parallelizing DataStream operations on Array elements Fri, 04 Nov, 23:53
danielsuo       Re: Parallelizing DataStream operations on Array elements Sat, 05 Nov, 01:47
Till Rohrmann         Re: Parallelizing DataStream operations on Array elements Mon, 07 Nov, 13:57
Re: window-like use case
Maciek Próchniak   Re: window-like use case Fri, 04 Nov, 19:43
Aljoscha Krettek     Re: window-like use case Mon, 07 Nov, 17:36
Alberto Ramón Stephan "Apache Flink to very Large State" Sat, 05 Nov, 13:26
Till Rohrmann   Re: Stephan "Apache Flink to very Large State" Mon, 07 Nov, 14:14
Alberto Ramón     Re: Stephan "Apache Flink to very Large State" Mon, 07 Nov, 15:58
Samir Abdou Last event of each window belongs to the next window - Wrong Sun, 06 Nov, 11:11
Till Rohrmann   Re: Last event of each window belongs to the next window - Wrong Mon, 07 Nov, 14:42
Aljoscha Krettek     Re: Last event of each window belongs to the next window - Wrong Mon, 07 Nov, 17:04
Samir Abdou       Re: Last event of each window belongs to the next window - Wrong Tue, 08 Nov, 18:59
Aljoscha Krettek         Re: Last event of each window belongs to the next window - Wrong Wed, 09 Nov, 12:43
Samir Abdou           Re: Last event of each window belongs to the next window - Wrong Sat, 12 Nov, 19:01
Samir Abdou     Re: Last event of each window belongs to the next window - Wrong Tue, 08 Nov, 18:56
Felix Neutatz Csv to windows? Sun, 06 Nov, 11:36
Till Rohrmann   Re: Csv to windows? Mon, 07 Nov, 15:15
Felix Neutatz     Re: Csv to windows? Mon, 07 Nov, 18:18
Yassine MARZOUGUI       Re: Csv to windows? Mon, 07 Nov, 20:28
Felix Neutatz         Re: Csv to windows? Tue, 08 Nov, 09:17
Felix Neutatz           Re: Csv to windows? Sat, 12 Nov, 11:17
Ufuk Celebi             Re: Csv to windows? Mon, 14 Nov, 08:41
Felix Neutatz               Re: Csv to windows? Tue, 15 Nov, 10:24
subash basnet Datastream reset variable in every-time window in map function Sun, 06 Nov, 21:15
Till Rohrmann   Re: Datastream reset variable in every-time window in map function Mon, 07 Nov, 15:21
Dominique Rondé Lot of RocksDB files in tmp Directory Mon, 07 Nov, 00:24
xiaogang.sxg   Re: Lot of RocksDB files in tmp Directory Mon, 07 Nov, 03:00
Dominique Rondé AW: Re: Lot of RocksDB files in tmp Directory Mon, 07 Nov, 08:21
Aljoscha Krettek   Re: Re: Lot of RocksDB files in tmp Directory Mon, 14 Nov, 15:31
Dominique Rondé     Re: Lot of RocksDB files in tmp Directory Tue, 15 Nov, 14:00
Aljoscha Krettek       Re: Lot of RocksDB files in tmp Directory Tue, 15 Nov, 17:02
Si-li Liu Flink failed when can not connect to BlobServer Mon, 07 Nov, 09:02
Stephan Ewen   Re: Flink failed when can not connect to BlobServer Mon, 07 Nov, 13:37
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
May 2019354
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