[jira] [Created] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor

Till Rohrmann created FLINK-5046: Summary: Avoid redundant serialization when creating the TaskDeploymentDescriptor Key: FLINK-5046 URL: https://issues.apache.org/jira/browse/FLINK-5046 Project:

[jira] [Created] (FLINK-5027) FileSource finishes successfully with a wrong path

Till Rohrmann created FLINK-5027: Summary: FileSource finishes successfully with a wrong path Key: FLINK-5027 URL: https://issues.apache.org/jira/browse/FLINK-5027 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15647135#comment-15647135 ] Till Rohrmann commented on FLINK-5013: -- Another user reported that on EMR 5.1.0 he gets the following

[jira] [Created] (FLINK-5033) CEP operators don't properly advance time

Till Rohrmann created FLINK-5033: Summary: CEP operators don't properly advance time Key: FLINK-5033 URL: https://issues.apache.org/jira/browse/FLINK-5033 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos

Till Rohrmann created FLINK-5055: Summary: Security feature crashes JM for certain Hadoop versions even though using no Kerberos Key: FLINK-5055 URL: https://issues.apache.org/jira/browse/FLINK-5055

[jira] [Closed] (FLINK-4954) Remove stashing from AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-4954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4954. Resolution: Fixed Fixed via 8f45e314aa4b21ce3137e46b0c22c8022fb39aa0 > Remove stashing from

[jira] [Closed] (FLINK-5033) CEP operators don't properly advance time

