From 8e69b2f68237b1375c65bb35beb7501b7acd789d Mon Sep 17 00:00:00 2001 From: V1ncentzzZ <45353183+V1ncentzzZ@users.noreply.github.com> Date: Sun, 7 Feb 2021 11:36:09 +0800 Subject: [PATCH] [hotfix][jdbc] Fix typo in UnsignedTypeConversionITCase This closes #14876 Co-authored-by: xiaozilong --- .../connector/jdbc/table/UnsignedTypeConversionITCase.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java b/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java index 64a937392eb3f..f9f3d863e3cab 100644 --- a/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java +++ b/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java @@ -95,7 +95,7 @@ public static void prepareMariaDB() throws IllegalStateException { } } } catch (Exception e) { - logger.warn("Initialize DB fail caused by {}", e); + logger.warn("Initialize DB failed.", e); stopDb(); } if (initDbSuccess) { @@ -106,7 +106,7 @@ public static void prepareMariaDB() throws IllegalStateException { if (!initDbSuccess) { throw new IllegalStateException( String.format( - "Initialize MySQL database instance failed after %s attempts," + "Initialize MySQL database instance failed after %d attempts," + " please open an issue.", INITIALIZE_DB_MAX_RETRY)); } @@ -249,7 +249,7 @@ private static void stopDb() { try { db.stop(); } catch (ManagedProcessException e1) { - logger.warn("Stop DB instance fail caused by {}", e1); + logger.warn("Stop DB instance failed.", e1); } } }