[
https://issues.apache.org/jira/browse/FLINK-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16091642#comment-16091642
]
ASF GitHub Bot commented on FLINK-7181:
---------------------------------------
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4342#discussion_r127988555
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupRawOperator.java
---
@@ -95,9 +96,8 @@ public CoGroupRawOperator(DataSet<I1> input1, DataSet<I2>
input2,
int[] logicalKeyPositions1 =
keys1.computeLogicalKeyPositions();
int[] logicalKeyPositions2 =
keys2.computeLogicalKeyPositions();
- CoGroupRawOperatorBase<I1, I2, OUT, CoGroupFunction<I1,
I2, OUT>> po
- = new CoGroupRawOperatorBase<I1, I2,
OUT, CoGroupFunction<I1, I2, OUT>>(
- function, new
BinaryOperatorInformation<I1, I2, OUT>(getInput1Type(), getInput2Type(),
+ CoGroupRawOperatorBase<I1, I2, OUT, CoGroupFunction<I1,
I2, OUT>> po = new CoGroupRawOperatorBase<I1, I2, OUT, CoGroupFunction<I1, I2,
OUT>>(
--- End diff --
now this line is a bit too long (even if the caret shortcut `<>` was used)
> Activate checkstyle flink-java/operators/*
> ------------------------------------------
>
> Key: FLINK-7181
> URL: https://issues.apache.org/jira/browse/FLINK-7181
> Project: Flink
> Issue Type: Improvement
> Components: Java API
> Reporter: Dawid Wysakowicz
> Assignee: Dawid Wysakowicz
> Priority: Trivial
>
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
