Repository: flink Updated Branches: refs/heads/master 50c88d5b1 -> b54f44888
[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/b54f4488 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b54f4488 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b54f4488 Branch: refs/heads/master Commit: b54f44888d6e7decb762429a861b1e03073a3774 Parents: 50c88d5 Author: Fabian Hueske <fhue...@apache.org> Authored: Sat May 13 23:37:21 2017 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Sat May 13 23:50:20 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/b54f4488/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/b54f4488/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,
