You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2018/05/24 06:46:52 UTC
[1/2] flink git commit: [FLINK-9415] [scala,
test] Remove ScalaStreamingMultipleProgramsTestBase
Repository: flink
Updated Branches:
refs/heads/master 5b8396719 -> 6e54f107b
[FLINK-9415] [scala, test] Remove ScalaStreamingMultipleProgramsTestBase
This closes #6058.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e54f107
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6e54f107
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6e54f107
Branch: refs/heads/master
Commit: 6e54f107b51d50008d72cfb9962a4e547dc094da
Parents: ce47571
Author: Thomas Weise <th...@apache.org>
Authored: Wed May 23 15:42:29 2018 -0700
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu May 24 11:06:05 2018 +0800
----------------------------------------------------------------------
...ScalaStreamingMultipleProgramsTestBase.scala | 49 --------------------
.../api/scala/StreamingOperatorsITCase.scala | 6 +--
2 files changed, 3 insertions(+), 52 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6e54f107/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/ScalaStreamingMultipleProgramsTestBase.scala
----------------------------------------------------------------------
diff --git a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/ScalaStreamingMultipleProgramsTestBase.scala b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/ScalaStreamingMultipleProgramsTestBase.scala
deleted file mode 100644
index e0c5b45..0000000
--- a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/ScalaStreamingMultipleProgramsTestBase.scala
+++ /dev/null
@@ -1,49 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.streaming.api.scala
-
-import org.apache.flink.configuration.Configuration
-import org.apache.flink.test.util.MiniClusterResource.MiniClusterResourceConfiguration
-import org.apache.flink.test.util.{MiniClusterResource, TestBaseUtils}
-import org.junit.{After, Before}
-import org.scalatest.junit.JUnitSuiteLike
-
-trait ScalaStreamingMultipleProgramsTestBase
- extends TestBaseUtils
- with JUnitSuiteLike {
-
- val parallelism = 4
- var cluster: Option[MiniClusterResource] = None
-
- @Before
- def beforeAll(): Unit = {
- val cl = new MiniClusterResource(
- new MiniClusterResourceConfiguration(new Configuration(), 1, parallelism)
- )
-
- cl.before()
-
- cluster = Some(cl)
- }
-
- @After
- def afterAll(): Unit = {
- cluster.foreach { c => c.after() }
- }
-}
http://git-wip-us.apache.org/repos/asf/flink/blob/6e54f107/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/StreamingOperatorsITCase.scala
----------------------------------------------------------------------
diff --git a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/StreamingOperatorsITCase.scala b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/StreamingOperatorsITCase.scala
index 4d690c8..334633a 100644
--- a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/StreamingOperatorsITCase.scala
+++ b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/StreamingOperatorsITCase.scala
@@ -18,16 +18,16 @@
package org.apache.flink.streaming.api.scala
-import org.apache.flink.api.common.functions.{RichMapFunction, FoldFunction}
+import org.apache.flink.api.common.functions.{FoldFunction, RichMapFunction}
import org.apache.flink.core.fs.FileSystem
import org.apache.flink.streaming.api.functions.source.SourceFunction
import org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
-import org.apache.flink.test.util.TestBaseUtils
+import org.apache.flink.test.util.{AbstractTestBase, TestBaseUtils}
import org.apache.flink.util.MathUtils
import org.junit.rules.TemporaryFolder
import org.junit.{After, Before, Rule, Test}
-class StreamingOperatorsITCase extends ScalaStreamingMultipleProgramsTestBase {
+class StreamingOperatorsITCase extends AbstractTestBase {
var resultPath1: String = _
var resultPath2: String = _
[2/2] flink git commit: [FLINK-9415] Remove reference to
StreamingMultipleProgramsTestBase in docs
Posted by tz...@apache.org.
[FLINK-9415] Remove reference to StreamingMultipleProgramsTestBase in docs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ce47571a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ce47571a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ce47571a
Branch: refs/heads/master
Commit: ce47571a647ca97781faa43ac1364c7a02adaf1a
Parents: 5b83967
Author: Thomas Weise <th...@apache.org>
Authored: Tue May 22 19:15:57 2018 -0700
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu May 24 11:06:05 2018 +0800
----------------------------------------------------------------------
docs/dev/stream/testing.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ce47571a/docs/dev/stream/testing.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/testing.md b/docs/dev/stream/testing.md
index 0a43d31..7676b19 100644
--- a/docs/dev/stream/testing.md
+++ b/docs/dev/stream/testing.md
@@ -140,7 +140,7 @@ You could write the following integration test:
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-public class ExampleIntegrationTest extends StreamingMultipleProgramsTestBase {
+public class ExampleIntegrationTest extends AbstractTestBase {
@Test
public void testMultiply() throws Exception {
@@ -181,7 +181,7 @@ public class ExampleIntegrationTest extends StreamingMultipleProgramsTestBase {
<div data-lang="scala" markdown="1">
{% highlight scala %}
-class ExampleIntegrationTest extends StreamingMultipleProgramsTestBase {
+class ExampleIntegrationTest extends AbstractTestBase {
@Test
def testMultiply(): Unit = {