Skip to content

Commit b7c7a15

Browse files
committed
fix style
1 parent 528a075 commit b7c7a15

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/postgres/PostgresSourceReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,8 @@ private PostgresSourceConfig generatePostgresConfig(
208208
} else if (ConfigUtil.isJson(startupMode)) {
209209
Map<String, String> offsetMap = ConfigUtil.toStringMap(startupMode);
210210
if (offsetMap == null || !offsetMap.containsKey(SourceInfo.LSN_KEY)) {
211-
throw new RuntimeException("JSON offset for PostgreSQL must contain 'lsn' key, got: " + startupMode);
211+
throw new RuntimeException(
212+
"JSON offset for PostgreSQL must contain 'lsn' key, got: " + startupMode);
212213
}
213214
configFactory.startupOptions(StartupOptions.specificOffset(offsetMap));
214215
} else if (ConfigUtil.is13Timestamp(startupMode)) {

0 commit comments

Comments
 (0)