You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2025/09/02 08:02:59 UTC
(flink) branch master updated: [FLINK-38308] Reduce logging of date parse errors in DateTimeUtils
This is an automated email from the ASF dual-hosted git repository.
roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 863b0511c00 [FLINK-38308] Reduce logging of date parse errors in DateTimeUtils
863b0511c00 is described below
commit 863b0511c00eb5277c0d5c0d4def18b8795cfdb1
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Mon Sep 1 15:48:14 2025 +0200
[FLINK-38308] Reduce logging of date parse errors in DateTimeUtils
---
.../main/java/org/apache/flink/table/utils/DateTimeUtils.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java
index 134a41905e4..7fd1e710e19 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java
@@ -800,7 +800,7 @@ public class DateTimeUtils {
return toFormatter.format(date);
} catch (ParseException e) {
- LOG.error(
+ LOG.debug(
"Exception when formatting: '"
+ dateStr
+ "' from: '"
@@ -809,8 +809,7 @@ public class DateTimeUtils {
+ toFormat
+ "' with offsetMills: '"
+ offsetMills
- + "'",
- e);
+ + "'");
return null;
}
}
@@ -1011,11 +1010,10 @@ public class DateTimeUtils {
Date date = formatter.parse(dateStr);
return date.getTime();
} catch (ParseException e) {
- LOG.error(
+ LOG.debug(
String.format(
"Exception when parsing datetime string '%s' in format '%s'",
- dateStr, format),
- e);
+ dateStr, format));
return Long.MIN_VALUE;
}
}