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
[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:
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
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
[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
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
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
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
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
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
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
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:
[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:
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:
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:
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:
[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:
[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:
[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:
[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:
[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:
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:
http://git-wip-us.apache.org/repos/asf/flink/blob/e3fcbb08/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master e8c909503 -> b8f8524af
[hotfix] [kafka] Remove unused operator state store field in
FlinkKafkaProducerBase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8f8524a
[FLINK-6608] [security, config] Relax Kerberos login contexts parsing
This closes #3928.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ffa9aa0e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ffa9aa0e
Diff:
[FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple
Kafka sink topics
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ed9b683
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9ed9b683
http://git-wip-us.apache.org/repos/asf/flink/blob/9ed9b683/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
--
diff --git
[FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom
partitioning
This commit wraps up some general improvements to the new Kafka sink
custom partitioning API, most notably:
1. remove deprecated constructors from base classes, as they are not
user-facing.
2. modify
[FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple
Kafka sink topics
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/58c4eed5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/58c4eed5
[FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom
partitioning
This commit wraps up some general improvements to the new Kafka sink
custom partitioning API, most notably:
1. remove deprecated constructors from base classes, as they are not
user-facing.
2. modify
http://git-wip-us.apache.org/repos/asf/flink/blob/d3b58709/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/58c4eed5/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
--
diff --git
[hotfix] [kafka] Remove unused operator state store field in
FlinkKafkaProducerBase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0963718a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0963718a
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.3 94111f985 -> 0963718ac
[FLINK-6608] [security, config] Relax Kerberos login contexts parsing
This closes #3928.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[hotfix] Remove some raw type usage in RocksDBKeyedStateBackend
Introduce more generic parameters
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f2af1a9f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f2af1a9f
[hotfix] Correct equals & hashCode implementation of KryoSerializer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e8c90950
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e8c90950
Diff:
[hotfix] Remove some raw type usage in RocksDBKeyedStateBackend
Introduce more generic parameters
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c573540
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6c573540
Repository: flink
Updated Branches:
refs/heads/release-1.3 51fb7ed79 -> 94111f985
[hotfix] Correct equals & hashCode implementation of KryoSerializer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/94111f98
Tree:
[hotfix] Restore KeySerializer only once
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cfb6a698
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cfb6a698
Diff:
[hotfix] Remove unnecessary job id from RocksDBKeyedStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20b356c7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/20b356c7
Diff:
Repository: flink
Updated Branches:
refs/heads/master 9a64d50f0 -> e8c909503
[hotfix] Restore KeySerializer only once
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef6f7b60
Tree:
[hotfix] Remove unnecessary job id from RocksDBKeyedStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe5b92f7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fe5b92f7
Diff:
[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:
[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:
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:
[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:
[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:
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
50 matches
Mail list logo