[
https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264363#comment-15264363
]
ASF GitHub Bot commented on FLINK-3821:
---------------------------------------
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1938#discussion_r61614176
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java ---
@@ -104,7 +104,10 @@ public void open(Configuration parameters) throws
Exception {
@Override
public
List<Tuple2<Integer, Long>>
initializeBroadcastVariable(Iterable<Tuple2<Integer, Long>> data) {
// sort the
list by task id to calculate the correct offset
-
List<Tuple2<Integer, Long>> sortedData = Lists.newArrayList(data);
+
List<Tuple2<Integer, Long>> sortedData = new ArrayList();
--- End diff --
Add the diamond operator to ArrayList?
> Reduce Guava usage in flink-java
> --------------------------------
>
> Key: FLINK-3821
> URL: https://issues.apache.org/jira/browse/FLINK-3821
> Project: Flink
> Issue Type: Improvement
> Components: Java API
> Affects Versions: 1.0.0
> Reporter: Chesnay Schepler
> Assignee: Chesnay Schepler
> Priority: Trivial
> Fix For: 1.1.0
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
