Skip to content

Commit fc03e9b

Browse files
committed
feat: jdbc log rolling
1 parent b6bc43b commit fc03e9b

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

connectors-common/sql-core/src/main/java/io/tapdata/common/CommonDbConnector.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import io.tapdata.pdk.apis.entity.TapAdvanceFilter;
3131
import io.tapdata.pdk.apis.entity.TapFilter;
3232
import io.tapdata.pdk.apis.functions.connector.target.CreateTableOptions;
33-
import io.tapdata.write.FileLogger;
3433
import org.apache.commons.lang3.StringUtils;
3534

3635
import java.io.IOException;
@@ -70,7 +69,6 @@ public abstract class CommonDbConnector extends ConnectorBase {
7069
protected DDLSqlGenerator ddlSqlGenerator;
7170
//Once the task is started, this ID is a unique identifier and stored in the stateMap
7271
protected String firstConnectorId;
73-
protected FileLogger fileLogger;
7472
//jdbc context for each relation datasource
7573
protected JdbcContext jdbcContext;
7674
//db config for each relation datasource (load properties from TapConnectionContext)

connectors-common/sql-core/src/main/java/io/tapdata/common/log/CustomLogDelegator.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -188,6 +188,9 @@ private FileLogger getOrCreateFileLogger(String loggerName) {
188188
.flushIntervalMs(1000) // Flush every 1 second
189189
.maxFileSizeMB(100) // Max file size 100MB
190190
.autoTimestamp(true) // Auto add timestamp
191+
.enableCompression(true)
192+
.compressIntervalMs(1000 * 60 * 30)
193+
.maxFileSizeMB(100)
191194
.build();
192195

193196
System.out.println("[CustomLogDelegator] Created FileLogger for: " + name + " -> " + LOG_DIR + "/" + filePrefix);

0 commit comments

Comments
 (0)