Skip to content

Commit a420f9f

Browse files
authored
[core] No consumer expiration when write-only is true (#6890)
1 parent a3a336e commit a420f9f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -461,7 +461,7 @@ public TableCommitImpl newCommit(String commitUser) {
461461
newExpireRunnable(),
462462
options.writeOnly() ? null : store().newPartitionExpire(commitUser, this),
463463
options.writeOnly() ? null : store().newTagAutoManager(this),
464-
CoreOptions.fromMap(options()).consumerExpireTime(),
464+
options.writeOnly() ? null : CoreOptions.fromMap(options()).consumerExpireTime(),
465465
new ConsumerManager(fileIO, path, snapshotManager().branch()),
466466
options.snapshotExpireExecutionMode(),
467467
name(),

0 commit comments

Comments
 (0)