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
Ted Yu (JIRA) [jira] [Updated] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink Sun, 05 Mar, 03:38
Ted Yu (JIRA) [jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() Sun, 05 Mar, 19:25
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Mon, 06 Mar, 03:58
Ted Yu (JIRA) [jira] [Created] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8 Tue, 07 Mar, 17:14
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() Thu, 09 Mar, 01:28
Ted Yu (JIRA) [jira] [Updated] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology() Sat, 11 Mar, 02:51
Ted Yu (JIRA) [jira] [Updated] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink Sun, 12 Mar, 01:58
Ted Yu (JIRA) [jira] [Updated] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions Sun, 12 Mar, 02:07
Ted Yu (JIRA) [jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() Sun, 12 Mar, 03:14
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Mon, 13 Mar, 01:14
Ted Yu (JIRA) [jira] [Created] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint() Tue, 14 Mar, 19:30
Ted Yu (JIRA) [jira] [Updated] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8 Wed, 15 Mar, 15:12
Ted Yu (JIRA) [jira] [Created] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open() Thu, 16 Mar, 14:58
Ted Yu (JIRA) [jira] [Created] (FLINK-6080) Unclosed ObjectOutputStream in NFA#serialize() Thu, 16 Mar, 15:04
Ted Yu (JIRA) [jira] [Created] (FLINK-6104) Unclosed WriteOptions in ListViaRangeSpeedMiniBenchmark#main() Fri, 17 Mar, 15:29
Ted Yu (JIRA) [jira] [Updated] (FLINK-6104) Resource leak in ListViaRangeSpeedMiniBenchmark Fri, 17 Mar, 15:31
Ted Yu (JIRA) [jira] [Updated] (FLINK-6104) Resource leak in ListViaRangeSpeedMiniBenchmark Fri, 17 Mar, 15:32
Ted Yu (JIRA) [jira] [Created] (FLINK-6105) Properly handle InterruptedException Fri, 17 Mar, 15:36
Ted Yu (JIRA) [jira] [Updated] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink Fri, 17 Mar, 17:01
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-5629) Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader() Fri, 17 Mar, 17:02
Ted Yu (JIRA) [jira] [Updated] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology() Fri, 17 Mar, 17:02
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() Fri, 17 Mar, 17:19
Ted Yu (JIRA) [jira] [Updated] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue Fri, 17 Mar, 17:20
Ted Yu (JIRA) [jira] [Updated] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown() Sun, 19 Mar, 21:24
Ted Yu (JIRA) [jira] [Updated] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint() Sun, 19 Mar, 21:24
Ted Yu (JIRA) [jira] [Created] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held Mon, 20 Mar, 15:17
Ted Yu (JIRA) [jira] [Created] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession() Tue, 21 Mar, 15:45
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Wed, 22 Mar, 01:54
Ted Yu (JIRA) [jira] [Created] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error Wed, 22 Mar, 15:56
Ted Yu (JIRA) [jira] [Commented] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler Wed, 22 Mar, 22:39
Ted Yu (JIRA) [jira] [Created] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler Wed, 22 Mar, 22:39
Ted Yu (JIRA) [jira] [Commented] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler Thu, 23 Mar, 14:10
Ted Yu (JIRA) [jira] [Updated] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology() Thu, 23 Mar, 15:53
Ted Yu (JIRA) [jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() Thu, 23 Mar, 17:38
Ted Yu (JIRA) [jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin Thu, 23 Mar, 17:39
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-5629) Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader() Mon, 27 Mar, 00:52
Ted Yu (JIRA) [jira] [Updated] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions Mon, 27 Mar, 00:52
Ted Yu (JIRA) [jira] [Updated] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue Mon, 27 Mar, 00:52
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() Mon, 27 Mar, 00:52
Ted Yu (JIRA) [jira] [Updated] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown() Mon, 27 Mar, 00:53
Ted Yu (JIRA) [jira] [Commented] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8 Mon, 27 Mar, 01:44
Ted Yu (JIRA) [jira] [Resolved] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error Mon, 27 Mar, 14:05
Ted Yu (JIRA) [jira] [Created] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark Tue, 28 Mar, 23:51
Ted Yu (JIRA) [jira] [Updated] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark Wed, 29 Mar, 03:20
Ted Yu (JIRA) [jira] [Updated] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler Thu, 30 Mar, 05:44
Ted Yu (JIRA) [jira] [Updated] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession() Thu, 30 Mar, 05:45
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5940) ZooKeeperCompletedCheckpointStore cannot handle broken state handles Wed, 01 Mar, 15:43
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5942) Harden ZooKeeperStateHandleStore to deal with corrupted data Wed, 01 Mar, 17:10
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-5938) Replace ExecutionContext by Executor in Scheduler Thu, 02 Mar, 13:01
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-5934) Scheduler in ExecutionGraph null if failure happens in ExecutionGraph.restoreLatestCheckpointedState Thu, 02 Mar, 13:04
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-4714) Set task state to RUNNING after state has been restored Thu, 02 Mar, 15:23
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5844) jobmanager was killed when disk less 10% and restart fail Thu, 02 Mar, 15:26
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Fri, 03 Mar, 14:50
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm Fri, 03 Mar, 14:51
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm Fri, 03 Mar, 14:58
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5916) make env.java.opts.jobmanager and env.java.opts.taskmanager working in YARN mode Fri, 03 Mar, 15:09
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5959) Verify that mesos-appmaster.sh respects env.java.opts(.jobmanager) Fri, 03 Mar, 15:13
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5960) Make CheckpointCoordinator less blocking Fri, 03 Mar, 16:09
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5962) Cancel checkpoint canceller tasks in CheckpointCoordinator Fri, 03 Mar, 17:29
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5962) Cancel checkpoint canceller tasks in CheckpointCoordinator Mon, 06 Mar, 10:20
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm Mon, 06 Mar, 10:31
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5971) JobLeaderIdService should time out registered jobs Mon, 06 Mar, 15:26
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask Tue, 07 Mar, 15:12
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-5916) make env.java.opts.jobmanager and env.java.opts.taskmanager working in YARN mode Tue, 07 Mar, 21:49
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails Fri, 10 Mar, 14:28
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails Fri, 10 Mar, 14:28
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5936) Can't pass keyed vectors to KNN join algorithm Fri, 10 Mar, 14:41
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-5971) JobLeaderIdService should time out registered jobs Mon, 13 Mar, 14:04
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-5942) Harden ZooKeeperStateHandleStore to deal with corrupted data Tue, 14 Mar, 08:20
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-5940) ZooKeeperCompletedCheckpointStore cannot handle broken state handles Tue, 14 Mar, 08:27
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI Tue, 14 Mar, 12:23
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6043) Display time when exceptions/root cause of failure happened Tue, 14 Mar, 12:35
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6045) FLINK_CONF_DIR has to be set even though specifying --configDir Tue, 14 Mar, 12:49
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-6045) FLINK_CONF_DIR has to be set even though specifying --configDir Tue, 14 Mar, 12:53
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6050) Improve failure reporting when using Future.thenAccept Tue, 14 Mar, 16:27
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-5210) Failing performCheckpoint method causes task to fail Wed, 15 Mar, 11:21
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5210) Failing performCheckpoint method causes task to fail Wed, 15 Mar, 11:24
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-5210) Failing performCheckpoint method causes task to fail Wed, 15 Mar, 11:24
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-6063) HA Configuration doesn't work with Flink 1.2 Wed, 15 Mar, 18:12
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-6063) HA Configuration doesn't work with Flink 1.2 Thu, 16 Mar, 13:33
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-6064) wrong BlobServer hostname in TaskExecutor Thu, 16 Mar, 13:37
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6076) Let the HeartbeatManager interface extend HeartbeatTarget Thu, 16 Mar, 13:58
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6078) ZooKeeper based high availability services should not close the underlying CuratorFramework Thu, 16 Mar, 14:50
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-6076) Let the HeartbeatManager interface extend HeartbeatTarget Fri, 17 Mar, 14:53
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-4364) Implement heartbeat logic between TaskManager and JobManager Fri, 17 Mar, 16:01
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6129) MetricQueryService does not stop query actor Mon, 20 Mar, 13:22
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-6129) MetricRegistry does not stop query actor Mon, 20 Mar, 13:23
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-6129) MetricRegistry does not stop query actor Mon, 20 Mar, 13:24
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5650) Flink-python tests executing cost too long time Mon, 20 Mar, 16:21
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-6063) HA Configuration doesn't work with Flink 1.2 Mon, 20 Mar, 16:26
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-6129) MetricRegistry does not stop query actor Mon, 20 Mar, 16:38
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6134) Set UUID(0L, 0L) as default leader session id Mon, 20 Mar, 17:19
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6136) Separate EmbeddedNonHaServices and NonHaServices Mon, 20 Mar, 17:34
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails Mon, 20 Mar, 17:39
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-6132) Remove redundant code in CliFrontend.java Tue, 21 Mar, 14:19
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6144) Port job manager related configuration options to ConfigOption Tue, 21 Mar, 16:06
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout Wed, 22 Mar, 11:09
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6161) Retry connection in case of a ResourceManager heartbeat timeout Wed, 22 Mar, 11:12
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-6134) Set UUID(0L, 0L) as default leader session id Wed, 22 Mar, 11:15
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-4354) Implement heartbeat logic between TaskManager and ResourceManager Thu, 23 Mar, 14:02
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
Feb 20204480
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