The Buildbot has detected a new failure on builder flink-docs-release-0.9 while
building . Full details are available at:
https://ci.apache.org/builders/flink-docs-release-0.9/builds/695
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave2_ubuntu
Build Reason: The Night
The Buildbot has detected a new failure on builder flink-docs-release-1.0 while
building . Full details are available at:
https://ci.apache.org/builders/flink-docs-release-1.0/builds/454
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave3_ubuntu
Build Reason: The Night
The Buildbot has detected a new failure on builder flink-docs-release-1.1 while
building . Full details are available at:
https://ci.apache.org/builders/flink-docs-release-1.1/builds/300
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave3_ubuntu
Build Reason: The Night
The Buildbot has detected a new failure on builder flink-docs-release-1.2 while
building . Full details are available at:
https://ci.apache.org/builders/flink-docs-release-1.2/builds/124
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave2_ubuntu
Build Reason: The Night
The Buildbot has detected a new failure on builder flink-docs-master while
building . Full details are available at:
https://ci.apache.org/builders/flink-docs-master/builds/717
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave3_ubuntu
Build Reason: The Nightly schedul
[FLINK-5636][metrics] Measure numRecordsIn in StreamTwoInputProcessor
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54b88d71
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/54b88d71
Diff: http://git-wip-us.apache.org
[hotfix][rat] Add exclusion for all test snapshots/savepoints
This closes #3854.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17a4bb14
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17a4bb14
Diff: http://git-wip-u
Repository: flink
Updated Branches:
refs/heads/release-1.3 c62553c00 -> 5fde739fd
[FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fde739f
Tree: ht
[FLINK-6586] InputGateMetrics return 0 as min for local channels
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c3ab5c82
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c3ab5c82
Diff: http://git-wip-us.apache.org/repo
[FLINK-6639][docs] fix code tabs in CEP docs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5d1cda52
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5d1cda52
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5d1
[FLINK-6586] InputGateMetrics return 0 as min for local channels
This closes #3907.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17ec6f02
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17ec6f02
Diff: http://git-wi
Repository: flink
Updated Branches:
refs/heads/master 8e3213678 -> 65fdadac8
[hotfix][rat] Add exclusion for all test snapshots/savepoints
This closes #3854.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4b485307
Tree:
[FLINK-6639][docs] fix code tabs in CEP docs
This closes #3952.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fadc026b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fadc026b
Diff: http://git-wip-us.apache.org/repo
[FLINK-5636][metrics] Measure numRecordsIn in StreamTwoInputProcessor
This closes #3950.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ccaffe3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8ccaffe3
Diff: http://g
[FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil
This closes #3904.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/65fdadac
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/65fdadac
Diff: htt
Repository: flink
Updated Branches:
refs/heads/release-1.3 f6a596fe3 -> c62553c00
[FLINK-6634] [cep] NFASerializer serializes ComputationState counter.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c62553c0
Tree: http://
Repository: flink
Updated Branches:
refs/heads/master 8814ba767 -> 8e3213678
[FLINK-6634] [cep] NFASerializer serializes ComputationState counter.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e321367
Tree: http://git-w
[FLINK-6606] Set UserCodeClassLoader as TCCL for MasterTriggerRestoreHook
- wrap calls to MasterTriggerRestoreHook (and its factory) such that the user
classloader is applied
This closes #3933.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repo
Repository: flink
Updated Branches:
refs/heads/master acea4cde5 -> 8814ba767
[FLINK-6606] Hide WrapperMasterHook by making it private
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8814ba76
Tree: http://git-wip-us.apache.
[FLINK-6606] Hide WrapperMasterHook by making it private
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f6a596fe
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f6a596fe
Diff: http://git-wip-us.apache.org/repos/asf/fl
Repository: flink
Updated Branches:
refs/heads/release-1.3 6d178a959 -> f6a596fe3
[FLINK-6606] Set UserCodeClassLoader as TCCL for MasterTriggerRestoreHook
- wrap calls to MasterTriggerRestoreHook (and its factory) such that the user
classloader is applied
This closes #3933.
Project: http:
Repository: flink
Updated Branches:
refs/heads/release-1.3 d1cff3ae3 -> 6d178a959
[FLINK-6574] [table] Support nested catalogs in ExternalCatalog.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d178a95
Tree: http://git-w
Repository: flink
Updated Branches:
refs/heads/master 6ae759ae5 -> acea4cde5
[FLINK-6574] [table] Support nested catalogs in ExternalCatalog.
This closes #3913.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/acea4cde
Tre
Repository: flink
Updated Branches:
refs/heads/release-1.3 f62004079 -> d1cff3ae3
[FLINK-6582] [docs] Project from maven archetype is not buildable by default
The pom.xml for flink-quickstart-java and flink-quickstart-scala must
specify scala.version and scala.binary.version.
This closes #391
Repository: flink
Updated Branches:
refs/heads/master 0162543ac -> 6ae759ae5
[FLINK-6582] [docs] Project from maven archetype is not buildable by default
The pom.xml for flink-quickstart-java and flink-quickstart-scala must
specify scala.version and scala.binary.version.
This closes #3910
P
Repository: flink
Updated Branches:
refs/heads/release-1.3 0963718ac -> f62004079
http://git-wip-us.apache.org/repos/asf/flink/blob/f58fec70/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStoreTest.java
http://git-wip-us.apache.org/repos/asf/flink/blob/f6200407/flink-runtime/src/test/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandleTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/
[FLINK-6612] Allow ZooKeeperStateHandleStore to lock created ZNodes
In order to guard against deletions of ZooKeeper nodes which are still being
used
by a different ZooKeeperStateHandleStore, we have to introduce a locking
mechanism.
Only after all ZooKeeperStateHandleStores have released their
[FLINK-6633] Register shared state before adding to CompletedCheckpointStore
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f6200407
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f6200407
Diff: http://git-wip-us.apa
[FLINK-6633] Register shared state before adding to CompletedCheckpointStore
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0162543a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0162543a
Diff: http://git-wip-us.apa
Repository: flink
Updated Branches:
refs/heads/master b8f8524af -> 0162543ac
http://git-wip-us.apache.org/repos/asf/flink/blob/0162543a/flink-runtime/src/test/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandleTest.java
---
http://git-wip-us.apache.org/repos/asf/flink/blob/3d119e11/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStoreTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/zook
[FLINK-6612] Allow ZooKeeperStateHandleStore to lock created ZNodes
In order to guard against deletions of ZooKeeper nodes which are still being
used
by a different ZooKeeperStateHandleStore, we have to introduce a locking
mechanism.
Only after all ZooKeeperStateHandleStores have released their
33 matches
Mail list logo