[FLINK-33921][table] Cleanup deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

This closes #23980

Author: liyubin117

flink-python/pyflink/table/table_config.py

@@ -226,36 +226,6 @@ def set_idle_state_retention(self, duration: datetime.timedelta):
         j_duration = j_duration_class.ofMillis(long(round(duration.total_seconds() * 1000)))
         self._j_table_config.setIdleStateRetention(j_duration)
 
-    def get_min_idle_state_retention_time(self) -> int:
-        """
-        State might be cleared and removed if it was not updated for the defined period of time.
-
-        .. note::
-
-            Currently the concept of min/max idle state retention has been deprecated and only
-            idle state retention time is supported. The min idle state retention is regarded as
-            idle state retention and the max idle state retention is derived from idle state
-            retention as 1.5 x idle state retention.
-
-        :return: The minimum time until state which was not updated will be retained.
-        """
-        return self._j_table_config.getMinIdleStateRetentionTime()
-
-    def get_max_idle_state_retention_time(self) -> int:
-        """
-        State will be cleared and removed if it was not updated for the defined period of time.
-
-        .. note::
-
-            Currently the concept of min/max idle state retention has been deprecated and only
-            idle state retention time is supported. The min idle state retention is regarded as
-            idle state retention and the max idle state retention is derived from idle state
-            retention as 1.5 x idle state retention.
-
-        :return: The maximum time until state which was not updated will be retained.
-        """
-        return self._j_table_config.getMaxIdleStateRetentionTime()
-
     def get_idle_state_retention(self) -> datetime.timedelta:
         """
 

flink-python/pyflink/table/tests/test_table_config.py

@@ -23,15 +23,6 @@
 
 
 class TableConfigTests(PyFlinkTestCase):
-    def test_get_set_idle_state_retention_time(self):
-        table_config = TableConfig.get_default()
-
-        table_config.set_idle_state_retention_time(
-            datetime.timedelta(days=1), datetime.timedelta(days=2))
-
-        self.assertEqual(3 * 24 * 3600 * 1000 / 2, table_config.get_max_idle_state_retention_time())
-        self.assertEqual(24 * 3600 * 1000, table_config.get_min_idle_state_retention_time())
-
     def test_get_set_idle_state_rentention(self):
         table_config = TableConfig.get_default()
 

flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java

@@ -411,34 +411,6 @@ public void setIdleStateRetention(Duration duration) {
         configuration.set(ExecutionConfigOptions.IDLE_STATE_RETENTION, duration);
     }
 
-    /**
-     * NOTE: Currently the concept of min/max idle state retention has been deprecated and only idle
-     * state retention time is supported. The min idle state retention is regarded as idle state
-     * retention and the max idle state retention is derived from idle state retention as 1.5 x idle
-     * state retention.
-     *
-     * @return The minimum time until state which was not updated will be retained.
-     * @deprecated use{@link getIdleStateRetention} instead.
-     */
-    @Deprecated
-    public long getMinIdleStateRetentionTime() {
-        return configuration.get(ExecutionConfigOptions.IDLE_STATE_RETENTION).toMillis();
-    }
-
-    /**
-     * NOTE: Currently the concept of min/max idle state retention has been deprecated and only idle
-     * state retention time is supported. The min idle state retention is regarded as idle state
-     * retention and the max idle state retention is derived from idle state retention as 1.5 x idle
-     * state retention.
-     *
-     * @return The maximum time until state which was not updated will be retained.
-     * @deprecated use{@link getIdleStateRetention} instead.
-     */
-    @Deprecated
-    public long getMaxIdleStateRetentionTime() {
-        return getMinIdleStateRetentionTime() * 3 / 2;
-    }
-
     /**
      * @return The duration until state which was not updated will be retained.
      */

flink-table/flink-table-api-scala-bridge/src/test/scala/org/apache/flink/table/api/bridge/scala/internal/StreamTableEnvironmentImplTest.scala

@@ -48,8 +48,7 @@ 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)
   }
 
   @Test
@@ -63,8 +62,7 @@ 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)
   }
 
   private def getStreamTableEnvironment(

flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/TableConfigUtils.java

@@ -105,11 +105,6 @@ public static ZoneId getLocalTimeZone(ReadableConfig tableConfig) {
         return ZoneId.of(zone);
     }
 
-    /**
-     * Similar to {@link TableConfig#getMaxIdleStateRetentionTime()}.
-     *
-     * @see TableConfig#getMaxIdleStateRetentionTime()
-     */
     @Deprecated
     public static long getMaxIdleStateRetentionTime(ReadableConfig tableConfig) {
         return tableConfig.get(ExecutionConfigOptions.IDLE_STATE_RETENTION).toMillis() * 3 / 2;