You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2017/06/06 10:16:43 UTC
flink git commit: [FLINK-6816] [table] Fix wrong usage of Scala
string interpolation in Table API
Repository: flink
Updated Branches:
refs/heads/master d42225f1d -> 762141e55
[FLINK-6816] [table] Fix wrong usage of Scala string interpolation in Table API
This closes #4050.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/762141e5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/762141e5
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/762141e5
Branch: refs/heads/master
Commit: 762141e55639e76d5aa9940d00975601817b6197
Parents: d42225f
Author: Jark Wu <wu...@alibaba-inc.com>
Authored: Fri Jun 2 21:15:55 2017 +0800
Committer: twalthr <tw...@apache.org>
Committed: Tue Jun 6 12:16:06 2017 +0200
----------------------------------------------------------------------
.../flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala | 4 ++--
.../flink/table/runtime/aggregate/ProcTimeBoundedRowsOver.scala | 4 ++--
.../runtime/aggregate/ProcTimeUnboundedNonPartitionedOver.scala | 4 ++--
.../runtime/aggregate/ProcTimeUnboundedPartitionedOver.scala | 4 ++--
.../flink/table/runtime/aggregate/RowTimeBoundedRangeOver.scala | 4 ++--
.../flink/table/runtime/aggregate/RowTimeBoundedRowsOver.scala | 4 ++--
.../flink/table/runtime/aggregate/RowTimeUnboundedOver.scala | 4 ++--
7 files changed, 14 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/762141e5/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
index d50912c..8f2ec98 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
@@ -62,8 +62,8 @@ class ProcTimeBoundedRangeOver(
private var function: GeneratedAggregations = _
override def open(config: Configuration) {
- LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
- s"Code:\n$genAggregations.code")
+ LOG.debug(s"Compiling AggregateHelper: ${genAggregations.name} \n\n" +
+ s"Code:\n${genAggregations.code}")
val clazz = compile(
getRuntimeContext.getUserCodeClassLoader,
genAggregations.name,
http://git-wip-us.apache.org/repos/asf/flink/blob/762141e5/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRowsOver.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRowsOver.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRowsOver.scala
index e388c93..ccc4b46 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRowsOver.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRowsOver.scala
@@ -67,8 +67,8 @@ class ProcTimeBoundedRowsOver(
private var function: GeneratedAggregations = _
override def open(config: Configuration) {
- LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
- s"Code:\n$genAggregations.code")
+ LOG.debug(s"Compiling AggregateHelper: ${genAggregations.name} \n\n" +
+ s"Code:\n${genAggregations.code}")
val clazz = compile(
getRuntimeContext.getUserCodeClassLoader,
genAggregations.name,
http://git-wip-us.apache.org/repos/asf/flink/blob/762141e5/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedNonPartitionedOver.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedNonPartitionedOver.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedNonPartitionedOver.scala
index 2a6c9c8..f86bed2 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedNonPartitionedOver.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedNonPartitionedOver.scala
@@ -52,8 +52,8 @@ class ProcTimeUnboundedNonPartitionedOver(
private var function: GeneratedAggregations = _
override def open(config: Configuration) {
- LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
- s"Code:\n$genAggregations.code")
+ LOG.debug(s"Compiling AggregateHelper: ${genAggregations.name} \n\n" +
+ s"Code:\n${genAggregations.code}")
val clazz = compile(
getRuntimeContext.getUserCodeClassLoader,
genAggregations.name,
http://git-wip-us.apache.org/repos/asf/flink/blob/762141e5/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedPartitionedOver.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedPartitionedOver.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedPartitionedOver.scala
index 97f0ad7..ad43d94 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedPartitionedOver.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedPartitionedOver.scala
@@ -48,8 +48,8 @@ class ProcTimeUnboundedPartitionedOver(
private var function: GeneratedAggregations = _
override def open(config: Configuration) {
- LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
- s"Code:\n$genAggregations.code")
+ LOG.debug(s"Compiling AggregateHelper: ${genAggregations.name} \n\n" +
+ s"Code:\n${genAggregations.code}")
val clazz = compile(
getRuntimeContext.getUserCodeClassLoader,
genAggregations.name,
http://git-wip-us.apache.org/repos/asf/flink/blob/762141e5/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRangeOver.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRangeOver.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRangeOver.scala
index 65edf6d..1a207bb 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRangeOver.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRangeOver.scala
@@ -68,8 +68,8 @@ class RowTimeBoundedRangeOver(
private var function: GeneratedAggregations = _
override def open(config: Configuration) {
- LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
- s"Code:\n$genAggregations.code")
+ LOG.debug(s"Compiling AggregateHelper: ${genAggregations.name} \n\n" +
+ s"Code:\n${genAggregations.code}")
val clazz = compile(
getRuntimeContext.getUserCodeClassLoader,
genAggregations.name,
http://git-wip-us.apache.org/repos/asf/flink/blob/762141e5/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRowsOver.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRowsOver.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRowsOver.scala
index 395ae39..a4b1076 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRowsOver.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeBoundedRowsOver.scala
@@ -73,8 +73,8 @@ class RowTimeBoundedRowsOver(
private var function: GeneratedAggregations = _
override def open(config: Configuration) {
- LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
- s"Code:\n$genAggregations.code")
+ LOG.debug(s"Compiling AggregateHelper: ${genAggregations.name} \n\n" +
+ s"Code:\n${genAggregations.code}")
val clazz = compile(
getRuntimeContext.getUserCodeClassLoader,
genAggregations.name,
http://git-wip-us.apache.org/repos/asf/flink/blob/762141e5/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala
index 741d2b4..f38ba93 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala
@@ -61,8 +61,8 @@ abstract class RowTimeUnboundedOver(
protected var function: GeneratedAggregations = _
override def open(config: Configuration) {
- LOG.debug(s"Compiling AggregateHelper: $genAggregations.name \n\n " +
- s"Code:\n$genAggregations.code")
+ LOG.debug(s"Compiling AggregateHelper: ${genAggregations.name} \n\n" +
+ s"Code:\n${genAggregations.code}")
val clazz = compile(
getRuntimeContext.getUserCodeClassLoader,
genAggregations.name,