You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/08/12 03:31:10 UTC
[flink] branch master updated: [hotfix][python] Remove unused
variables
This is an automated email from the ASF dual-hosted git repository.
dianfu 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 8c4f342 [hotfix][python] Remove unused variables
8c4f342 is described below
commit 8c4f342c9fa190813bc5e83f7e6dfc6a0d6120e8
Author: Dian Fu <di...@apache.org>
AuthorDate: Wed Aug 12 11:27:51 2020 +0800
[hotfix][python] Remove unused variables
---
.../api/runners/python/beam/BeamPythonStatelessFunctionRunner.java | 3 +--
.../runners/python/beam/BeamTablePythonStatelessFunctionRunner.java | 1 -
2 files changed, 1 insertion(+), 3 deletions(-)
diff --git a/flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java b/flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java
index cec677a..f97e26b 100644
--- a/flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java
+++ b/flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java
@@ -50,8 +50,7 @@ import static org.apache.beam.runners.core.construction.BeamUrns.getUrn;
* A {@link BeamPythonFunctionRunner} used to execute Python stateless functions.
*/
@Internal
-public abstract class BeamPythonStatelessFunctionRunner extends BeamPythonFunctionRunner{
- private static final long serialVersionUID = 1L;
+public abstract class BeamPythonStatelessFunctionRunner extends BeamPythonFunctionRunner {
private static final String INPUT_ID = "input";
private static final String OUTPUT_ID = "output";
private static final String TRANSFORM_ID = "transform";
diff --git a/flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/beam/BeamTablePythonStatelessFunctionRunner.java b/flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/beam/BeamTablePythonStatelessFunctionRunner.java
index bcffe82..fc97b16 100644
--- a/flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/beam/BeamTablePythonStatelessFunctionRunner.java
+++ b/flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/beam/BeamTablePythonStatelessFunctionRunner.java
@@ -38,7 +38,6 @@ import java.util.Map;
@Internal
public class BeamTablePythonStatelessFunctionRunner extends BeamPythonStatelessFunctionRunner {
- private static final long serialVersionUID = 1L;
private final RowType inputType;
private final RowType outputType;
private final String coderUrn;