[ https://issues.apache.org/jira/browse/FLINK-5033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5033. Resolution: Fixed Fixed in 1.2 029fda24583c6655cd97d02773b5ca628cf9e8f1 in 1.1

[jira] [Closed] (FLINK-5027) FileSource finishes successfully with a wrong path

[ https://issues.apache.org/jira/browse/FLINK-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5027. Resolution: Fixed Fixed via 6516938b93c08882587d32e8c39e7ebd9ed2fc7b > FileSource finishes

[jira] [Closed] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor

[ https://issues.apache.org/jira/browse/FLINK-5046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5046. Resolution: Fixed Fixed in 1.2 via 58204da13d42c265d6a503a8cf738b6522e12ba6 in 1.1 via

[jira] [Created] (FLINK-4829) Accumulators are not thread safe

Till Rohrmann created FLINK-4829: Summary: Accumulators are not thread safe Key: FLINK-4829 URL: https://issues.apache.org/jira/browse/FLINK-4829 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-4489) Implement TaskManager's SlotAllocationTable

[ https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4489. Resolution: Fixed Added via 9da76dcfde689e8f4516880459b80c448233aec5 > Implement TaskManager's

[jira] [Created] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

Till Rohrmann created FLINK-4871: Summary: Add memory calculation for TaskManagers and forward MetricRegistry Key: FLINK-4871 URL: https://issues.apache.org/jira/browse/FLINK-4871 Project: Flink

[jira] [Updated] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4887: - Summary: Replace ActorGateway by TaskManagerGateway interface (was: Replace ActorGateway by

[jira] [Assigned] (FLINK-4887) Replace ActorGateway by TaskGateway interface

[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4887: Assignee: Till Rohrmann > Replace ActorGateway by TaskGateway interface >

[jira] [Created] (FLINK-4887) Replace ActorGateway by TaskGateway interface

Till Rohrmann created FLINK-4887: Summary: Replace ActorGateway by TaskGateway interface Key: FLINK-4887 URL: https://issues.apache.org/jira/browse/FLINK-4887 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions

[ https://issues.apache.org/jira/browse/FLINK-4847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4847. Resolution: Fixed Fixed via f63f972932e152822603d7a8bb8bf74bf3f05441 > Let

[jira] [Closed] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4851. Resolution: Fixed Fixed via f38bf4484df3e022f389357059ca984c5e3f76a6 > Add FatalErrorHandler and

[jira] [Closed] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

[ https://issues.apache.org/jira/browse/FLINK-4882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4882. Resolution: Fixed Fixed via 0de5689632bd1f8eac6e436959d80d31df9e5ef9 > Cleanup throws exception

[jira] [Closed] (FLINK-4853) Clean up JobManager registration at the ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4853. Resolution: Fixed Fixed via 0e965ae3e00454575a8920fce7b97842fdb9e3a9 > Clean up JobManager

[jira] [Closed] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4871. Resolution: Fixed Fixed via 80b6c2a015fa12bd73dfe8ccdb3930de0396e623 > Add memory calculation for

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581770#comment-15581770 ] Till Rohrmann commented on FLINK-4283: -- Maybe we could also replace the {{ExecutionContext.global}}

[jira] [Commented] (FLINK-4835) Implement standalone High Availability Services

[ https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581790#comment-15581790 ] Till Rohrmann commented on FLINK-4835: -- Don't we need

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

[ https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585342#comment-15585342 ] Till Rohrmann commented on FLINK-1807: -- This could work as a workaround but I think it's not the

[jira] [Created] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager

Till Rohrmann created FLINK-4851: Summary: Add FatalErrorHandler and MetricRegistry to ResourceManager Key: FLINK-4851 URL: https://issues.apache.org/jira/browse/FLINK-4851 Project: Flink

[jira] [Created] (FLINK-4853) Clean up JobManager registration at the ResourceManager

Till Rohrmann created FLINK-4853: Summary: Clean up JobManager registration at the ResourceManager Key: FLINK-4853 URL: https://issues.apache.org/jira/browse/FLINK-4853 Project: Flink Issue

[jira] [Created] (FLINK-4903) Introduce non async future methods

Till Rohrmann created FLINK-4903: Summary: Introduce non async future methods Key: FLINK-4903 URL: https://issues.apache.org/jira/browse/FLINK-4903 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-4857) ZooKeeperUtils have a throws exception clause without throwing exceptions

[ https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4857. Resolution: Fixed Fixed via 6f0faf9bb35e7cac3a38ed792cdabd6400fc4c79 > ZooKeeperUtils have a

[jira] [Created] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

Till Rohrmann created FLINK-4882: Summary: Cleanup throws exception clause in HighAvailabilityServices Key: FLINK-4882 URL: https://issues.apache.org/jira/browse/FLINK-4882 Project: Flink

[jira] [Created] (FLINK-4857) ZooKeeperUtils have a throws exception clause without throwing exceptions

Till Rohrmann created FLINK-4857: Summary: ZooKeeperUtils have a throws exception clause without throwing exceptions Key: FLINK-4857 URL: https://issues.apache.org/jira/browse/FLINK-4857 Project:

[jira] [Created] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

Till Rohrmann created FLINK-5063: Summary: State handles are not properly cleaned up for declined or expired checkpoints Key: FLINK-5063 URL: https://issues.apache.org/jira/browse/FLINK-5063 Project:

[jira] [Updated] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5063: - Description: In case that a {{Checkpoint}} is declined or expires, the {{CheckpointCoordinator}}

[jira] [Created] (FLINK-5065) Resource leaks in case of lost checkpoint messages

Till Rohrmann created FLINK-5065: Summary: Resource leaks in case of lost checkpoint messages Key: FLINK-5065 URL: https://issues.apache.org/jira/browse/FLINK-5065 Project: Flink Issue Type:

[jira] [Created] (FLINK-5064) Checkpoint messages are not scoped to the leader session ID

Till Rohrmann created FLINK-5064: Summary: Checkpoint messages are not scoped to the leader session ID Key: FLINK-5064 URL: https://issues.apache.org/jira/browse/FLINK-5064 Project: Flink

[jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684241#comment-15684241 ] Till Rohrmann commented on FLINK-3516: -- The test timed out in this instance so that it was terminated

[jira] [Closed] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout

[ https://issues.apache.org/jira/browse/FLINK-5010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5010. Resolution: Fixed Fix Version/s: (was: 1.1.4) Fixed in 1.2 via

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686321#comment-15686321 ] Till Rohrmann commented on FLINK-5114: -- The failing {{TimestampITCase}} seems to be related.

[jira] [Closed] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously

[ https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5085. Resolution: Fixed Fixed in 1.2 via c590912c93a4059b40452dfa6cffbdd4d58cac13 Fixed in 1.1.4 via

[jira] [Closed] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread

[ https://issues.apache.org/jira/browse/FLINK-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5073. Resolution: Fixed Fixed in 1.2 via 3fb92d8687f03c1fac8b87396b2b5a7ff29f6dd6 Fixed in 1.1.4 via

[jira] [Resolved] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts

[ https://issues.apache.org/jira/browse/FLINK-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5107. -- Resolution: Fixed Fixed via f5af7f1025aac9cac3f83de5f0e3aece5730ec0f > Job Manager goes out of

[jira] [Resolved] (FLINK-4910) Introduce safety net for closing file system streams

[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4910. -- Resolution: Fixed Fixed via ba8ed263695d16eacb4bdfdf195dd22c83bb53ed > Introduce safety net

[jira] [Created] (FLINK-5176) Properly wait for component shutdown in Runner components

Till Rohrmann created FLINK-5176: Summary: Properly wait for component shutdown in Runner components Key: FLINK-5176 URL: https://issues.apache.org/jira/browse/FLINK-5176 Project: Flink

[jira] [Resolved] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified

[ https://issues.apache.org/jira/browse/FLINK-5170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5170. -- Resolution: Fixed Fixed via 8265b545cff2fb5e6ca3771effd46a2fda488576 > getAkkaConfig will use

[jira] [Resolved] (FLINK-5076) Shutting down TM when shutting down new mini cluster

[ https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5076. -- Resolution: Fixed Fixed via dc8254d4b3eb7333d1e3a2717e01bab051da33a1 > Shutting down TM when

[jira] [Resolved] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

[ https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5093. -- Resolution: Fixed Fixed via 029db00c1d74222fd9f67b08213668fd0eea1e4d >

[jira] [Resolved] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner

[ https://issues.apache.org/jira/browse/FLINK-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5171. -- Resolution: Fixed Fixed via 09ec78a5bd5db1b74c267c8a69e182543135a161 > Wrong use of

[jira] [Closed] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager

[ https://issues.apache.org/jira/browse/FLINK-5082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5082. Resolution: Fixed Fixed in 1.2 via ae4b274a9919d01a236df4e819a0a07c5d8543ac Fixed in 1.1.4 via

[jira] [Created] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

Till Rohrmann created FLINK-5158: Summary: Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator Key: FLINK-5158 URL: https://issues.apache.org/jira/browse/FLINK-5158 Project:

[jira] [Assigned] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5158: Assignee: Till Rohrmann > Handle ZooKeeperCompletedCheckpointStore exceptions in

[jira] [Created] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously

Till Rohrmann created FLINK-5085: Summary: Execute CheckpointCoodinator's state discard calls asynchronously Key: FLINK-5085 URL: https://issues.apache.org/jira/browse/FLINK-5085 Project: Flink

[jira] [Created] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread

Till Rohrmann created FLINK-5073: Summary: ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread Key: FLINK-5073 URL: https://issues.apache.org/jira/browse/FLINK-5073

[jira] [Created] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager

Till Rohrmann created FLINK-5082: Summary: Pull ExecutionService lifecycle management out of the JobManager Key: FLINK-5082 URL: https://issues.apache.org/jira/browse/FLINK-5082 Project: Flink

[jira] [Created] (FLINK-5098) Detect network problems to eagerly time out ask operations

Till Rohrmann created FLINK-5098: Summary: Detect network problems to eagerly time out ask operations Key: FLINK-5098 URL: https://issues.apache.org/jira/browse/FLINK-5098 Project: Flink

[jira] [Created] (FLINK-5112) Remove unused accumulator code from ArchivedExecutionJobVertex

Till Rohrmann created FLINK-5112: Summary: Remove unused accumulator code from ArchivedExecutionJobVertex Key: FLINK-5112 URL: https://issues.apache.org/jira/browse/FLINK-5112 Project: Flink

[jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683770#comment-15683770 ] Till Rohrmann commented on FLINK-3053: -- Another instance on the release 1.1 branch

[jira] [Created] (FLINK-4986) Harden JobMaster logic

Till Rohrmann created FLINK-4986: Summary: Harden JobMaster logic Key: FLINK-4986 URL: https://issues.apache.org/jira/browse/FLINK-4986 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4887. Resolution: Fixed Fixed via cfb3790fb6feb6c771bccbd05d3b12c69f53657d > Replace ActorGateway by

[jira] [Closed] (FLINK-4958) Send slot report to RM when registering

[ https://issues.apache.org/jira/browse/FLINK-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4958. Resolution: Fixed Fixed via 360268c0b894234b37744579303e9fa1d989e830 > Send slot report to RM when

[jira] [Resolved] (FLINK-4987) Harden slot pool logic

[ https://issues.apache.org/jira/browse/FLINK-4987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4987. -- Resolution: Fixed Fixed via 8b2731a03681b9b74f5a640b3be14d53d22328cf > Harden slot pool logic

[jira] [Resolved] (FLINK-4986) Harden JobMaster logic

[ https://issues.apache.org/jira/browse/FLINK-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4986. -- Resolution: Fixed Fixed via e28711394de0cbba5ae840ff8b7cb4854a382d79 > Harden JobMaster logic

[jira] [Created] (FLINK-4987) Harden slot pool logic

Till Rohrmann created FLINK-4987: Summary: Harden slot pool logic Key: FLINK-4987 URL: https://issues.apache.org/jira/browse/FLINK-4987 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4889) Make InstanceManager independent of ActorRef

[ https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4889. Resolution: Fixed Fixed via

[jira] [Resolved] (FLINK-4850) FlinkML - SVM predict Operation for Vector and not LaveledVector

[ https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4850. -- Resolution: Fixed Fixed via da991aebb038b13a2d34344cf456c32feb4222dd > FlinkML - SVM predict

[jira] [Updated] (FLINK-4944) Replace Akka's death watch with own heartbeat on the TM side

[ https://issues.apache.org/jira/browse/FLINK-4944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4944: - Summary: Replace Akka's death watch with own heartbeat on the TM side (was: Replace Akka's

[jira] [Created] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout

Till Rohrmann created FLINK-5010: Summary: Decouple the death watch parameters from the Akka ask timeout Key: FLINK-5010 URL: https://issues.apache.org/jira/browse/FLINK-5010 Project: Flink

[jira] [Created] (FLINK-4944) Replace Akka's deatch watch with own heartbeat on the TM side

Till Rohrmann created FLINK-4944: Summary: Replace Akka's deatch watch with own heartbeat on the TM side Key: FLINK-4944 URL: https://issues.apache.org/jira/browse/FLINK-4944 Project: Flink

[jira] [Closed] (FLINK-4903) Introduce non async future methods

[ https://issues.apache.org/jira/browse/FLINK-4903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4903. Resolution: Fixed Added via 1e1e4dc701d3606bdcaa291d2d85460fdfbb0dc7 > Introduce non async future

[jira] [Created] (FLINK-4954) Remove stashing from AkkaRpcActor

Till Rohrmann created FLINK-4954: Summary: Remove stashing from AkkaRpcActor Key: FLINK-4954 URL: https://issues.apache.org/jira/browse/FLINK-4954 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

Till Rohrmann created FLINK-4973: Summary: Flakey Yarn tests due to recently added latency marker Key: FLINK-4973 URL: https://issues.apache.org/jira/browse/FLINK-4973 Project: Flink Issue

[jira] [Commented] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622525#comment-15622525 ] Till Rohrmann commented on FLINK-3813: -- Two more instances:

[jira] [Updated] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3813: - Affects Version/s: 1.2.0 > YARNSessionFIFOITCase.testDetachedMode failed on Travis >

[jira] [Updated] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4973: - Description: The newly introduced {{LatencyMarksEmitter}} emits latency marker on the

[jira] [Updated] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4973: - Labels: test-stability (was: ) > Flakey Yarn tests due to recently added latency marker >

[jira] [Updated] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4973: - Priority: Critical (was: Major) > Flakey Yarn tests due to recently added latency marker >

[jira] [Created] (FLINK-4968) Replace direct JobManager ActorGateways by JobManagerGateway

Till Rohrmann created FLINK-4968: Summary: Replace direct JobManager ActorGateways by JobManagerGateway Key: FLINK-4968 URL: https://issues.apache.org/jira/browse/FLINK-4968 Project: Flink

[jira] [Resolved] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4596. -- Resolution: Fixed Partly fixed via ac3997927e38f9da45de0b001d308430c323c842 > RESTART_STRATEGY

[jira] [Created] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down

Till Rohrmann created FLINK-5022: Summary: Suppress RejectedExecutionException when the Executor is shut down Key: FLINK-5022 URL: https://issues.apache.org/jira/browse/FLINK-5022 Project: Flink

[jira] [Created] (FLINK-4932) Don't let ExecutionGraph fail when in state Restarting

Till Rohrmann created FLINK-4932: Summary: Don't let ExecutionGraph fail when in state Restarting Key: FLINK-4932 URL: https://issues.apache.org/jira/browse/FLINK-4932 Project: Flink Issue

[jira] [Assigned] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3347: Assignee: Till Rohrmann > TaskManager (or its ActorSystem) need to restart in case they

[jira] [Created] (FLINK-4933) ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph

Till Rohrmann created FLINK-4933: Summary: ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph Key: FLINK-4933 URL: https://issues.apache.org/jira/browse/FLINK-4933 Project: Flink

[jira] [Resolved] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4283. -- Resolution: Fixed Fixed via b5938b052dfd1b4e9450c430446062852bca8850 >

[jira] [Created] (FLINK-4958) Send slot report to RM when registering

Till Rohrmann created FLINK-4958: Summary: Send slot report to RM when registering Key: FLINK-4958 URL: https://issues.apache.org/jira/browse/FLINK-4958 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4694) Add wait for termination function to RpcEndpoints

[ https://issues.apache.org/jira/browse/FLINK-4694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4694. Resolution: Fixed Added via f863d16860be24ab6932282db0722eadc51b64a6 > Add wait for termination

[jira] [Closed] (FLINK-4738) Port TaskManager logic to TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4738. Resolution: Fixed Added via 8c656d9252fd01ea82c75ff1ea830b110f68f8a9 > Port TaskManager logic to

[jira] [Closed] (FLINK-4746) Replace TaskManagerRuntimeInfo by TaskManagerConfiguration

[ https://issues.apache.org/jira/browse/FLINK-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4746. Resolution: Fixed Fixed via 64ee1386294cde6c61c8ee15c5e1d1ad018dcc46 > Replace

[jira] [Created] (FLINK-4783) Allow to register TypeInfoFactories manually

Till Rohrmann created FLINK-4783: Summary: Allow to register TypeInfoFactories manually Key: FLINK-4783 URL: https://issues.apache.org/jira/browse/FLINK-4783 Project: Flink Issue Type:

[jira] [Closed] (FLINK-4358) Implement TaskManager deployment task into slot

[ https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4358. Resolution: Fixed Done via FLINK-4738 > Implement TaskManager deployment task into slot >

[jira] [Closed] (FLINK-4360) Implement TaskManager registration slot at JobManager

[ https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4360. Resolution: Fixed Added via 2486d3787b0d45a6220d3dcc96ca665986c47837 > Implement TaskManager

[jira] [Closed] (FLINK-4357) Implement TaskManager side of slot allocation from ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4357. Resolution: Fixed Done via FLINK-4360 > Implement TaskManager side of slot allocation from

[jira] [Assigned] (FLINK-4357) Implement TaskManager side of slot allocation from ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4357: Assignee: Till Rohrmann (was: Zhijiang Wang) > Implement TaskManager side of slot

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582116#comment-15582116 ] Till Rohrmann commented on FLINK-4283: -- I think we can do this by not using the

[jira] [Commented] (FLINK-4835) Implement standalone High Availability Services

[ https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582109#comment-15582109 ] Till Rohrmann commented on FLINK-4835: -- Why does the NonHAServices inherit from

[jira] [Resolved] (FLINK-4839) JobManager handle TaskManager's slot offering

[ https://issues.apache.org/jira/browse/FLINK-4839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4839. -- Resolution: Fixed Fixed via 4f891a6c26847ac66c477853101de31eb75993f7 > JobManager handle

[jira] [Assigned] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions

[ https://issues.apache.org/jira/browse/FLINK-4847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4847: Assignee: Till Rohrmann > Let RpcEndpoint.start/shutDown throw exceptions >

[jira] [Created] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions

Till Rohrmann created FLINK-4847: Summary: Let RpcEndpoint.start/shutDown throw exceptions Key: FLINK-4847 URL: https://issues.apache.org/jira/browse/FLINK-4847 Project: Flink Issue Type:

[jira] [Created] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

Till Rohrmann created FLINK-5285: Summary: CancelCheckpointMarker flood when using at least once mode Key: FLINK-5285 URL: https://issues.apache.org/jira/browse/FLINK-5285 Project: Flink

[jira] [Created] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

Till Rohrmann created FLINK-5297: Summary: Relocate Flink's Hadoop dependency and its transitive dependencies Key: FLINK-5297 URL: https://issues.apache.org/jira/browse/FLINK-5297 Project: Flink

[jira] [Created] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

Till Rohrmann created FLINK-5300: Summary: FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory Key: FLINK-5300 URL: https://issues.apache.org/jira/browse/FLINK-5300

[jira] [Assigned] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5300: Assignee: Till Rohrmann > FileStateHandle#discard & FsCheckpointStateOutputStream#close

[jira] [Updated] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5300: - Priority: Critical (was: Minor) > FileStateHandle#discard & FsCheckpointStateOutputStream#close

[jira] [Commented] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

[ https://issues.apache.org/jira/browse/FLINK-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735043#comment-15735043 ] Till Rohrmann commented on FLINK-5297: -- Then let's try to first relocate {{aws-java-sdk}} and see

<    7   8   9   10   11   12   13   14   15   16   >