LiChang created FLINK-25484: ------------------------------- Summary: TableRollingPolicy do not support inactivityInterval config which is supported in datastream api Key: FLINK-25484 URL: https://issues.apache.org/jira/browse/FLINK-25484 Project: Flink Issue Type: Improvement Components: Connectors / FileSystem Affects Versions: 1.15.0 Reporter: LiChang Fix For: 1.15.0
TableRollingPolicy do not support inactivityInterval config public static class TableRollingPolicy extends CheckpointRollingPolicy<RowData, String> { private final boolean rollOnCheckpoint; private final long rollingFileSize; private final long rollingTimeInterval; public TableRollingPolicy( boolean rollOnCheckpoint, long rollingFileSize, long rollingTimeInterval) { this.rollOnCheckpoint = rollOnCheckpoint; Preconditions.checkArgument(rollingFileSize > 0L); Preconditions.checkArgument(rollingTimeInterval > 0L); this.rollingFileSize = rollingFileSize; this.rollingTimeInterval = rollingTimeInterval; } -- This message was sent by Atlassian Jira (v8.20.1#820001)