Repository: flink Updated Branches: refs/heads/release-1.3 81d520bbf -> 670b23e97
[hotfix] [table] Change scala.Boolean to java.lang.Boolean in UpsertStreamTableSink interface. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/670b23e9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/670b23e9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/670b23e9 Branch: refs/heads/release-1.3 Commit: 670b23e972895684bf9a0df634f75085ae45ace5 Parents: 81d520b Author: Fabian Hueske <[email protected]> Authored: Sat May 13 23:37:21 2017 +0200 Committer: Fabian Hueske <[email protected]> Committed: Sat May 13 23:47:39 2017 +0200 ---------------------------------------------------------------------- .../scala/org/apache/flink/table/sinks/UpsertStreamTableSink.scala | 2 +- .../org/apache/flink/table/sinks/StreamTableSinksITCase.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/670b23e9/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/UpsertStreamTableSink.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/UpsertStreamTableSink.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/UpsertStreamTableSink.scala index 2ae3406..9c735d0 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/UpsertStreamTableSink.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/UpsertStreamTableSink.scala @@ -67,7 +67,7 @@ trait UpsertStreamTableSink[T] extends TableSink[JTuple2[JBool, T]] { * * @param isAppendOnly true if the table is append-only, false otherwise. */ - def setIsAppendOnly(isAppendOnly: Boolean): Unit + def setIsAppendOnly(isAppendOnly: JBool): Unit /** Returns the requested record type */ def getRecordType: TypeInformation[T] http://git-wip-us.apache.org/repos/asf/flink/blob/670b23e9/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sinks/StreamTableSinksITCase.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sinks/StreamTableSinksITCase.scala b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sinks/StreamTableSinksITCase.scala index 2dfb658..47c55f1 100644 --- a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sinks/StreamTableSinksITCase.scala +++ b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/sinks/StreamTableSinksITCase.scala @@ -462,7 +462,7 @@ private class TestUpsertSink( assertNull("Provided key fields should not be null.", expectedKeys) } - override def setIsAppendOnly(isAppendOnly: Boolean): Unit = + override def setIsAppendOnly(isAppendOnly: JBool): Unit = assertEquals( "Provided isAppendOnly does not match expected isAppendOnly", expectedIsAppendOnly,
