diff --git a/wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkJoinOperatorTest.java b/wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkJoinOperatorTest.java index 8275e092c..8a21c695d 100644 --- a/wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkJoinOperatorTest.java +++ b/wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkJoinOperatorTest.java @@ -36,11 +36,7 @@ */ class FlinkJoinOperatorTest extends FlinkOperatorTestBase { - //TODO: Validate FlinkJoinOperator implementation - // it is required to validate the implementation of FlinkJoinOperator - // because trigger an exception in the test and looks like is a problem in the - // implementation of the implementation in the operator - // labels:flink,bug + @Test void testExecution() throws Exception { // Prepare test data.