You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/07/18 19:11:22 UTC
[flink] branch release-1.9 updated:
[FLINK-13327][table-planner-blink] Fixed scala 2.12 compilation
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 0faa667 [FLINK-13327][table-planner-blink] Fixed scala 2.12 compilation
0faa667 is described below
commit 0faa66747775bd75cc2f55c4d6b00560a8c41c05
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Thu Jul 18 18:26:59 2019 +0200
[FLINK-13327][table-planner-blink] Fixed scala 2.12 compilation
---
.../apache/flink/table/plan/nodes/resource/ExecNodeResourceTest.scala | 2 +-
.../src/test/scala/org/apache/flink/table/util/TableTestBase.scala | 2 +-
.../src/test/scala/org/apache/flink/table/util/testTableSources.scala | 4 ++--
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plan/nodes/resource/ExecNodeResourceTest.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plan/nodes/resource/ExecNodeResourceTest.scala
index 5b1d050..3d0d4d7 100644
--- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plan/nodes/resource/ExecNodeResourceTest.scala
+++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plan/nodes/resource/ExecNodeResourceTest.scala
@@ -180,7 +180,7 @@ object ExecNodeResourceTest {
/**
* Batch/Stream [[org.apache.flink.table.sources.TableSource]] for resource testing.
*/
-class MockTableSource(val isBounded: Boolean, schema: TableSchema)
+class MockTableSource(override val isBounded: Boolean, schema: TableSchema)
extends StreamTableSource[BaseRow] {
override def getDataStream(
diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/TableTestBase.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/TableTestBase.scala
index 7a26fb6..28dacb7 100644
--- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/TableTestBase.scala
+++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/TableTestBase.scala
@@ -849,7 +849,7 @@ case class JavaBatchTableTestUtil(test: TableTestBase) extends JavaTableTestUtil
/**
* Batch/Stream [[org.apache.flink.table.sources.TableSource]] for testing.
*/
-class TestTableSource(val isBounded: Boolean, schema: TableSchema)
+class TestTableSource(override val isBounded: Boolean, schema: TableSchema)
extends StreamTableSource[Row] {
override def getDataStream(execEnv: environment.StreamExecutionEnvironment): DataStream[Row] = {
diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/testTableSources.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/testTableSources.scala
index f51b1e2..fa73905 100644
--- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/testTableSources.scala
+++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/testTableSources.scala
@@ -132,7 +132,7 @@ object TestTableSources {
}
class TestTableSourceWithTime[T](
- val isBounded: Boolean,
+ override val isBounded: Boolean,
tableSchema: TableSchema,
returnType: TypeInformation[T],
values: Seq[T],
@@ -342,7 +342,7 @@ class TestNestedProjectableTableSource(
* @param filterPushedDown Whether predicates have been pushed down yet.
*/
class TestFilterableTableSource(
- val isBounded: Boolean,
+ override val isBounded: Boolean,
rowTypeInfo: RowTypeInfo,
data: Seq[Row],
filterableFields: Set[String] = Set(),