flink git commit: [FLINK-4258] fix potential NPE in SavepointCoordinator

Repository: flink Updated Branches: refs/heads/master 9bcbcf4a5 -> 884d3e2a4 [FLINK-4258] fix potential NPE in SavepointCoordinator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/884d3e2a Tree:

flink git commit: [FLINK-4246] Allow Specifying Multiple Metrics Reporters

Repository: flink Updated Branches: refs/heads/master cd232e683 -> 9bcbcf4a5 [FLINK-4246] Allow Specifying Multiple Metrics Reporters This also updates documentation and tests. Reporters can now be specified like this: metrics.reporters: foo,bar metrics.reporter.foo.class:

flink git commit: [FLINK-4261][tools] retry in case of failed snapshot deployment

Repository: flink Updated Branches: refs/heads/master 2648bc1a5 -> cd232e683 [FLINK-4261][tools] retry in case of failed snapshot deployment Unfortunately, we can't deploy snapshots atomically using the Nexus repository. The staged process which leads to an atomic deployment is only designed

[2/2] flink git commit: [FLINK-4152] Allow re-registration of TMs at resource manager

[FLINK-4152] Allow re-registration of TMs at resource manager - Add YarnFlinkResourceManager test to reaccept task manager registrations from a re-elected job manager - Remove unnecessary sync logic between JobManager and ResourceManager - Avoid duplicate reigstration attempts in case of a

[1/2] flink git commit: [FLINK-4152] Allow re-registration of TMs at resource manager

Repository: flink Updated Branches: refs/heads/master c6715b7f7 -> 2648bc1a5 http://git-wip-us.apache.org/repos/asf/flink/blob/2648bc1a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFlinkResourceManagerTest.java -- diff

flink git commit: [travis] remove outdated comment regarding snapshots

Repository: flink Updated Branches: refs/heads/master e3fec1f9a -> c6715b7f7 [travis] remove outdated comment regarding snapshots Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c6715b7f Tree:

[2/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java -- diff --git

[6/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

[FLINK-4192] [metrics] Move metrics classes out of 'flink-core' - moved user-facing API to 'flink-metrics/flink-metrics-core' - moved JMXReporter to 'flink-metrics/flink-metrics-jmx' - moved remaining metric classes to 'flink-runtime' This closes #2226 Project:

[3/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-metrics/flink-metrics-jmx/src/test/java/org/apache/flink/metrics/jmx/JMXReporterTest.java -- diff --git

[1/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

Repository: flink Updated Branches: refs/heads/master e4fe89d6e -> e3fec1f9a http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/TaskManagerGroupTest.java

[5/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-core/src/main/java/org/apache/flink/metrics/groups/UnregisteredMetricsGroup.java -- diff --git

flink git commit: [FLINK-4210][metrics] Move close()/isClosed() out of MetricGroup

Repository: flink Updated Branches: refs/heads/master 0b4c04d7d -> e4fe89d6e [FLINK-4210][metrics] Move close()/isClosed() out of MetricGroup This closes #2286 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e4fe89d6

flink git commit: [FLINK-4239] Set Default Allowed Lateness to Zero and Make Triggers Non-Purging

Repository: flink Updated Branches: refs/heads/master f0ac261ad -> 0b4c04d7d [FLINK-4239] Set Default Allowed Lateness to Zero and Make Triggers Non-Purging This closes #2278. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/3] flink git commit: [FLINK-4067] [runtime] Add savepoint headers

Repository: flink Updated Branches: refs/heads/master 110bba386 -> f0ac261ad http://git-wip-us.apache.org/repos/asf/flink/blob/f0ac261a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java

[2/3] flink git commit: [FLINK-4067] [runtime] Add savepoint headers

http://git-wip-us.apache.org/repos/asf/flink/blob/f0ac261a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java -- diff --git

[3/3] flink git commit: [FLINK-4067] [runtime] Add savepoint headers

[FLINK-4067] [runtime] Add savepoint headers Savepoints were previously persisted without any meta data using default Java serialization of `CompletedCheckpoint`. This commit introduces a savepoint interface with version-specific serializers and stores savepoints with meta data. Savepoints

[1/2] flink git commit: [FLINK-4103] [table] Modify CsvTableSource to implement StreamTableSource

Repository: flink Updated Branches: refs/heads/master 0360fb968 -> 110bba386 [FLINK-4103] [table] Modify CsvTableSource to implement StreamTableSource This closes #2162. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-4103] [table] Add CsvTableSource docs and Java accessibility

[FLINK-4103] [table] Add CsvTableSource docs and Java accessibility Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/110bba38 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/110bba38 Diff: