You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/01/09 08:59:32 UTC
[flink] branch master updated (64f766f -> 4782236)
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 64f766f [hotfix][docs] Sync formatting for cli usage examples
new 9323ef6 [hotfix][test] Remove usage of deprecated method
new 5b5ec59 [hotfix][test] Reduce test timeout to a reasonable value
new 4782236 [hotfix][test] Adjust suppressWarnings
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../itcases/AbstractQueryableStateTestBase.java | 12 ++++++------
.../itcases/HAQueryableStateFsBackendITCase.java | 4 ++--
.../itcases/HAQueryableStateRocksDBBackendITCase.java | 4 ++--
.../itcases/NonHAQueryableStateFsBackendITCase.java | 4 ++--
.../itcases/NonHAQueryableStateRocksDBBackendITCase.java | 4 ++--
5 files changed, 14 insertions(+), 14 deletions(-)
[flink] 02/03: [hotfix][test] Reduce test timeout to a reasonable
value
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5b5ec591273fc6ce8352f20fd9108315bc0a05d9
Author: tison <wa...@gmail.com>
AuthorDate: Tue Jan 8 13:25:03 2019 +0800
[hotfix][test] Reduce test timeout to a reasonable value
---
.../flink/queryablestate/itcases/AbstractQueryableStateTestBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
index bb48910..9efc9e2 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
@@ -106,7 +106,7 @@ import static org.junit.Assert.fail;
*/
public abstract class AbstractQueryableStateTestBase extends TestLogger {
- private static final Duration TEST_TIMEOUT = Duration.ofSeconds(10000L);
+ private static final Duration TEST_TIMEOUT = Duration.ofSeconds(200L);
private static final long RETRY_TIMEOUT = 50L;
private final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4);
[flink] 03/03: [hotfix][test] Adjust suppressWarnings
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4782236aaec550f478ff21f8ae1a08f5c5a6ac2f
Author: tison <wa...@gmail.com>
AuthorDate: Tue Jan 8 13:26:44 2019 +0800
[hotfix][test] Adjust suppressWarnings
---
.../flink/queryablestate/itcases/AbstractQueryableStateTestBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
index 9efc9e2..ac4052e 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
@@ -153,7 +153,6 @@ public abstract class AbstractQueryableStateTestBase extends TestLogger {
* to query the counts of each key in rounds until all keys have non-zero counts.
*/
@Test
- @SuppressWarnings("unchecked")
public void testQueryableState() throws Exception {
final Deadline deadline = Deadline.now().plus(TEST_TIMEOUT);
final int numKeys = 256;
@@ -597,6 +596,7 @@ public abstract class AbstractQueryableStateTestBase extends TestLogger {
}
}).asQueryableState("matata");
+ @SuppressWarnings("unchecked")
final ValueStateDescriptor<Tuple2<Integer, Long>> stateDesc =
(ValueStateDescriptor<Tuple2<Integer, Long>>) queryableState.getStateDescriptor();
[flink] 01/03: [hotfix][test] Remove usage of deprecated method
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9323ef6ac12e1a44f9745ea7589c526153223cfa
Author: tison <wa...@gmail.com>
AuthorDate: Tue Jan 8 13:24:26 2019 +0800
[hotfix][test] Remove usage of deprecated method
---
.../queryablestate/itcases/AbstractQueryableStateTestBase.java | 8 ++++----
.../queryablestate/itcases/HAQueryableStateFsBackendITCase.java | 4 ++--
.../itcases/HAQueryableStateRocksDBBackendITCase.java | 4 ++--
.../itcases/NonHAQueryableStateFsBackendITCase.java | 4 ++--
.../itcases/NonHAQueryableStateRocksDBBackendITCase.java | 4 ++--
5 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
index eb6b3ef..bb48910 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
@@ -56,8 +56,8 @@ import org.apache.flink.runtime.concurrent.ScheduledExecutor;
import org.apache.flink.runtime.concurrent.ScheduledExecutorServiceAdapter;
import org.apache.flink.runtime.jobgraph.JobGraph;
import org.apache.flink.runtime.jobgraph.JobStatus;
-import org.apache.flink.runtime.state.AbstractStateBackend;
import org.apache.flink.runtime.state.CheckpointListener;
+import org.apache.flink.runtime.state.StateBackend;
import org.apache.flink.runtime.testingUtils.TestingUtils;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.QueryableStateStream;
@@ -107,7 +107,7 @@ import static org.junit.Assert.fail;
public abstract class AbstractQueryableStateTestBase extends TestLogger {
private static final Duration TEST_TIMEOUT = Duration.ofSeconds(10000L);
- public static final long RETRY_TIMEOUT = 50L;
+ private static final long RETRY_TIMEOUT = 50L;
private final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(4);
private final ScheduledExecutor executor = new ScheduledExecutorServiceAdapter(executorService);
@@ -115,7 +115,7 @@ public abstract class AbstractQueryableStateTestBase extends TestLogger {
/**
* State backend to use.
*/
- protected AbstractStateBackend stateBackend;
+ private StateBackend stateBackend;
/**
* Client shared between all the test.
@@ -142,7 +142,7 @@ public abstract class AbstractQueryableStateTestBase extends TestLogger {
*
* @return a state backend instance for each unit test
*/
- protected abstract AbstractStateBackend createStateBackend() throws Exception;
+ protected abstract StateBackend createStateBackend() throws Exception;
/**
* Runs a simple topology producing random (key, 1) pairs at the sources (where
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateFsBackendITCase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateFsBackendITCase.java
index 9755b52..ef6a267 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateFsBackendITCase.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateFsBackendITCase.java
@@ -25,7 +25,7 @@ import org.apache.flink.configuration.QueryableStateOptions;
import org.apache.flink.configuration.TaskManagerOptions;
import org.apache.flink.configuration.WebOptions;
import org.apache.flink.queryablestate.client.QueryableStateClient;
-import org.apache.flink.runtime.state.AbstractStateBackend;
+import org.apache.flink.runtime.state.StateBackend;
import org.apache.flink.runtime.state.filesystem.FsStateBackend;
import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
import org.apache.flink.test.util.MiniClusterWithClientResource;
@@ -58,7 +58,7 @@ public class HAQueryableStateFsBackendITCase extends AbstractQueryableStateTestB
private static MiniClusterWithClientResource miniClusterResource;
@Override
- protected AbstractStateBackend createStateBackend() throws Exception {
+ protected StateBackend createStateBackend() throws Exception {
return new FsStateBackend(temporaryFolder.newFolder().toURI().toString());
}
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateRocksDBBackendITCase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateRocksDBBackendITCase.java
index 94baaed..46202c3 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateRocksDBBackendITCase.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAQueryableStateRocksDBBackendITCase.java
@@ -26,7 +26,7 @@ import org.apache.flink.configuration.TaskManagerOptions;
import org.apache.flink.configuration.WebOptions;
import org.apache.flink.contrib.streaming.state.RocksDBStateBackend;
import org.apache.flink.queryablestate.client.QueryableStateClient;
-import org.apache.flink.runtime.state.AbstractStateBackend;
+import org.apache.flink.runtime.state.StateBackend;
import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
import org.apache.flink.test.util.MiniClusterWithClientResource;
@@ -58,7 +58,7 @@ public class HAQueryableStateRocksDBBackendITCase extends AbstractQueryableState
private static MiniClusterWithClientResource miniClusterResource;
@Override
- protected AbstractStateBackend createStateBackend() throws Exception {
+ protected StateBackend createStateBackend() throws Exception {
return new RocksDBStateBackend(temporaryFolder.newFolder().toURI().toString());
}
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java
index 36637c0..f138255 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java
@@ -24,7 +24,7 @@ import org.apache.flink.configuration.QueryableStateOptions;
import org.apache.flink.configuration.TaskManagerOptions;
import org.apache.flink.configuration.WebOptions;
import org.apache.flink.queryablestate.client.QueryableStateClient;
-import org.apache.flink.runtime.state.AbstractStateBackend;
+import org.apache.flink.runtime.state.StateBackend;
import org.apache.flink.runtime.state.filesystem.FsStateBackend;
import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
import org.apache.flink.test.util.MiniClusterWithClientResource;
@@ -61,7 +61,7 @@ public class NonHAQueryableStateFsBackendITCase extends AbstractQueryableStateTe
.build());
@Override
- protected AbstractStateBackend createStateBackend() throws Exception {
+ protected StateBackend createStateBackend() throws Exception {
return new FsStateBackend(temporaryFolder.newFolder().toURI().toString());
}
diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateRocksDBBackendITCase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateRocksDBBackendITCase.java
index ce3e665..3ad0dda 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateRocksDBBackendITCase.java
+++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateRocksDBBackendITCase.java
@@ -25,7 +25,7 @@ import org.apache.flink.configuration.TaskManagerOptions;
import org.apache.flink.configuration.WebOptions;
import org.apache.flink.contrib.streaming.state.RocksDBStateBackend;
import org.apache.flink.queryablestate.client.QueryableStateClient;
-import org.apache.flink.runtime.state.AbstractStateBackend;
+import org.apache.flink.runtime.state.StateBackend;
import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
import org.apache.flink.test.util.MiniClusterWithClientResource;
@@ -60,7 +60,7 @@ public class NonHAQueryableStateRocksDBBackendITCase extends AbstractQueryableSt
.build());
@Override
- protected AbstractStateBackend createStateBackend() throws Exception {
+ protected StateBackend createStateBackend() throws Exception {
return new RocksDBStateBackend(temporaryFolder.newFolder().toURI().toString());
}