Skip to content

Commit

Permalink
fix log level
Browse files Browse the repository at this point in the history
  • Loading branch information
vernedeng committed Jan 6, 2025
1 parent 0bab6ab commit 6a3f450
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ public <T> DirtySink<T> createDirtySink(DynamicTableFactory.Context context) {
return new InlongSdkDirtySink<>(options,
context.getCatalogTable().getResolvedSchema().toPhysicalRowDataType());
} catch (Throwable t) {
log.info("failed to create dirty sink", t);
log.warn("failed to create dirty sink", t);
return null;
}
}
Expand Down Expand Up @@ -127,9 +127,9 @@ private String decrypt(String before, String key) {
byte[] bytes = AESUtils.parseHexStr2Byte(before);
bytes = AESUtils.decrypt(bytes, key.trim().getBytes(StandardCharsets.UTF_8));
decrypted = new String(Base64.decodeBase64(bytes), StandardCharsets.UTF_8);
} catch (Throwable e) {
log.warn("failed to decrypt {} into cmk", before, e);
throw new RuntimeException(e);
} catch (Throwable t) {
log.warn("failed to decrypt {} into cmk", before, t);
throw new RuntimeException(t);
}
return decrypted;
}
Expand Down

0 comments on commit 6a3f450

Please sign in to comment.