Repository: flink Updated Branches: refs/heads/master 36c09b099 -> 31837a757
[hotfix] Fix failing Table API test and checkstyle violation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31837a75 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/31837a75 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/31837a75 Branch: refs/heads/master Commit: 31837a7571dd79795a75d74e3b54245cb720a57c Parents: 36c09b0 Author: twalthr <twal...@apache.org> Authored: Tue Aug 2 20:07:20 2016 +0200 Committer: twalthr <twal...@apache.org> Committed: Tue Aug 2 20:07:20 2016 +0200 ---------------------------------------------------------------------- .../apache/flink/examples/scala/StreamSQLExample.scala | 12 ++++++------ .../flink/api/java/batch/table/AggregationsITCase.java | 2 +- 2 files changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/31837a75/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala index 5e0c773..5b39080 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala @@ -33,9 +33,9 @@ import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironm */ object StreamSQLExample { - // ************************************************************************* - // PROGRAM - // ************************************************************************* + // ************************************************************************* + // PROGRAM + // ************************************************************************* def main(args: Array[String]): Unit = { @@ -67,9 +67,9 @@ object StreamSQLExample { env.execute() } - // ************************************************************************* - // USER DATA TYPES - // ************************************************************************* + // ************************************************************************* + // USER DATA TYPES + // ************************************************************************* case class Order(user: Long, product: String, amount: Int) http://git-wip-us.apache.org/repos/asf/flink/blob/31837a75/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/AggregationsITCase.java ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/AggregationsITCase.java b/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/AggregationsITCase.java index 6df3f65..6bcac56 100644 --- a/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/AggregationsITCase.java +++ b/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/AggregationsITCase.java @@ -196,7 +196,7 @@ public class AggregationsITCase extends MultipleProgramsTestBase { Table filtered = table .groupBy("word") - .select("word.frequency as frequency, word") + .select("word.count as frequency, word") .filter("frequency = 2"); List<String> result = tableEnv.toDataSet(filtered, WC.class)
