flink-issues mailing list archives: September 2016

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 · Next »Thread · Author · Date
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
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 · Next »Thread · Author · Date
Box list
Jul 20197196
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