You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2019/10/16 13:58:45 UTC

[flink] branch master updated: [FLINK-13008] fix findbugs warning in AggregationsFunction

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 36e9b2d  [FLINK-13008] fix findbugs warning in AggregationsFunction
36e9b2d is described below

commit 36e9b2d8e4b7490e0de5cf35e15471981c4c43b8
Author: wangpeibin <pe...@koubei.com>
AuthorDate: Thu Jun 27 11:31:01 2019 +0800

    [FLINK-13008] fix findbugs warning in AggregationsFunction
---
 .../apache/flink/table/runtime/aggregate/GeneratedAggregations.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/GeneratedAggregations.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/GeneratedAggregations.scala
index b771c5e..f2b506f 100644
--- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/GeneratedAggregations.scala
+++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/GeneratedAggregations.scala
@@ -149,7 +149,7 @@ class SingleElementIterable[T] extends java.lang.Iterable[T] {
       }
     }
 
-    override def remove(): Unit = new java.lang.UnsupportedOperationException
+    override def remove(): Unit = throw new java.lang.UnsupportedOperationException
   }
 
   val it = new SingleElementIterator