flink-issues mailing list archives: March 2017

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 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early Fri, 31 Mar, 15:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early Fri, 31 Mar, 15:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3695) ValueArray types Fri, 31 Mar, 15:14
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition Fri, 31 Mar, 15:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5785) Add an Imputer for preparing data Fri, 31 Mar, 15:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode Fri, 31 Mar, 16:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5912) Inputs for CSV and graph generators Fri, 31 Mar, 16:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5913) Example drivers Fri, 31 Mar, 16:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode Fri, 31 Mar, 16:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3695) ValueArray types Fri, 31 Mar, 16:43
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL Fri, 31 Mar, 16:43
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5785) Add an Imputer for preparing data Fri, 31 Mar, 18:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL Fri, 31 Mar, 19:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL Fri, 31 Mar, 19:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL Fri, 31 Mar, 19:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4949) Refactor Gelly driver inputs Fri, 31 Mar, 20:36
Abey Sam Alex (JIRA) [jira] [Created] (FLINK-6234) HTTP/HTTPS WebServer Extension Fri, 31 Mar, 11:24
Adam Gibson (JIRA) [jira] [Commented] (FLINK-5782) Support GPU calculations Wed, 01 Mar, 12:18
Addison Higham (JIRA) [jira] [Created] (FLINK-5975) Mesos should support adding volumes to launched taskManagers Tue, 07 Mar, 03:49
Ajith S (JIRA) [jira] [Commented] (FLINK-5902) Some images can not show in IE Fri, 17 Mar, 07:17
Alex DeCastro (JIRA) [jira] [Updated] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm Mon, 06 Mar, 09:24
Alex DeCastro (JIRA) [jira] [Commented] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm Fri, 10 Mar, 14:29
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky Wed, 01 Mar, 15:02
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction Wed, 01 Mar, 15:03
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction Wed, 01 Mar, 15:08
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction Thu, 02 Mar, 10:32
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5917) Remove MapState.size() Thu, 02 Mar, 12:51
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5917) Remove MapState.size() Thu, 02 Mar, 12:52
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction Thu, 02 Mar, 15:27
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction Fri, 03 Mar, 06:54
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5944) Flink should support reading Snappy Files Fri, 03 Mar, 11:18
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5740) Make WrappingFunction an interface and move to flink-core Fri, 03 Mar, 11:19
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear() Fri, 03 Mar, 11:22
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-5958) Asynchronous snapshots for heap-based keyed state backends Fri, 03 Mar, 16:35
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends Fri, 03 Mar, 16:39
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-3089) OperatorState timeout Fri, 03 Mar, 16:39
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-3946) State API Should Support Data Expiration Mon, 06 Mar, 09:59
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-3089) State API Should Support Data Expiration Mon, 06 Mar, 09:59
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-3089) OperatorState timeout Mon, 06 Mar, 09:59
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5967) Document AggregatingState Mon, 06 Mar, 10:16
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5968) Document WindowedStream.aggregate() Mon, 06 Mar, 10:17
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5969) Add savepoint backwards compatibility tests from 1.2 to 1.3 Mon, 06 Mar, 10:50
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5972) Don't allow shrinking merging windows Mon, 06 Mar, 16:09
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Thu, 09 Mar, 06:37
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation Thu, 09 Mar, 06:40
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5991) Expose Broadcast Operator State through public APIs Thu, 09 Mar, 06:50
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation Thu, 09 Mar, 09:41
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService Thu, 09 Mar, 15:54
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService Thu, 09 Mar, 15:55
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5775) NullReferenceException when running job on local cluster Fri, 10 Mar, 13:45
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6028) Unnamed operations in main method logged as "main(null:-1)" Mon, 13 Mar, 12:34
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6028) Unnamed operations in main method logged as "main(null:-1)" Mon, 13 Mar, 12:35
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6026) Return type of flatMap with lambda function not correctly resolved Mon, 13 Mar, 12:45
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6026) Return type of flatMap with lambda function not correctly resolved Mon, 13 Mar, 12:45
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6026) Return type of flatMap with lambda function not correctly resolved Mon, 13 Mar, 12:51
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key" Mon, 13 Mar, 13:01
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method Mon, 13 Mar, 13:05
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Mon, 13 Mar, 13:05
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader. Mon, 13 Mar, 14:33
Aljoscha Krettek (JIRA) [jira] [Comment Edited] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader. Mon, 13 Mar, 14:34
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Mon, 13 Mar, 14:40
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Mon, 13 Mar, 14:40
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4858) Remove Legacy Checkpointing Interfaces Mon, 13 Mar, 16:56
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5991) Expose Broadcast Operator State through public APIs Mon, 13 Mar, 16:59
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-5222) Rename StateBackend interface to StateBinder Mon, 13 Mar, 16:59
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries Mon, 13 Mar, 17:02
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running Mon, 13 Mar, 17:06
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running Mon, 13 Mar, 17:06
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6055) Supported setting timers on a Non-Keyed Stream Wed, 15 Mar, 09:45
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-6058) Don't read DEFAULT_PARALLELISM from GlobalConfiguration Wed, 15 Mar, 10:02
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6055) Supported setting timers on a Non-Keyed Stream Wed, 15 Mar, 10:14
Aljoscha Krettek (JIRA) [jira] [Assigned] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness Wed, 15 Mar, 13:47
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness Wed, 15 Mar, 13:48
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling entries() on a keyed state in the open() function Wed, 15 Mar, 14:09
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6026) Return type of flatMap with lambda function not correctly resolved Wed, 15 Mar, 15:05
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6060) not exist class referance in the scala function annotation Wed, 15 Mar, 15:11
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Wed, 15 Mar, 17:47
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-6107) Add custom checkstyle for flink-streaming-java Sat, 18 Mar, 06:59
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-4460) Side Outputs in Flink Sat, 18 Mar, 07:16
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism Sat, 18 Mar, 08:40
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-6116) Watermarks don't work when unioning with same DataStream Sun, 19 Mar, 06:59
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream Sun, 19 Mar, 06:59
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Sun, 19 Mar, 19:57
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-6118) Chained operators forward watermark without checking Sun, 19 Mar, 20:06
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI Sun, 19 Mar, 20:10
Aljoscha Krettek (JIRA) [jira] [Assigned] (FLINK-6113) Implement split/select with OutputTag Sun, 19 Mar, 20:13
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6113) Implement split/select with Side Outputs Sun, 19 Mar, 20:14
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6113) Implement split/select with Side Outputs Sun, 19 Mar, 20:14
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed Sun, 19 Mar, 20:17
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6055) Supported setting timers on a Non-Keyed Stream Mon, 20 Mar, 14:35
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6127) Add MissingDeprecatedCheck to checkstyle Mon, 20 Mar, 14:47
Aljoscha Krettek (JIRA) [jira] [Assigned] (FLINK-4940) Add Support for Broadcast/Global State Mon, 20 Mar, 15:41
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-6131) Add side inputs for DataStream API Mon, 20 Mar, 15:43
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4940) Add Support for Broadcast/Global State Mon, 20 Mar, 15:44
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-3659) Add ConnectWithBroadcast Operation Mon, 20 Mar, 15:49
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Mon, 20 Mar, 15:54
Aljoscha Krettek (JIRA) [jira] [Reopened] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Mon, 20 Mar, 15:54
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Mon, 20 Mar, 15:55
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4940) Add Support for Broadcast State Mon, 20 Mar, 16:15
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4940) Add Support for Broadcast State Mon, 20 Mar, 16:51
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 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · Next »Thread · Author · Date
Box list
Apr 20202139
Mar 202012382
Feb 202010561
Jan 20208835
Dec 201913015
Nov 201911280
Oct 201911647
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