[hotfix] Fix failing Table API test and checkstyle violation

kongxi · Aug 2, 2016 · 31837a7 · 31837a7
1 parent 36c09b0
commit 31837a7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/...braries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala b/...braries/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)
 

diff --git a/...s/flink-table/src/test/java/org/apache/flink/api/java/batch/table/AggregationsITCase.java b/...s/flink-table/src/test/java/org/apache/flink/api/java/batch/table/AggregationsITCase.java
@@ -196,7 +196,7 @@ public void testPojoAggregation() throws Exception {
 
  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)