[FLINK-20968][table-planner-blink] Rename ExecNode#getDesc to ExecNod…

…e#getDescription This closes apache#14733
zobar · Jan 26, 2021 · e6e9c7a · e6e9c7a
1 parent 5ed569f
commit e6e9c7a
Show file tree

Hide file tree

Showing 52 changed files with 56 additions and 59 deletions.
diff --git a/...-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNode.java b/...-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNode.java
@@ -35,12 +35,8 @@
  */
 public interface ExecNode<T> {
 
-    /**
-     * Returns a string which describes this node. TODO rename to `getDescription` once all
-     * ExecNodes do not extend from FlinkPhysicalRel, because RelNode already has `getDescription`
-     * method.
-     */
-    String getDesc();
+    /** Returns a string which describes this node. */
+    String getDescription();
 
     /**
      * Returns the output {@link LogicalType} of this node, this type should be consistent with the

diff --git a/...nner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeBase.java b/...nner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeBase.java
@@ -54,7 +54,7 @@ protected ExecNodeBase(List<ExecEdge> inputEdges, LogicalType outputType, String
     }
 
     @Override
-    public String getDesc() {
+    public String getDescription() {
         return description;
     }
 

diff --git a/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecExchange.java b/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecExchange.java
@@ -65,7 +65,7 @@ public void setRequiredShuffleMode(@Nullable ShuffleMode requiredShuffleMode) {
     }
 
     @Override
-    public String getDesc() {
+    public String getDescription() {
         // make sure the description be consistent with before, update this once plan is stable
         ExecEdge.RequiredShuffle requiredShuffle = getInputEdges().get(0).getRequiredShuffle();
         StringBuilder sb = new StringBuilder();

diff --git a/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashAggregate.java b/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashAggregate.java
@@ -128,7 +128,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
 
         return ExecNodeUtil.createOneInputTransformation(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 new CodeGenOperatorFactory<>(generatedOperator),
                 InternalTypeInfo.of(outputRowType),
                 inputTransform.getParallelism(),

diff --git a/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashJoin.java b/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashJoin.java
@@ -211,7 +211,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
                 ExecNodeUtil.createTwoInputTransformation(
                         buildTransform,
                         probeTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         probeTransform.getParallelism(),

diff --git a/...va/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashWindowAggregate.java b/...va/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashWindowAggregate.java
@@ -142,7 +142,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
                         .getBytes();
         return ExecNodeUtil.createOneInputTransformation(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 new CodeGenOperatorFactory<>(generatedOperator),
                 InternalTypeInfo.of(getOutputType()),
                 inputTransform.getParallelism(),

diff --git a/...nk/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecLimit.java b/...nk/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecLimit.java
@@ -60,7 +60,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         Transformation<RowData> transformation =
                 ExecNodeUtil.createOneInputTransformation(
                         input,
-                        getDesc(),
+                        getDescription(),
                         SimpleOperatorFactory.of(operator),
                         input.getOutputType(),
                         input.getParallelism(),

diff --git a/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMultipleInput.java b/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMultipleInput.java
@@ -95,7 +95,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
 
         final MultipleInputTransformation<RowData> multipleInputTransform =
                 new MultipleInputTransformation<>(
-                        getDesc(),
+                        getDescription(),
                         new BatchMultipleInputStreamOperatorFactory(
                                 inputTransformAndInputSpecPairs.stream()
                                         .map(Pair::getValue)

diff --git a/...in/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecNestedLoopJoin.java b/...in/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecNestedLoopJoin.java
@@ -108,7 +108,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
                 ExecNodeUtil.createTwoInputTransformation(
                         leftInputTransform,
                         rightInputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         parallelism,

diff --git a/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecOverAggregate.java b/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecOverAggregate.java
@@ -160,7 +160,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         }
         return ExecNodeUtil.createOneInputTransformation(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 SimpleOperatorFactory.of(operator),
                 InternalTypeInfo.of(getOutputType()),
                 inputTransform.getParallelism(),

diff --git a/...a/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonGroupAggregate.java b/...a/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonGroupAggregate.java
@@ -104,7 +104,7 @@ private OneInputTransformation<RowData, RowData> createPythonOneInputTransformat
                         pythonFunctionInfos);
         return new OneInputTransformation(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 pythonOperator,
                 InternalTypeInfo.of(outputRowType),
                 inputTransform.getParallelism());

diff --git a/...apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonGroupWindowAggregate.java b/...apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonGroupWindowAggregate.java
@@ -156,7 +156,7 @@ private OneInputTransformation<RowData, RowData> createPythonOneInputTransformat
                         pythonFunctionInfos);
         return new OneInputTransformation<>(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 pythonOperator,
                 InternalTypeInfo.of(outputRowType),
                 inputTransform.getParallelism());

diff --git a/...va/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonOverAggregate.java b/...va/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecPythonOverAggregate.java
@@ -165,7 +165,7 @@ private OneInputTransformation<RowData, RowData> createPythonOneInputTransformat
                         pythonFunctionInfos);
         return new OneInputTransformation<>(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 pythonOperator,
                 InternalTypeInfo.of(outputRowType),
                 inputTransform.getParallelism());

diff --git a/...ink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecRank.java b/...ink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecRank.java
@@ -95,7 +95,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         SimpleOperatorFactory.of(operator),
                         InternalTypeInfo.of((RowType) getOutputType()),
                         inputTransform.getParallelism());

diff --git a/...ink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSort.java b/...ink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSort.java
@@ -73,7 +73,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         OneInputTransformation<RowData, RowData> transform =
                 ExecNodeUtil.createOneInputTransformation(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         SimpleOperatorFactory.of(operator),
                         InternalTypeInfo.of((RowType) getOutputType()),
                         inputTransform.getParallelism(),

diff --git a/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortAggregate.java b/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortAggregate.java
@@ -117,7 +117,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
 
         return new OneInputTransformation<>(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 new CodeGenOperatorFactory<>(generatedOperator),
                 InternalTypeInfo.of(outputRowType),
                 inputTransform.getParallelism());

diff --git a/...rc/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortLimit.java b/...rc/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortLimit.java
@@ -86,7 +86,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         SimpleOperatorFactory.of(operator),
                         InternalTypeInfo.of(inputType),
                         inputTransform.getParallelism());

diff --git a/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortMergeJoin.java b/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortMergeJoin.java
@@ -155,7 +155,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
                 ExecNodeUtil.createTwoInputTransformation(
                         leftInputTransform,
                         rightInputTransform,
-                        getDesc(),
+                        getDescription(),
                         SimpleOperatorFactory.of(operator),
                         InternalTypeInfo.of(getOutputType()),
                         rightInputTransform.getParallelism(),

diff --git a/...va/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortWindowAggregate.java b/...va/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortWindowAggregate.java
@@ -142,7 +142,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
 
         return new OneInputTransformation<>(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 new CodeGenOperatorFactory<>(generatedOperator),
                 InternalTypeInfo.of(getOutputType()),
                 inputTransform.getParallelism());

diff --git a/...k/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecCalc.java b/...k/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecCalc.java
@@ -85,7 +85,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final Transformation<RowData> transformation =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         substituteStreamOperator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/.../main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecCorrelate.java b/.../main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecCorrelate.java
@@ -84,7 +84,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
                         inputTransform.getParallelism(),
                         retainHeader,
                         getClass().getSimpleName(),
-                        getDesc());
+                        getDescription());
 
         if (inputsContainSingleton()) {
             transform.setParallelism(1);

diff --git a/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecExpand.java b/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecExpand.java
@@ -71,7 +71,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final Transformation<RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operatorFactory,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/...main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java b/...main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java
@@ -208,7 +208,7 @@ public Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransformation,
-                        getDesc(),
+                        getDescription(),
                         operatorFactory,
                         InternalTypeInfo.of(resultRowType),
                         inputTransformation.getParallelism());

diff --git a/...main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecPythonCalc.java b/...main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecPythonCalc.java
@@ -79,7 +79,8 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final Configuration config =
                 CommonPythonUtil.getMergedConfig(planner.getExecEnv(), planner.getTableConfig());
         OneInputTransformation<RowData, RowData> ret =
-                createPythonOneInputTransformation(inputTransform, calcProgram, getDesc(), config);
+                createPythonOneInputTransformation(
+                        inputTransform, calcProgram, getDescription(), config);
         if (inputsContainSingleton()) {
             ret.setParallelism(1);
             ret.setMaxParallelism(1);

diff --git a/...java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecPythonCorrelate.java b/...java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecPythonCorrelate.java
@@ -105,7 +105,7 @@ private OneInputTransformation<RowData, RowData> createPythonOneInputTransformat
                         pythonUdtfInputOffsets);
         return new OneInputTransformation<>(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 pythonOperator,
                 pythonOperatorOutputRowType,
                 inputTransform.getParallelism());

diff --git a/...k/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java b/...k/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java
@@ -194,7 +194,7 @@ protected Transformation<Object> createSinkTransformation(
             }
             return new LegacySinkTransformation<>(
                     finalInputTransform,
-                    getDesc(),
+                    getDescription(),
                     SimpleOperatorFactory.of(operator),
                     parallelism);
         }

diff --git a/...java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java b/...java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java
@@ -55,7 +55,7 @@ protected CommonExecTableSourceScan(
     @Override
     protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final StreamExecutionEnvironment env = planner.getExecEnv();
-        final String operatorName = getDesc();
+        final String operatorName = getDescription();
         InternalTypeInfo<RowData> outputTypeInfo = InternalTypeInfo.of((RowType) getOutputType());
         ScanTableSource.ScanRuntimeProvider provider =
                 tableSource.getScanRuntimeProvider(ScanRuntimeProviderContext.INSTANCE);

diff --git a/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecValues.java b/...src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecValues.java
@@ -53,7 +53,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
                 planner.getExecEnv()
                         .createInput(inputFormat, inputFormat.getProducedType())
                         .getTransformation();
-        transformation.setName(getDesc());
+        transformation.setName(getDescription());
         transformation.setParallelism(1);
         transformation.setMaxParallelism(1);
         return transformation;

diff --git a/...a/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecChangelogNormalize.java b/...a/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecChangelogNormalize.java
@@ -107,7 +107,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         rowTypeInfo,
                         inputTransform.getParallelism());

diff --git a/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDeduplicate.java b/...ain/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDeduplicate.java
@@ -128,7 +128,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         rowTypeInfo,
                         inputTransform.getParallelism());

diff --git a/...ava/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDropUpdateBefore.java b/...ava/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDropUpdateBefore.java
@@ -52,7 +52,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
 
         return new OneInputTransformation<>(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 operator,
                 inputTransform.getOutputType(),
                 inputTransform.getParallelism());

diff --git a/...org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGlobalGroupAggregate.java b/...org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGlobalGroupAggregate.java
@@ -181,7 +181,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/.../java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupAggregate.java b/.../java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupAggregate.java
@@ -181,7 +181,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/...org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupWindowAggregate.java b/...org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupWindowAggregate.java
@@ -193,7 +193,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/...pache/flink/table/planner/plan/nodes/exec/stream/StreamExecIncrementalGroupAggregate.java b/...pache/flink/table/planner/plan/nodes/exec/stream/StreamExecIncrementalGroupAggregate.java
@@ -149,7 +149,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/...in/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecIntervalJoin.java b/...in/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecIntervalJoin.java
@@ -317,7 +317,7 @@ private TwoInputTransformation<RowData, RowData, RowData> createProcTimeJoin(
         return new TwoInputTransformation<>(
                 leftInputTransform,
                 rightInputTransform,
-                getDesc(),
+                getDescription(),
                 new KeyedCoProcessOperator<>(procJoinFunc),
                 returnTypeInfo,
                 leftInputTransform.getParallelism());
@@ -350,7 +350,7 @@ private TwoInputTransformation<RowData, RowData, RowData> createRowTimeJoin(
         return new TwoInputTransformation<>(
                 leftInputTransform,
                 rightInputTransform,
-                getDesc(),
+                getDescription(),
                 new KeyedCoProcessOperatorWithWatermarkDelay<>(
                         rowJoinFunc, rowJoinFunc.getMaxOutputDelay()),
                 returnTypeInfo,

diff --git a/...k/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecJoin.java b/...k/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecJoin.java
@@ -136,7 +136,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
                 new TwoInputTransformation<>(
                         leftTransform,
                         rightTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(returnType),
                         leftTransform.getParallelism());

diff --git a/.../org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLocalGroupAggregate.java b/.../org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLocalGroupAggregate.java
@@ -114,7 +114,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/.../src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMatch.java b/.../src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMatch.java
@@ -161,7 +161,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         final OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         timestampedInputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         timestampedInputTransform.getParallelism());

diff --git a/...va/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java b/...va/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java
@@ -80,7 +80,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
 
         return new OneInputTransformation<>(
                 inputTransform,
-                getDesc(),
+                getDescription(),
                 operator,
                 InternalTypeInfo.of(getOutputType()),
                 inputTransform.getParallelism());

diff --git a/...n/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecOverAggregate.java b/...n/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecOverAggregate.java
@@ -190,7 +190,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         OneInputTransformation<RowData, RowData> transform =
                 new OneInputTransformation<>(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());

diff --git a/...org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecPythonGroupAggregate.java b/...org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecPythonGroupAggregate.java
@@ -128,7 +128,7 @@ protected Transformation<RowData> translateToPlanInternal(PlannerBase planner) {
         OneInputTransformation transform =
                 new OneInputTransformation(
                         inputTransform,
-                        getDesc(),
+                        getDescription(),
                         operator,
                         InternalTypeInfo.of(getOutputType()),
                         inputTransform.getParallelism());