You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/05/13 21:49:49 UTC
flink git commit: [hotfix] [table] Change scala.Boolean to
java.lang.Boolean in UpsertStreamTableSink interface.
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 <fh...@apache.org>
Authored: Sat May 13 23:37:21 2017 +0200
Committer: Fabian Hueske <fh...@apache.org>
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,