Skip to content

Commit cdab228

Browse files
committedMar 8, 2025
[FLINK-37431]We should use guava Lists instead of curator shade Lists to avoid unnecessary error
1 parent 45fcd56 commit cdab228

File tree

7 files changed

+8
-12
lines changed

7 files changed

+8
-12
lines changed
 

‎flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecIntervalJoin.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@
5757
import org.apache.flink.table.types.logical.RowType;
5858
import org.apache.flink.util.Preconditions;
5959

60-
import org.apache.flink.shaded.guava33.com.google.common.collect.Lists;
60+
import com.google.common.collect.Lists;
6161
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonCreator;
6262
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonProperty;
6363

‎flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecJoin.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@
5151
import org.apache.flink.table.runtime.typeutils.InternalTypeInfo;
5252
import org.apache.flink.table.types.logical.RowType;
5353

54-
import org.apache.flink.shaded.guava33.com.google.common.collect.Lists;
54+
import com.google.common.collect.Lists;
5555
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonCreator;
5656
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonInclude;
5757
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonProperty;

‎flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecWindowJoin.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@
4949
import org.apache.flink.table.runtime.util.TimeWindowUtil;
5050
import org.apache.flink.table.types.logical.RowType;
5151

52-
import org.apache.flink.shaded.guava33.com.google.common.collect.Lists;
52+
import com.google.common.collect.Lists;
5353
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonCreator;
5454
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonProperty;
5555

‎flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/EventTimeTemporalJoinRewriteRule.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,7 @@
2828
import org.apache.flink.table.planner.plan.schema.TimeIndicatorRelDataType;
2929
import org.apache.flink.table.planner.plan.utils.TemporalTableJoinUtil;
3030

31-
import org.apache.flink.shaded.curator5.org.apache.curator.shaded.com.google.common.collect.Lists;
32-
31+
import com.google.common.collect.Lists;
3332
import org.apache.calcite.plan.RelOptRule;
3433
import org.apache.calcite.plan.RelOptRuleCall;
3534
import org.apache.calcite.plan.RelRule;

‎flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/JoinDeriveNullFilterRule.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,7 @@
2020

2121
import org.apache.flink.table.planner.plan.metadata.FlinkRelMetadataQuery;
2222

23-
import org.apache.flink.shaded.curator5.org.apache.curator.shaded.com.google.common.collect.Lists;
24-
23+
import com.google.common.collect.Lists;
2524
import org.apache.calcite.plan.RelOptRuleCall;
2625
import org.apache.calcite.plan.RelRule;
2726
import org.apache.calcite.rel.RelNode;

‎flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowPropertiesRules.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -30,9 +30,8 @@
3030
import org.apache.flink.table.runtime.groupwindow.WindowEnd;
3131
import org.apache.flink.table.runtime.groupwindow.WindowStart;
3232

33-
import org.apache.flink.shaded.guava33.com.google.common.collect.Iterables;
34-
import org.apache.flink.shaded.guava33.com.google.common.collect.Lists;
35-
33+
import com.google.common.collect.Iterables;
34+
import com.google.common.collect.Lists;
3635
import org.apache.calcite.plan.RelOptRuleCall;
3736
import org.apache.calcite.plan.RelRule;
3837
import org.apache.calcite.rel.RelNode;

‎flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/batch/JoinHintTestBase.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,7 @@
3131
import org.apache.flink.table.planner.utils.PlanKind;
3232
import org.apache.flink.table.planner.utils.TableTestBase;
3333

34-
import org.apache.flink.shaded.curator5.org.apache.curator.shaded.com.google.common.collect.Lists;
35-
34+
import com.google.common.collect.Lists;
3635
import org.apache.calcite.rel.RelNode;
3736
import org.apache.calcite.sql.SqlExplainLevel;
3837
import org.apache.logging.log4j.util.Strings;

0 commit comments

Comments
 (0)
Please sign in to comment.