| Simone Robutti (JIRA) |
[jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment |
Fri, 09 Sep, 09:18 |
| Simone Robutti (JIRA) |
[jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment |
Fri, 09 Sep, 12:57 |
| Simone Robutti (JIRA) |
[jira] [Commented] (FLINK-4629) Kafka v 0.10 Support |
Sat, 17 Sep, 12:42 |
| Simone Robutti (JIRA) |
[jira] [Commented] (FLINK-4565) Support for SQL IN operator |
Mon, 19 Sep, 14:21 |
| Simone Robutti (JIRA) |
[jira] [Updated] (FLINK-4565) Support for SQL IN operator |
Mon, 19 Sep, 14:22 |
| Simone Robutti (JIRA) |
[jira] [Assigned] (FLINK-4301) Parameterize Flink version in Quickstart bash script |
Tue, 20 Sep, 14:06 |
| Simone Robutti (JIRA) |
[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 |
Tue, 20 Sep, 20:57 |
| Stefan Richter (JIRA) |
[jira] [Assigned] (FLINK-4556) Make Queryable State Key-Group Aware |
Tue, 20 Sep, 14:36 |
| Stefan Richter (JIRA) |
[jira] [Commented] (FLINK-4603) KeyedStateBackend cannot restore user code classes |
Thu, 22 Sep, 08:08 |
| StefanRRichter |
[GitHub] flink issue #2440: [FLINK-3755] Introduce key groups for key-value state to ... |
Wed, 07 Sep, 17:39 |
| StefanRRichter |
[GitHub] flink pull request #2440: [FLINK-3755] Introduce key groups for key-value st... |
Wed, 07 Sep, 17:40 |
| StefanRRichter |
[GitHub] flink pull request #2512: Partitionable op state |
Mon, 19 Sep, 13:58 |
| StefanRRichter |
[GitHub] flink issue #2512: [FLINK-4379] Rescalable non-partitioned state |
Mon, 19 Sep, 14:04 |
| StefanRRichter |
[GitHub] flink pull request #2513: [hotfix] RescalingITCase |
Mon, 19 Sep, 15:57 |
| StefanRRichter |
[GitHub] flink pull request #2513: [hotfix] RescalingITCase |
Mon, 19 Sep, 19:32 |
| StefanRRichter |
[GitHub] flink pull request #2523: [FLINK-4556] Make Queryable State Key-Group Aware |
Tue, 20 Sep, 14:52 |
| StefanRRichter |
[GitHub] flink pull request #2513: [hotfix] RescalingITCase |
Wed, 21 Sep, 08:22 |
| StefanRRichter |
[GitHub] flink issue #2512: [FLINK-4379] Rescalable non-partitioned state |
Wed, 21 Sep, 09:09 |
| StefanRRichter |
[GitHub] flink pull request #2533: [FLINK-4603] Fixes: KeyedStateBackend cannot resto... |
Thu, 22 Sep, 08:02 |
| StefanRRichter |
[GitHub] flink issue #2533: [FLINK-4603] Fixes: KeyedStateBackend cannot restore user... |
Thu, 22 Sep, 08:03 |
| StefanRRichter |
[GitHub] flink pull request #2533: [FLINK-4603] Fixes: KeyedStateBackend cannot resto... |
Thu, 22 Sep, 10:06 |
| StefanRRichter |
[GitHub] flink issue #2533: [FLINK-4603] Fixes: KeyedStateBackend cannot restore user... |
Thu, 22 Sep, 10:12 |
| StefanRRichter |
[GitHub] flink issue #2523: [FLINK-4556] Make Queryable State Key-Group Aware |
Thu, 22 Sep, 13:43 |
| StefanRRichter |
[GitHub] flink pull request #2544: [FLINK-4218] [checkpoints] Do not rely on FileSyst... |
Fri, 23 Sep, 20:23 |
| StefanRRichter |
[GitHub] flink pull request #2544: [FLINK-4218] [checkpoints] Do not rely on FileSyst... |
Fri, 23 Sep, 20:23 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager |
Thu, 01 Sep, 09:42 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager |
Thu, 01 Sep, 10:24 |
| Stephan Ewen (JIRA) |
[jira] [Created] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes |
Fri, 02 Sep, 09:49 |
| Stephan Ewen (JIRA) |
[jira] [Created] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains |
Fri, 02 Sep, 09:50 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains |
Fri, 02 Sep, 15:37 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains |
Fri, 02 Sep, 15:37 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4490) Decouple Slot and Instance |
Fri, 02 Sep, 15:38 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4490) Decouple Slot and Instance |
Fri, 02 Sep, 15:38 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4525) Drop the "eager split pre-assignment" code paths |
Fri, 02 Sep, 15:41 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes |
Fri, 02 Sep, 15:43 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes |
Fri, 02 Sep, 15:43 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend |
Fri, 02 Sep, 16:47 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4459) Introduce SlotProvider for Scheduler |
Sun, 04 Sep, 21:13 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4459) Introduce SlotProvider for Scheduler |
Sun, 04 Sep, 21:13 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4620) Automatically creating savepoints |
Thu, 15 Sep, 14:02 |
| Stephan Ewen (JIRA) |
[jira] [Created] (FLINK-4625) Guard Flink processes against blocking shutdown hooks |
Thu, 15 Sep, 17:27 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung |
Mon, 19 Sep, 09:56 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT |
Mon, 19 Sep, 18:13 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4625) Guard Flink processes against blocking shutdown hooks |
Mon, 19 Sep, 20:34 |
| Stephan Ewen (JIRA) |
[jira] [Created] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java |
Tue, 20 Sep, 14:58 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails |
Tue, 20 Sep, 16:50 |
| Stephan Ewen (JIRA) |
[jira] [Created] (FLINK-4645) Hard to register Kryo Serializers due to generics |
Tue, 20 Sep, 17:48 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails |
Tue, 20 Sep, 18:15 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails |
Tue, 20 Sep, 18:56 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4645) Hard to register Kryo Serializers due to generics |
Tue, 20 Sep, 19:39 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants |
Tue, 20 Sep, 19:40 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager |
Wed, 21 Sep, 08:55 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung |
Wed, 21 Sep, 10:12 |
| Stephan Ewen (JIRA) |
[jira] [Assigned] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails |
Wed, 21 Sep, 13:13 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails |
Wed, 21 Sep, 15:55 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails |
Wed, 21 Sep, 15:55 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4645) Hard to register Kryo Serializers due to generics |
Wed, 21 Sep, 15:56 |
| Stephan Ewen (JIRA) |
[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. |
Wed, 21 Sep, 15:56 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4645) Hard to register Kryo Serializers due to generics |
Wed, 21 Sep, 15:56 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager |
Thu, 22 Sep, 09:48 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4646) Add BipartiteGraph class |
Thu, 22 Sep, 10:05 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT |
Thu, 22 Sep, 10:09 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4646) Add BipartiteGraph class |
Thu, 22 Sep, 10:28 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-3370) Add an aligned version of the window operator |
Thu, 22 Sep, 10:32 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop |
Thu, 22 Sep, 12:55 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting |
Thu, 22 Sep, 12:59 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE |
Thu, 22 Sep, 13:45 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4603) KeyedStateBackend cannot restore user code classes |
Thu, 22 Sep, 13:54 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4603) KeyedStateBackend cannot restore user code classes |
Thu, 22 Sep, 13:54 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4628) User class loader unavailable during input split assignment |
Thu, 22 Sep, 13:55 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4628) User class loader unavailable during input split assignment |
Thu, 22 Sep, 13:55 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4596) RESTART_STRATEGY is not really pluggable |
Fri, 23 Sep, 09:51 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop |
Fri, 23 Sep, 09:52 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting |
Fri, 23 Sep, 10:38 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4666) Make constants to be final in ParameterTool |
Fri, 23 Sep, 12:14 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4666) Make constants to be final in ParameterTool |
Fri, 23 Sep, 12:14 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4665) Remove boxing/unboxing to parse a primitive |
Fri, 23 Sep, 12:15 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4665) Remove boxing/unboxing to parse a primitive |
Fri, 23 Sep, 12:15 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message |
Fri, 23 Sep, 12:17 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message |
Fri, 23 Sep, 12:17 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4556) Make Queryable State Key-Group Aware |
Fri, 23 Sep, 12:18 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4556) Make Queryable State Key-Group Aware |
Fri, 23 Sep, 12:18 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting |
Fri, 23 Sep, 12:28 |
| Stephan Ewen (JIRA) |
[jira] [Created] (FLINK-4672) TaskManager accidentally decorates Kill messages |
Fri, 23 Sep, 16:43 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung |
Fri, 23 Sep, 16:53 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock |
Fri, 23 Sep, 17:17 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock |
Fri, 23 Sep, 17:17 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung |
Mon, 26 Sep, 08:09 |
| Stephan Ewen (JIRA) |
[jira] [Updated] (FLINK-4632) when yarn nodemanager lost, flink hung |
Mon, 26 Sep, 08:09 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4672) TaskManager accidentally decorates Kill messages |
Mon, 26 Sep, 12:26 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4672) TaskManager accidentally decorates Kill messages |
Mon, 26 Sep, 12:26 |
| Stephan Ewen (JIRA) |
[jira] [Resolved] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting |
Mon, 26 Sep, 12:27 |
| Stephan Ewen (JIRA) |
[jira] [Closed] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting |
Mon, 26 Sep, 12:30 |
| Stephan Ewen (JIRA) |
[jira] [Commented] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part |
Mon, 26 Sep, 12:40 |
| Stephan Ewen (JIRA) |
[jira] [Assigned] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part |
Mon, 26 Sep, 12:40 |
| Stephan Ewen (JIRA) |
[jira] [Created] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator |
Mon, 26 Sep, 15:10 |
| Stephan Ewen (JIRA) |
[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints |
Mon, 26 Sep, 15:57 |
| Stephan Ewen (JIRA) |
[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints |
Mon, 26 Sep, 15:59 |
| Stephan Ewen (JIRA) |
[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints |
Mon, 26 Sep, 15:59 |
| Stephan Ewen (JIRA) |
[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints |
Mon, 26 Sep, 15:59 |