Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6322
---
Github user Wosin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6322#discussion_r202480724
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1759,11 +1759,22 @@ class JobManager(
case
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6322#discussion_r202248523
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1759,11 +1759,22 @@ class JobManager(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6322#discussion_r202248449
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1759,11 +1759,22 @@ class JobManager(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6322#discussion_r202248365
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1759,11 +1759,22 @@ class JobManager(
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6322#discussion_r202013852
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1759,11 +1759,22 @@ class JobManager(
case
GitHub user Wosin opened a pull request:
https://github.com/apache/flink/pull/6322
[FLINK-9575]: Remove job-related BLOBS only if the job was removed suceâ¦
## What is the purpose of the change
Currently flink removes all blobs connected with the job, no matter if the
job