flink git commit: [hotfix] [tests] Harden JobManagerRegistrationTest

Repository: flink Updated Branches: refs/heads/master 90ca43810 -> 926547582 [hotfix] [tests] Harden JobManagerRegistrationTest The problem is that we don't wait until the JobManager becomes the leader. Due to this, the sent RegisterTaskManager messages might get dropped. This PR fixes the p

[1/2] flink git commit: [hotfix] Fix wrong comparator in WindowOperatorTest

Repository: flink Updated Branches: refs/heads/master 926547582 -> db759c530 [hotfix] Fix wrong comparator in WindowOperatorTest And also the same bug in WindowOperatorMigrationTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flin

[2/2] flink git commit: [FLINK-4953] Allow access to "time" in ProcessWindowFunction.Context

[FLINK-4953] Allow access to "time" in ProcessWindowFunction.Context Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db759c53 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db759c53 Diff: http://git-wip-us.apache.org/

[1/4] flink git commit: [hotfix][metrics] keep the non-null assumption and implement tests properly

Repository: flink Updated Branches: refs/heads/master db759c530 -> fff04bfbe [hotfix][metrics] keep the non-null assumption and implement tests properly Previous commit in e908b62ab3 caused a regression leading to unit test failures. Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[2/4] flink git commit: [hotfix][metrics] remove an unnecessary check for non-null

[hotfix][metrics] remove an unnecessary check for non-null The metrics group given to a Task must always be non-null otherwise the code would have crashed anyway. Similarly, the group returned by getIOMetricGroup() is always present. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Com

[3/4] flink git commit: [FLINK-5090] [network] Add metrics for details about inbound/outbound network queues

[FLINK-5090] [network] Add metrics for details about inbound/outbound network queues These metrics are optimised go go through the channels only once in order to gather all metrics, i.e. min, max, avg and sum. Whenever a request to either of those is made, all metrics are refreshed and cached. Re

[4/4] flink git commit: [FLINK-5090] Fixups for "Add metrics for details about inbound/outbound network queues"

[FLINK-5090] Fixups for "Add metrics for details about inbound/outbound network queues" This closes #3348. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fff04bfb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fff0

[2/2] flink git commit: [FLINK-6392] [table] Improve group window API to make alias mandatory.

[FLINK-6392] [table] Improve group window API to make alias mandatory. This closes #3786. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb972b85 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bb972b85 Diff: http://

[1/2] flink git commit: [FLINK-6247] [table] Put flink-table.jar with all dependencies into ./opt folder.

Repository: flink Updated Branches: refs/heads/master fff04bfbe -> bb972b85a [FLINK-6247] [table] Put flink-table.jar with all dependencies into ./opt folder. This closes #3666. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/c

flink git commit: [FLINK-6120] [heartbeat] Implement heartbeat logic between JobManager and ResourceManager

Repository: flink Updated Branches: refs/heads/master bb972b85a -> 81114d5f7 [FLINK-6120] [heartbeat] Implement heartbeat logic between JobManager and ResourceManager This closes #3645. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf

Build failed in Jenkins: flink-snapshot-deployment #444

See -- [...truncated 433.20 KB...] required: org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator,?,?> found: org.apache.flink.streaming.api.ope

flink git commit: [FLINK-6176] [scripts] [yarn] [mesos] Add JARs to CLASSPATH deterministically

Repository: flink Updated Branches: refs/heads/release-1.2 664c49df7 -> ef20aa1a1 [FLINK-6176] [scripts] [yarn] [mesos] Add JARs to CLASSPATH deterministically Sorts files read from Flink's lib directory and places the distribution JAR to the end of the CLASSPATH. This closes #3632 Project:

Build failed in Jenkins: flink-snapshot-deployment #445

See -- [...truncated 472.33 KB...] required: org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator,?,?> found: org.apache.flink.streaming.api.ope

flink git commit: [FLINK-6404] [FLINK-6400] Ensure PendingCheckpoint is registered when calling Checkpoint Hooks

Repository: flink Updated Branches: refs/heads/master 81114d5f7 -> fcb13e1f5 [FLINK-6404] [FLINK-6400] Ensure PendingCheckpoint is registered when calling Checkpoint Hooks Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f

Build failed in Jenkins: flink-snapshot-deployment #446

See -- [...truncated 429.44 KB...] required: org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator,?,?> found: org.apache.flink.streaming.api.ope