Skip to content

Commit

Permalink
[FLINK-2354] [runtime] Remove state changing futures in JobManager
Browse files Browse the repository at this point in the history
Internal actor states must only be modified within the actor thread.
This avoids all the well-known issues coming with concurrency.

Fix RemoveCachedJob by introducing RemoveJob

Fix JobManagerITCase

Add removeJob which maintains the job in the SubmittedJobGraphStore

Make revokeLeadership not remove the jobs from the state backend

Fix shading problem with curator by hiding CuratorFramework in ChaosMonkeyITCase
  • Loading branch information
tillrohrmann committed Oct 19, 2015
1 parent 73c73e9 commit c2989f2
Show file tree
Hide file tree
Showing 14 changed files with 404 additions and 189 deletions.
4 changes: 2 additions & 2 deletions flink-runtime/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -182,7 +182,7 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-shaded-curator</artifactId>
<artifactId>flink-shaded-curator-recipes</artifactId>
<version>${project.version}</version>
</dependency>

Expand Down Expand Up @@ -417,7 +417,7 @@ under the License.
<configuration>
<artifactSet>
<includes combine.children="append">
<include>org.apache.flink:flink-shaded-curator</include>
<include>org.apache.flink:flink-shaded-curator-recipes</include>
</includes>
</artifactSet>
<relocations combine.children="append">
Expand Down
Loading

0 comments on commit c2989f2

Please sign in to comment.