Repository: flink Updated Branches: refs/heads/master 8595dadb8 -> 2fd8721d0
http://git-wip-us.apache.org/repos/asf/flink/blob/0c771505/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java index 8f803ed..0a4b5bf 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java @@ -49,14 +49,14 @@ import org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer; import org.apache.flink.core.memory.DataOutputViewStreamWrapper; import org.apache.flink.core.testutils.CheckedThread; import org.apache.flink.core.testutils.OneShotLatch; +import org.apache.flink.queryablestate.KvStateID; +import org.apache.flink.queryablestate.client.state.serialization.KvStateSerializer; import org.apache.flink.runtime.checkpoint.CheckpointOptions; import org.apache.flink.runtime.checkpoint.StateAssignmentOperation; import org.apache.flink.runtime.execution.Environment; import org.apache.flink.runtime.operators.testutils.DummyEnvironment; -import org.apache.flink.runtime.query.KvStateID; import org.apache.flink.runtime.query.KvStateRegistry; import org.apache.flink.runtime.query.KvStateRegistryListener; -import org.apache.flink.runtime.query.netty.message.KvStateSerializer; import org.apache.flink.runtime.state.heap.AbstractHeapState; import org.apache.flink.runtime.state.heap.NestedMapsStateTable; import org.apache.flink.runtime.state.heap.StateTable; http://git-wip-us.apache.org/repos/asf/flink/blob/0c771505/flink-tests/src/test/java/org/apache/flink/test/completeness/TypeInfoTestCoverageTest.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/completeness/TypeInfoTestCoverageTest.java b/flink-tests/src/test/java/org/apache/flink/test/completeness/TypeInfoTestCoverageTest.java index 91566af..95e1598 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/completeness/TypeInfoTestCoverageTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/completeness/TypeInfoTestCoverageTest.java @@ -50,7 +50,8 @@ public class TypeInfoTestCoverageTest extends TestLogger { typeInfo.getName().contains("Test$") || typeInfo.getName().contains("TestBase$") || typeInfo.getName().contains("ITCase$") || - typeInfo.getName().contains("$$anon")) { + typeInfo.getName().contains("$$anon") || + typeInfo.getName().contains("queryablestate")) { continue; } boolean found = false; http://git-wip-us.apache.org/repos/asf/flink/blob/0c771505/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index 9384a48..e4a49d4 100644 --- a/pom.xml +++ b/pom.xml @@ -68,6 +68,7 @@ under the License. <module>flink-connectors</module> <module>flink-examples</module> <module>flink-clients</module> + <module>flink-queryable-state</module> <module>flink-tests</module> <module>flink-end-to-end-tests</module> <module>flink-test-utils-parent</module> @@ -81,7 +82,6 @@ under the License. <module>flink-yarn</module> <module>flink-yarn-tests</module> <module>flink-fs-tests</module> - <module>flink-queryable-state</module> </modules> <properties> http://git-wip-us.apache.org/repos/asf/flink/blob/0c771505/tools/travis_mvn_watchdog.sh ---------------------------------------------------------------------- diff --git a/tools/travis_mvn_watchdog.sh b/tools/travis_mvn_watchdog.sh index f608e51..b7e3709 100755 --- a/tools/travis_mvn_watchdog.sh +++ b/tools/travis_mvn_watchdog.sh @@ -68,7 +68,8 @@ flink-libraries/flink-gelly-examples,\ flink-libraries/flink-ml,\ flink-libraries/flink-python,\ flink-libraries/flink-table,\ -flink-queryable-state/flink-queryable-state-java" +flink-queryable-state/flink-queryable-state-runtime,\ +flink-queryable-state/flink-queryable-state-client-java" MODULES_CONNECTORS="\ flink-contrib/flink-connector-wikiedits,\
