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 <dwysakow...@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(),