flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject flink git commit: [hotfix] [table] Change scala.Boolean to java.lang.Boolean in UpsertStreamTableSink interface.
Date Sat, 13 May 2017 21:49:49 GMT
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 <fhueske@apache.org>
Authored: Sat May 13 23:37:21 2017 +0200
Committer: Fabian Hueske <fhueske@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,


Mime
View raw message