[2/2] flink git commit: [FLINK-6336] [mesos] Add mesos placement constraints

[FLINK-6336] [mesos] Add mesos placement constraints This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks to be placed on agents with matching attributes. Signed-off-by: Stephen Gran This closes #3744. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http:

[1/2] flink git commit: [FLINK-5975] Add volume support to flink-mesos

Repository: flink Updated Branches: refs/heads/master fcb13e1f5 -> 8ef6926f3 [FLINK-5975] Add volume support to flink-mesos When using containerization, specifically, docker, it is useful to be able to attach additional volumes, such as an NFS share. This adds support for volumes to be attach

flink git commit: [FLINK-6398] RowSerializer's duplicate should always return a new instance

Repository: flink Updated Branches: refs/heads/master 8ef6926f3 -> b0cd48dd3 [FLINK-6398] RowSerializer's duplicate should always return a new instance This closes #3794. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0

flink git commit: [FLINK-6386] Missing bracket in 'Compiler Limitation' section

Repository: flink Updated Branches: refs/heads/master b0cd48dd3 -> 753763ad1 [FLINK-6386] Missing bracket in 'Compiler Limitation' section This closes #3775. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/753763ad Tree:

flink git commit: [FLINK-3347] [akka] Add QuarantineMonitor which shuts a quarantined actor system and JVM down

Repository: flink Updated Branches: refs/heads/master 753763ad1 -> bdf5c486f [FLINK-3347] [akka] Add QuarantineMonitor which shuts a quarantined actor system and JVM down The QuarantineMonitor subscribes to the actor system's event bus and listens to AssociationErrorEvents. These are the even

flink git commit: [FLINK-6410] [build] Fix Gelly Example packaging to support different Scala versions

Repository: flink Updated Branches: refs/heads/master bdf5c486f -> 03afbca5d [FLINK-6410] [build] Fix Gelly Example packaging to support different Scala versions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/03afbca5 Tr

flink git commit: [hotfix] Change checkstyle/suppression file references to be absolute

Repository: flink Updated Branches: refs/heads/master 03afbca5d -> b527582d0 [hotfix] Change checkstyle/suppression file references to be absolute The relative path caused problems with "mvn deploy". Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.

[1/2] flink git commit: [FLINK-6208] [cep] Implement skip till next match strategy

Repository: flink Updated Branches: refs/heads/master b527582d0 -> 7c35dc0e4 http://git-wip-us.apache.org/repos/asf/flink/blob/7c35dc0e/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java -- diff --g

[2/2] flink git commit: [FLINK-6208] [cep] Implement skip till next match strategy

[FLINK-6208] [cep] Implement skip till next match strategy Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c35dc0e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7c35dc0e Diff: http://git-wip-us.apache.org/repos/asf/

Jenkins build is back to normal : flink-snapshot-deployment #447

See

flink git commit: [FLINK-6293] [tests] Harden JobManagerITCase

Repository: flink Updated Branches: refs/heads/master 7c35dc0e4 -> f3da8f69e [FLINK-6293] [tests] Harden JobManagerITCase One of the unit tests in JobManagerITCase starts a MiniCluster and sends a LeaderSessionMessage to the JobManager without waiting until the JobManager has gained leadership

[2/7] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runt

[1/7] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

Repository: flink Updated Branches: refs/heads/master f3da8f69e -> d75ec5b35 http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java -

[3/7] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/reso

[5/7] flink git commit: [FLINK-5810] [flip-6] Multiple small cleanups across Resource Manager related code

[FLINK-5810] [flip-6] Multiple small cleanups across Resource Manager related code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/759f46ea Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/759f46ea Diff: http://git-wip

[4/7] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

[FLINK-5810] [flip-6] Introduce a hardened slot manager Harden the slot manager so that it better deals with lost and out of order messages from the TaskManager. The basic idea is that the TaskManager are considered the ground truth and the SlotManager tries to maintain a consistent view of what

[7/7] flink git commit: [FLINK-5810] [flip-6] Use single timeout task for SlotManager

[FLINK-5810] [flip-6] Use single timeout task for SlotManager Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d75ec5b3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d75ec5b3 Diff: http://git-wip-us.apache.org/repos/a

[6/7] flink git commit: [FLINK-5810] [flip-6] Make slot registration static

[FLINK-5810] [flip-6] Make slot registration static Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d16a5a29 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d16a5a29 Diff: http://git-wip-us.apache.org/repos/asf/flink/d

flink git commit: [FLINK-6411] [flip-6] Remove job removal from RunningJobsRegistry in YarnFlinkApplicationMasterRunner.shutdown

Repository: flink Updated Branches: refs/heads/master d75ec5b35 -> c36d6b808 [FLINK-6411] [flip-6] Remove job removal from RunningJobsRegistry in YarnFlinkApplicationMasterRunner.shutdown The YarnFlinkApplicationMasterRunner should not be concerned with removing jobs from the RunningJobsRegi

flink git commit: [FLINK-6398] RowSerializer's duplicate should always return a new instance

Repository: flink Updated Branches: refs/heads/release-1.2 ef20aa1a1 -> c0fb70f1c [FLINK-6398] RowSerializer's duplicate should always return a new instance This closes #3794. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/comm

[1/2] flink git commit: [FLINK-6341] [jm] Don't let JM fall into infinite loop

Repository: flink Updated Branches: refs/heads/master c36d6b808 -> 591841f30 [FLINK-6341] [jm] Don't let JM fall into infinite loop This closes #3745. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23838392 Tree: http://

[2/2] flink git commit: [FLINK-6341] [jm] Add test case to guard against RM registration loop

[FLINK-6341] [jm] Add test case to guard against RM registration loop Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/591841f3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/591841f3 Diff: http://git-wip-us.apache.org

[4/6] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperationV2.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkp

[6/6] flink git commit: [FLINK-5892] Add tests for topology modifications

[FLINK-5892] Add tests for topology modifications This closes #3770. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c68085f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2c68085f Diff: http://git-wip-us.apache.org

[3/6] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpo

[1/6] flink git commit: [FLINK-5892] Add new StateAssignmentOperationV2

Repository: flink Updated Branches: refs/heads/master 591841f30 -> 2c68085f6 [FLINK-5892] Add new StateAssignmentOperationV2 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8045faba Tree: http://git-wip-us.apache.org/repos

[5/6] flink git commit: [Flink-5892] Restore state on operator level

[Flink-5892] Restore state on operator level Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7980a7e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7980a7e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f79

[2/6] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java -- diff --git a/flink-streaming-java/src/main/java/org/apache/flink

flink git commit: [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table.

Repository: flink Updated Branches: refs/heads/master 2c68085f6 -> c8eb55f17 [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table. This closes #3546. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/f

flink git commit: [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table.

Repository: flink Updated Branches: refs/heads/release-1.2 c0fb70f1c -> fdb3f65f2 [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fdb