[FLINK-33921][table] Cleanup usage of deprecated IdleStateRetentionTi…

…me related method in org.apache.flink.table.api.TableConfig
liyubin117 · Dec 11, 2024 · 1e22194 · 1e22194
1 parent 0e6dc41
commit 1e22194
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ala/org/apache/flink/table/api/bridge/scala/internal/StreamTableEnvironmentImplTest.scala b/...ala/org/apache/flink/table/api/bridge/scala/internal/StreamTableEnvironmentImplTest.scala
@@ -48,8 +48,8 @@ class StreamTableEnvironmentImplTest {
     val table = tEnv.fromDataStream(elements)
     tEnv.toDataStream(table)
 
-    assertThat(tEnv.getConfig.getMinIdleStateRetentionTime).isEqualTo(retention.toMillis)
-    assertThat(tEnv.getConfig.getMaxIdleStateRetentionTime).isEqualTo(retention.toMillis * 3 / 2)
+    assertThat(tEnv.getConfig.getIdleStateRetention.toMillis).isEqualTo(retention.toMillis)
+    assertThat(tEnv.getConfig.getIdleStateRetention.toMillis * 3 / 2).isEqualTo(retention.toMillis * 3 / 2)
   }
 
   @Test
@@ -63,8 +63,8 @@ class StreamTableEnvironmentImplTest {
     val table = tEnv.fromDataStream(elements)
     tEnv.toRetractStream[Row](table)
 
-    assertThat(tEnv.getConfig.getMinIdleStateRetentionTime).isEqualTo(retention.toMillis)
-    assertThat(tEnv.getConfig.getMaxIdleStateRetentionTime).isEqualTo(retention.toMillis * 3 / 2)
+    assertThat(tEnv.getConfig.getIdleStateRetention.toMillis).isEqualTo(retention.toMillis)
+    assertThat(tEnv.getConfig.getIdleStateRetention.toMillis * 3 / 2).isEqualTo(retention.toMillis * 3 / 2)
   }
 
   private def getStreamTableEnvironment(