Repository: flink Updated Branches: refs/heads/release-1.3 6144a5f84 -> fdcdb1698
[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/fdcdb169 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fdcdb169 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fdcdb169 Branch: refs/heads/release-1.3 Commit: fdcdb16985a2d72634067c9a8fc86c9ac4f99e1c Parents: 6144a5f Author: Jark Wu <[email protected]> Authored: Fri Jun 2 21:15:55 2017 +0800 Committer: twalthr <[email protected]> Committed: Tue Jun 6 12:17:53 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/fdcdb169/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/fdcdb169/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/fdcdb169/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/fdcdb169/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/fdcdb169/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/fdcdb169/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/fdcdb169/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,
