This is an automated email from the ASF dual-hosted git repository. bertty pushed a commit to branch pull_135 in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit ae623f2ef3dd132c6fdd1ea41903d35fd4a3d4b6 Author: Bertty Contreras-Rojas <[email protected]> AuthorDate: Mon Apr 4 11:30:41 2022 +0200 [WAYANG-134] small corrections Signed-off-by: bertty <[email protected]> --- .../wayang/flink/operators/FlinkOperatorTestBase.java | 5 ++--- wayang-platforms/wayang-flink/src/main/scala/README.md | 16 ++++++++++++++++ 2 files changed, 18 insertions(+), 3 deletions(-) diff --git a/wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkOperatorTestBase.java b/wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkOperatorTestBase.java index c835961a..ed3adbb0 100644 --- a/wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkOperatorTestBase.java +++ b/wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkOperatorTestBase.java @@ -33,7 +33,6 @@ import org.apache.wayang.flink.execution.FlinkExecutor; import org.apache.wayang.flink.platform.FlinkPlatform; import org.apache.wayang.flink.test.ChannelFactory; import org.apache.wayang.java.channels.CollectionChannel; -import org.apache.wayang.flink.operators.FlinkExecutionOperator; import java.util.Collection; @@ -66,9 +65,9 @@ public class FlinkOperatorTestBase { } - protected void evaluate(FlinkExecutor operator, + protected void evaluate(FlinkExecutionOperator operator, ChannelInstance[] inputs, - ChannelInstance[] outputs) { + ChannelInstance[] outputs) throws Exception { operator.evaluate(inputs, outputs, this.flinkExecutor, this.createOperatorContext(operator)); } diff --git a/wayang-platforms/wayang-flink/src/main/scala/README.md b/wayang-platforms/wayang-flink/src/main/scala/README.md new file mode 100644 index 00000000..61bee772 --- /dev/null +++ b/wayang-platforms/wayang-flink/src/main/scala/README.md @@ -0,0 +1,16 @@ +[comment]: # (Licensed to the Apache Software Foundation (ASF) under one or more) +[comment]: # (contributor license agreements. See the NOTICE file distributed with) +[comment]: # (this work for additional information regarding copyright ownership.) +[comment]: # (The ASF licenses this file to You under the Apache License, Version 2.0) +[comment]: # ((the "License"); you may not use this file except in compliance with) +[comment]: # (the License. You may obtain a copy of the License at) +[comment]: # () +[comment]: # (http://www.apache.org/licenses/LICENSE-2.0) +[comment]: # () +[comment]: # (Unless required by applicable law or agreed to in writing, software) +[comment]: # (distributed under the License is distributed on an "AS IS" BASIS,) +[comment]: # (WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.) +[comment]: # (See the License for the specific language governing permissions and) +[comment]: # (limitations under the License.) + +In this folder it was created to avoid error in the parameters of the variables
