You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2019/11/19 06:15:02 UTC
[flink] 13/16: [FLINK-XXXXX] Fix completeness tests
This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a commit to branch executors-clean
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 044645b401f738f8ca345cc968a55d2a1940c3a2
Author: Kostas Kloudas <kk...@gmail.com>
AuthorDate: Tue Nov 19 05:22:51 2019 +0100
[FLINK-XXXXX] Fix completeness tests
---
.../pyflink/dataset/tests/test_execution_environment_completeness.py | 3 ++-
.../flink/streaming/api/environment/StreamExecutionEnvironment.java | 4 ----
.../flink/api/scala/completeness/BatchScalaAPICompletenessTest.scala | 3 +++
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/flink-python/pyflink/dataset/tests/test_execution_environment_completeness.py b/flink-python/pyflink/dataset/tests/test_execution_environment_completeness.py
index a86db7b..7277e4e 100644
--- a/flink-python/pyflink/dataset/tests/test_execution_environment_completeness.py
+++ b/flink-python/pyflink/dataset/tests/test_execution_environment_completeness.py
@@ -49,7 +49,8 @@ class ExecutionEnvironmentCompletenessTests(PythonAPICompletenessTestCase,
'getIdString', 'setSessionTimeout', 'fromElements', 'createRemoteEnvironment',
'startNewSession', 'fromCollection', 'readTextFileWithValue', 'registerDataSink',
'createCollectionsEnvironment', 'readFile', 'readFileOfPrimitives',
- 'generateSequence', 'areExplicitEnvironmentsAllowed', 'createInput'}
+ 'generateSequence', 'areExplicitEnvironmentsAllowed', 'createInput',
+ 'getUserCodeClassLoader', 'getExecutorServiceLoader', 'getConfiguration'}
if __name__ == '__main__':
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
index ea50d04..b8544cf 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -179,10 +179,6 @@ public class StreamExecutionEnvironment {
this.userClassloader = checkNotNull(userClassloader);
}
- public ClassLoader getUserCodeClassLoader() {
- return userClassloader;
- }
-
protected Configuration getConfiguration() {
return this.configuration;
}
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/BatchScalaAPICompletenessTest.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/BatchScalaAPICompletenessTest.scala
index 6dc2ac5..e0666cf 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/BatchScalaAPICompletenessTest.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/BatchScalaAPICompletenessTest.scala
@@ -55,6 +55,9 @@ class BatchScalaAPICompletenessTest extends ScalaAPICompletenessTestBase {
"org.apache.flink.api.java.operators.TwoInputOperator.getInput2Type",
"org.apache.flink.api.java.ExecutionEnvironment.areExplicitEnvironmentsAllowed",
"org.apache.flink.api.java.ExecutionEnvironment.resetContextEnvironment",
+ "org.apache.flink.api.java.ExecutionEnvironment.getUserCodeClassLoader",
+ "org.apache.flink.api.java.ExecutionEnvironment.getExecutorServiceLoader",
+ "org.apache.flink.api.java.ExecutionEnvironment.getConfiguration",
// TypeHints are only needed for Java API, Scala API doesn't need them
"org.apache.flink.api.java.operators.SingleInputUdfOperator.returns",