flink-dev mailing list archives: January 2017

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Jamie Grier Re: Dynamic Scaling Mon, 02 Jan, 19:48
Markus Dale (JIRA) [jira] [Created] (FLINK-5403) Apache Flink Snapshot 1.2 Javadocs link does not have files like index.html, overview-summary.html or index-all.html Mon, 02 Jan, 22:31
Markus Dale (JIRA) [jira] [Created] (FLINK-5404) Consolidate and update S3 documentation Tue, 03 Jan, 03:12
madhairsilence Datastream splitter - Confusing behaviour Tue, 03 Jan, 11:26
madhairsilence Categorize or GroupBy datastream data and process with CEP separately Tue, 03 Jan, 11:30
Robert Metzger [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Tue, 03 Jan, 12:43
Jark Wu Re: Datastream splitter - Confusing behaviour Tue, 03 Jan, 12:44
Jamie Grier Re: Categorize or GroupBy datastream data and process with CEP separately Tue, 03 Jan, 16:55
Luis (JIRA) [jira] [Created] (FLINK-5405) Add streaming connection to twitter through a internet proxy Tue, 03 Jan, 21:14
godfrey he (JIRA) [jira] [Created] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase Wed, 04 Jan, 07:21
madhairsilence Re: Datastream splitter - Confusing behaviour Wed, 04 Jan, 07:58
madhairsilence Re: Categorize or GroupBy datastream data and process with CEP separately Wed, 04 Jan, 08:07
Stephan Ewen (JIRA) [jira] [Created] (FLINK-5407) Savepoint for iterative Task fails. Wed, 04 Jan, 11:31
madhairsilence Re: Categorize or GroupBy datastream data and process with CEP separately Wed, 04 Jan, 11:32
Jamie Grier Re: Categorize or GroupBy datastream data and process with CEP separately Wed, 04 Jan, 18:43
Stephan Ewen (JIRA) [jira] [Created] (FLINK-5408) RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders Wed, 04 Jan, 23:28
Matt Zimmer (JIRA) [jira] [Created] (FLINK-5409) Separate Job API from the Runtime Thu, 05 Jan, 01:24
Eron Wright CheckpointedFunction applicability? Thu, 05 Jan, 03:40
madhairsilence Re: Categorize or GroupBy datastream data and process with CEP separately Thu, 05 Jan, 06:39
Sachin Goel (JIRA) [jira] [Created] (FLINK-5410) Running out of memory on Yarn Thu, 05 Jan, 08:42
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-5411) LocalStreamEnvironmentITCase#testRunIsolatedJob failed on travis Thu, 05 Jan, 13:05
Stefan Richter Re: CheckpointedFunction applicability? Thu, 05 Jan, 13:54
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-5412) Enable RocksDB tests on Windows Thu, 05 Jan, 15:04
Timo Walther (JIRA) [jira] [Created] (FLINK-5413) Convert TableEnvironmentITCases to unit tests Thu, 05 Jan, 15:06
Timo Walther (JIRA) [jira] [Created] (FLINK-5414) Bump up Calcite version to 1.11 Thu, 05 Jan, 16:12
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-5415) ContinuousFileProcessingTest failed on travis Thu, 05 Jan, 16:42
Eron Wright (JIRA) [jira] [Created] (FLINK-5416) Function wrappers should support CheckpointedFunction Thu, 05 Jan, 16:49
Eron Wright Re: CheckpointedFunction applicability? Thu, 05 Jan, 17:05
Tao Wang (JIRA) [jira] [Created] (FLINK-5417) Fix the wrong config file name Fri, 06 Jan, 04:18
madhairsilence DataStream and CEP - Pattern not matching after applying a window Fri, 06 Jan, 10:05
Timo Walther (JIRA) [jira] [Created] (FLINK-5418) Estimated row size does not support nested types Fri, 06 Jan, 11:01
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-5419) Taskmanager metrics not accessible via REST Fri, 06 Jan, 13:01
Kostas Kloudas (JIRA) [jira] [Created] (FLINK-5420) Make the CEP library rescalable. Fri, 06 Jan, 13:38
Stefan Richter (JIRA) [jira] [Created] (FLINK-5421) Explicit restore method in Snapshotable Fri, 06 Jan, 14:48
Kostas Kloudas (JIRA) [jira] [Created] (FLINK-5422) Check for name collisions in the Rolling/BucketingSink Fri, 06 Jan, 16:18
Fokko Driesprong (JIRA) [jira] [Created] (FLINK-5423) Implement Stochastic Outlier Selection Fri, 06 Jan, 17:01
Shannon Carey (JIRA) [jira] [Created] (FLINK-5424) Improve Restart Strategy Logging Fri, 06 Jan, 19:23
Shannon Carey (JIRA) [jira] [Created] (FLINK-5425) JobManager <host> replaced by IP in metrics Sat, 07 Jan, 02:34
madhairsilence Re: DataStream and CEP - Pattern not matching after applying a window Sat, 07 Jan, 18:47
Fokko Driesprong (JIRA) [jira] [Created] (FLINK-5426) Clean up the Flink Machine Learning library Sat, 07 Jan, 19:15
Alexey Demin time format for akka status Sun, 08 Jan, 07:32
Дёмин Алексей Re: DataStream and CEP - Pattern not matching after applying a window Sun, 08 Jan, 17:28
Alexey Demin Re: DataStream and CEP - Pattern not matching after applying a window Mon, 09 Jan, 05:12
madhairsilence Re: DataStream and CEP - Pattern not matching after applying a window Mon, 09 Jan, 05:37
Till Rohrmann Re: [ANNOUNCE] Flink 1.1.4 Released Mon, 09 Jan, 10:35
Yelei Feng (JIRA) [jira] [Created] (FLINK-5427) Typo in the event_timestamps_watermarks doc Mon, 09 Jan, 10:36
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5428) Decrease restart delay in RecoveryITCase Mon, 09 Jan, 10:50
Till Rohrmann Re: [FLINK-3615] Add support for non-native SQL types Mon, 09 Jan, 10:58
Tzu-Li (Gordon) Tai Re: [DISCUSS] ElasticSearch in Flink Strategy Mon, 09 Jan, 11:24
Timo Walther Re: [FLINK-3615] Add support for non-native SQL types Mon, 09 Jan, 11:45
Flavio Pompermaier Re: [DISCUSS] ElasticSearch in Flink Strategy Mon, 09 Jan, 11:47
Till Rohrmann Re: [DISCUSS] schedule for execution from different list of ExecutionJobVertex Mon, 09 Jan, 11:58
Till Rohrmann Re: Categorize or GroupBy datastream data and process with CEP separately Mon, 09 Jan, 13:24
Till Rohrmann Re: time format for akka status Mon, 09 Jan, 13:25
Robert Metzger Re: [DISCUSS] ElasticSearch in Flink Strategy Mon, 09 Jan, 13:53
Timo Walther (JIRA) [jira] [Created] (FLINK-5429) Code generate types between operators in Table API Mon, 09 Jan, 14:04
Mike Winters Re: [DISCUSS] Proposed updates to Flink project site Mon, 09 Jan, 14:07
Kostas Tzoumas Re: [DISCUSS] ElasticSearch in Flink Strategy Mon, 09 Jan, 14:50
Stephan Ewen (JIRA) [jira] [Created] (FLINK-5430) Bring documentation up to speed for current feature set Mon, 09 Jan, 15:40
Mike Winters Re: [DISCUSS] Proposed updates to Flink project site Mon, 09 Jan, 16:08
Ufuk Celebi Re: [DISCUSS] Proposed updates to Flink project site Mon, 09 Jan, 17:12
Alexey Diomin (JIRA) [jira] [Created] (FLINK-5431) time format for akka status Mon, 09 Jan, 17:58
Alexey Demin Re: time format for akka status Mon, 09 Jan, 18:10
Alexey Demin Slow duplicated tests Mon, 09 Jan, 19:11
Yassine Marzougui (JIRA) [jira] [Created] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files Mon, 09 Jan, 22:08
Tzu-Li (Gordon) Tai Re: [DISCUSS] ElasticSearch in Flink Strategy Tue, 10 Jan, 05:50
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-5433) initiate function of Aggregate does not take effect for DataStream aggregation Tue, 10 Jan, 08:29
Vasia Kalavri (JIRA) [jira] [Created] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs Tue, 10 Jan, 10:23
Mike Winters Re: [DISCUSS] Proposed updates to Flink project site Tue, 10 Jan, 10:56
shijinkui 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Tue, 10 Jan, 10:58
Ufuk Celebi Re: [DISCUSS] Proposed updates to Flink project site Tue, 10 Jan, 12:27
Till Rohrmann Re: time format for akka status Tue, 10 Jan, 13:22
Kostas Tzoumas Re: [DISCUSS] Proposed updates to Flink project site Tue, 10 Jan, 13:22
Till Rohrmann Re: [DISCUSS] Proposed updates to Flink project site Tue, 10 Jan, 13:35
Robert Metzger Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) Tue, 10 Jan, 14:16
Robert Metzger Re: [DISCUSS] ElasticSearch in Flink Strategy Tue, 10 Jan, 14:17
Kurt Young [DISCUSS] Improvements to flink's cost based optimizer Tue, 10 Jan, 14:22
Kurt Young (JIRA) [jira] [Created] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12 Tue, 10 Jan, 14:27
Aljoscha Krettek Re: Slow duplicated tests Tue, 10 Jan, 14:29
Shaoxuan Wang [DISCUSS] proposal for the User Defined AGGregate (UDAGG) Tue, 10 Jan, 14:40
Robert Metzger Re: Slow duplicated tests Tue, 10 Jan, 14:42
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5436) UDF state without CheckpointedRestoring can result in restarting loop Tue, 10 Jan, 15:26
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5437) Make CheckpointedRestoring error message more detailed Tue, 10 Jan, 15:27
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5438) Typo in JobGraph generator Exception Tue, 10 Jan, 15:30
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5439) Adjust max parallelism when migrating Tue, 10 Jan, 15:35
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint Tue, 10 Jan, 15:41
Timo Walther (JIRA) [jira] [Created] (FLINK-5441) Directly allow SQL queries on a Table Tue, 10 Jan, 15:47
Alexey Demin Re: Slow duplicated tests Tue, 10 Jan, 19:14
Fabian Hueske Re: [DISCUSS] Improvements to flink's cost based optimizer Tue, 10 Jan, 21:56
Fabian Hueske Re: [DISCUSS] proposal for the User Defined AGGregate (UDAGG) Tue, 10 Jan, 22:09
Stefan Richter (JIRA) [jira] [Created] (FLINK-5442) Add test to fix ordinals of serialized enum StateDescriptor.Type Wed, 11 Jan, 10:01
Kostas Kloudas (JIRA) [jira] [Created] (FLINK-5443) Create a path to migrate from the Rolling to the BucketingSink. Wed, 11 Jan, 10:19
Joerg Schad (JIRA) [jira] [Created] (FLINK-5444) Flink UI uses absolute URLs. Wed, 11 Jan, 10:25
Renjie Liu (JIRA) [jira] [Created] (FLINK-5445) flink kafka consumer should support rate control Wed, 11 Jan, 11:12
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-5446) System metrics reference incomplete Wed, 11 Jan, 14:11
Timo Walther (JIRA) [jira] [Created] (FLINK-5447) Sync documentation of built-in functions for Table API with SQL Wed, 11 Jan, 14:15
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5448) Fix typo in StateAssignmentOperation Exception Wed, 11 Jan, 14:39
Andrey (JIRA) [jira] [Created] (FLINK-5449) Time drift in MetricRegistry Wed, 11 Jan, 14:50
Robert Metzger (JIRA) [jira] [Created] (FLINK-5450) WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window Wed, 11 Jan, 14:52
Ivan Mushketyk Flink CEP development is stalling Wed, 11 Jan, 15:23
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Box list
Aug 2018211
Jul 2018578
Jun 2018433
May 2018483
Apr 2018266
Mar 2018522
Feb 2018441
Jan 2018287
Dec 2017261
Nov 2017306
Oct 2017301
Sep 2017280
Aug 2017381
Jul 2017579
Jun 2017626
May 2017619
Apr 2017352
Mar 2017605
Feb 2017562
Jan 2017581
Dec 2016366
Nov 2016429
Oct 2016554
Sep 2016426
Aug 2016586
Jul 2016455
Jun 2016386
May 2016405
Apr 2016535
Mar 2016421
Feb 2016502
Jan 2016389
Dec 2015259
Nov 2015589
Oct 2015589
Sep 2015449
Aug 2015478
Jul 2015503
Jun 2015880
May 2015491
Apr 2015583
Mar 2015716
Feb 2015545
Jan 2015600
Dec 2014303
Nov 2014375
Oct 2014283
Sep 2014430
Aug 2014314
Jul 2014390
Jun 2014990
May 2014184
Apr 201415