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 2016/08/02 18:08:28 UTC
flink git commit: [hotfix] Fix failing Table API test and checkstyle
violation
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 <tw...@apache.org>
Authored: Tue Aug 2 20:07:20 2016 +0200
Committer: twalthr <tw...@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)