diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java index 1aad5de62aa68..2640951b0c214 100644 --- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java +++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java @@ -18,14 +18,13 @@ package org.apache.flink.table.runtime.operators.rank; +import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalCause; +import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalListener; +import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalNotification; import org.apache.flink.streaming.api.operators.KeyContext; import org.apache.flink.table.data.RowData; import org.apache.flink.util.function.ThrowingConsumer; -import org.apache.flink.shaded.guava31.com.google.common.cache.RemovalCause; -import org.apache.flink.shaded.guava31.com.google.common.cache.RemovalListener; -import org.apache.flink.shaded.guava31.com.google.common.cache.RemovalNotification; - /** * A common cache removal listener for rank node. *