flink-issues mailing list archives: October 2015

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · Next »Thread · Author · Date
Greg Hogan (JIRA) [jira] [Commented] (FLINK-2810) Warn user if bc not installed Fri, 02 Oct, 14:09
Greg Hogan (JIRA) [jira] [Updated] (FLINK-2810) Warn user if bc not installed Fri, 02 Oct, 14:35
Greg Hogan (JIRA) [jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph Fri, 02 Oct, 16:52
Greg Hogan (JIRA) [jira] [Created] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode Fri, 02 Oct, 20:08
Greg Hogan (JIRA) [jira] [Created] (FLINK-2820) Configuration not passed to JobGraphGenerator Mon, 05 Oct, 19:46
Greg Hogan (JIRA) [jira] [Created] (FLINK-2834) Global round-robin for temporary directories Thu, 08 Oct, 13:15
Greg Hogan (JIRA) [jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph Fri, 09 Oct, 14:13
Greg Hogan (JIRA) [jira] [Created] (FLINK-2865) OutOfMemory error (Direct buffer memory) Sun, 18 Oct, 18:34
Greg Hogan (JIRA) [jira] [Commented] (FLINK-2865) OutOfMemory error (Direct buffer memory) Mon, 19 Oct, 14:30
Greg Hogan (JIRA) [jira] [Created] (FLINK-2876) Minutiae Tue, 20 Oct, 14:08
Greg Hogan (JIRA) [jira] [Created] (FLINK-2881) WebRuntimeMonitor overly restrictive file patterns Tue, 20 Oct, 18:07
Greg Hogan (JIRA) [jira] [Created] (FLINK-2882) Improve performance of string conversions Tue, 20 Oct, 19:42
Greg Hogan (JIRA) [jira] [Created] (FLINK-2895) Duplicate immutable object creation Thu, 22 Oct, 13:18
Greg Hogan (JIRA) [jira] [Commented] (FLINK-2895) Duplicate immutable object creation Thu, 22 Oct, 13:30
Greg Hogan (JIRA) [jira] [Created] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin Thu, 22 Oct, 14:41
Greg Hogan (JIRA) [jira] [Created] (FLINK-2898) Invert Travis CI build order Thu, 22 Oct, 15:12
Greg Hogan (JIRA) [jira] [Created] (FLINK-2902) Web interface sort tasks newest first Thu, 22 Oct, 21:17
Greg Hogan (JIRA) [jira] [Created] (FLINK-2903) Web interface numeric localization Thu, 22 Oct, 21:18
Greg Hogan (JIRA) [jira] [Created] (FLINK-2904) Web interface truncated task counts Thu, 22 Oct, 21:19
Greg Hogan (JIRA) [jira] [Created] (FLINK-2907) Bloom filter for Join Fri, 23 Oct, 16:29
Greg Hogan (JIRA) [jira] [Created] (FLINK-2908) Web interface redraw web plan when browser resized Fri, 23 Oct, 17:30
Greg Hogan (JIRA) [jira] [Created] (FLINK-2909) Gelly Graph Generators Fri, 23 Oct, 18:54
Greg Hogan (JIRA) [jira] [Commented] (FLINK-2909) Gelly Graph Generators Mon, 26 Oct, 20:34
Gyula Fora (JIRA) [jira] [Created] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows Fri, 02 Oct, 08:24
Gyula Fora (JIRA) [jira] [Created] (FLINK-2807) Add javadocs/comments to new windowing mechanics Fri, 02 Oct, 11:05
Gyula Fora (JIRA) [jira] [Closed] (FLINK-1940) StockPrice example cannot be visualized Sun, 04 Oct, 07:31
Gyula Fora (JIRA) [jira] [Created] (FLINK-2822) Windowing classes incorrectly import scala.Serializable Tue, 06 Oct, 10:40
Gyula Fora (JIRA) [jira] [Closed] (FLINK-2822) Windowing classes incorrectly import scala.Serializable Tue, 06 Oct, 12:37
Gyula Fora (JIRA) [jira] [Created] (FLINK-2824) Iteration feedback partitioning does not work as expected Tue, 06 Oct, 18:03
Gyula Fora (JIRA) [jira] [Created] (FLINK-2829) Confusing error message when Flink cannot create enough task threads Wed, 07 Oct, 14:21
Gyula Fora (JIRA) [jira] [Created] (FLINK-2888) Default state not copied for AbstractHeapKvState Wed, 21 Oct, 21:14
Gyula Fora (JIRA) [jira] [Closed] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter Wed, 21 Oct, 21:17
Gyula Fora (JIRA) [jira] [Closed] (FLINK-2154) ActiveTriggerPolicy collects elements to a closed buffer after job finishes Wed, 21 Oct, 21:18
Gyula Fora (JIRA) [jira] [Closed] (FLINK-2180) Streaming iterate test fails spuriously Wed, 21 Oct, 21:18
Gyula Fora (JIRA) [jira] [Resolved] (FLINK-2403) Rework partitioned state checkpointing logic Wed, 21 Oct, 21:19
Gyula Fora (JIRA) [jira] [Closed] (FLINK-2201) Inconsistent use of ClosureCleaner in streaming window helpers Wed, 21 Oct, 21:19
Gyula Fora (JIRA) [jira] [Closed] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming Wed, 21 Oct, 21:20
Gyula Fora (JIRA) [jira] [Resolved] (FLINK-2481) Test at least once processing guarantee for streaming Wed, 21 Oct, 21:21
Gyula Fora (JIRA) [jira] [Closed] (FLINK-2494) Fix StreamGraph getJobGraph bug Wed, 21 Oct, 21:22
Gyula Fora (JIRA) [jira] [Commented] (FLINK-2470) Stream Iteration can Hang after some Data Wed, 21 Oct, 21:22
Gyula Fora (JIRA) [jira] [Resolved] (FLINK-2630) Scala DataStream API does not have a project method Wed, 21 Oct, 21:24
Gyula Fora (JIRA) [jira] [Resolved] (FLINK-2138) PartitionCustom for streaming Wed, 21 Oct, 21:25
Gyula Fora (JIRA) [jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases Wed, 21 Oct, 21:26
Gyula Fora (JIRA) [jira] [Resolved] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed Wed, 21 Oct, 21:26
Gyula Fora (JIRA) [jira] [Closed] (FLINK-1503) GSoC project: Batch and Streaming integration through new operators and unified API Wed, 21 Oct, 21:28
Gyula Fora (JIRA) [jira] [Closed] (FLINK-2471) FileSinkFunction invoke performance optimize Wed, 21 Oct, 21:29
Gyula Fora (JIRA) [jira] [Resolved] (FLINK-2589) Threads created in TimeTriggerPolicy don't end properly Wed, 21 Oct, 21:29
Gyula Fora (JIRA) [jira] [Updated] (FLINK-2888) Default state not copied for AbstractHeapKvState Wed, 21 Oct, 21:30
Gyula Fora (JIRA) [jira] [Updated] (FLINK-2888) Default state not copied for AbstractHeapKvState Wed, 21 Oct, 21:30
Gyula Fora (JIRA) [jira] [Commented] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation Thu, 22 Oct, 06:13
Gyula Fora (JIRA) [jira] [Commented] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation Thu, 22 Oct, 06:18
Gyula Fora (JIRA) [jira] [Created] (FLINK-2916) Add more context information for the StateBackend Sun, 25 Oct, 10:59
Gyula Fora (JIRA) [jira] [Created] (FLINK-2917) Make non-copying behaviour default for stream operator Sun, 25 Oct, 15:40
Gyula Fora (JIRA) [jira] [Commented] (FLINK-2922) Add Queryable Window Operator Mon, 26 Oct, 15:55
Gyula Fora (JIRA) [jira] [Created] (FLINK-2923) Make it possible to mix-and-match StateBackends with KvState implementations Mon, 26 Oct, 18:36
Gyula Fora (JIRA) [jira] [Created] (FLINK-2924) Create database state backend Mon, 26 Oct, 18:42
Gyula Fora (JIRA) [jira] [Commented] (FLINK-2922) Add Queryable Window Operator Mon, 26 Oct, 18:48
Gyula Fora (JIRA) [jira] [Created] (FLINK-2931) Add global recovery timestamp to state restore Tue, 27 Oct, 17:11
Henry Saputra (JIRA) [jira] [Created] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Sat, 03 Oct, 03:44
Henry Saputra (JIRA) [jira] [Closed] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Tue, 06 Oct, 15:16
Henry Saputra (JIRA) [jira] [Created] (FLINK-2847) Fix flaky test in StormTestBase.testJob Fri, 09 Oct, 23:35
Henry Saputra (JIRA) [jira] [Commented] (FLINK-2847) Fix flaky test in StormTestBase.testJob Fri, 09 Oct, 23:36
Henry Saputra (JIRA) [jira] [Commented] (FLINK-2847) Fix flaky test in StormTestBase.testJob Sun, 11 Oct, 00:19
Henry Saputra (JIRA) [jira] [Created] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives Mon, 19 Oct, 17:13
Henry Saputra (JIRA) [jira] [Closed] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives Tue, 20 Oct, 21:00
Henry Saputra (JIRA) [jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core Thu, 22 Oct, 20:21
Henry Saputra (JIRA) [jira] [Commented] (FLINK-1988) Port Record API based tests in the common.io Thu, 22 Oct, 20:22
Henry Saputra (JIRA) [jira] [Closed] (FLINK-1611) [REFACTOR] Rename classes and packages in test that contains Nephele Tue, 27 Oct, 01:07
HilmiYildirim [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... Fri, 09 Oct, 12:33
HilmiYildirim [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... Wed, 14 Oct, 07:39
HilmiYildirim [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... Fri, 16 Oct, 14:07
HilmiYildirim [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... Mon, 19 Oct, 11:24
HilmiYildirim [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... Mon, 19 Oct, 11:59
HilmiYildirim [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... Mon, 19 Oct, 15:22
HuangWHWHW [GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou... Thu, 08 Oct, 01:14
HuangWHWHW [GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou... Fri, 16 Oct, 08:48
Hubert Czerpak (JIRA) [jira] [Commented] (FLINK-2559) Fix Javadoc Code Examples Thu, 22 Oct, 17:41
Johannes (JIRA) [jira] [Created] (FLINK-2935) Allow scala shell to read yarn properties Wed, 28 Oct, 15:12
Jonas Traub (JIRA) [jira] [Commented] (FLINK-2642) Scala Table API crashes when executing word count example Fri, 02 Oct, 10:33
JonathanH5 [GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ... Mon, 12 Oct, 09:25
Kostas Tzoumas (JIRA) [jira] [Assigned] (FLINK-2794) Document exactly-once support for sources and sinks Thu, 01 Oct, 09:20
Kostas Tzoumas (JIRA) [jira] [Commented] (FLINK-2807) Add javadocs/comments to new windowing mechanics Fri, 02 Oct, 11:12
Martin Junghanns (JIRA) [jira] [Comment Edited] (FLINK-2411) Add basic graph summarization algorithm Sat, 10 Oct, 15:45
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm Sat, 10 Oct, 15:45
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm Sun, 11 Oct, 08:45
Martin Junghanns (JIRA) [jira] [Created] (FLINK-2905) Add intersect method to Graph class Fri, 23 Oct, 08:35
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-2905) Add intersect method to Graph class Sat, 24 Oct, 09:29
Martin Junghanns (JIRA) [jira] [Created] (FLINK-2910) Combine tests for binary graph operators Sat, 24 Oct, 09:49
Martin Junghanns (JIRA) [jira] [Updated] (FLINK-2910) Combine tests for binary graph operators Sat, 24 Oct, 09:51
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-2905) Add intersect method to Graph class Tue, 27 Oct, 14:19
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-2905) Add intersect method to Graph class Tue, 27 Oct, 15:02
Martin Junghanns (JIRA) [jira] [Comment Edited] (FLINK-2905) Add intersect method to Graph class Tue, 27 Oct, 15:06
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-2905) Add intersect method to Graph class Tue, 27 Oct, 17:07
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-2905) Add intersect method to Graph class Thu, 29 Oct, 13:51
Martin Junghanns (JIRA) [jira] [Comment Edited] (FLINK-2905) Add intersect method to Graph class Thu, 29 Oct, 13:54
Martin Liesenberg (JIRA) [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. Thu, 01 Oct, 20:05
Martin Liesenberg (JIRA) [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. Tue, 06 Oct, 16:18
Martin Liesenberg (JIRA) [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. Sat, 10 Oct, 19:40
Martin Liesenberg (JIRA) [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. Sun, 11 Oct, 20:59
Martin Liesenberg (JIRA) [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. Tue, 13 Oct, 14:04
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · Next »Thread · Author · Date
Box list
Oct 20193904
Sep 20198451
Aug 201910193
Jul 201911502
Jun 20198159
May 20197326
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300