You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2021/02/05 02:35:13 UTC
[flink] branch release-1.12 updated: [hotfix][jdbc] Fix typo in
UnsignedTypeConversionITCase
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.12 by this push:
new 48cd320 [hotfix][jdbc] Fix typo in UnsignedTypeConversionITCase
48cd320 is described below
commit 48cd320db4a1fcb2055c69a2293ba07a7777b0fb
Author: V1ncentzzZ <45...@users.noreply.github.com>
AuthorDate: Fri Feb 5 10:32:45 2021 +0800
[hotfix][jdbc] Fix typo in UnsignedTypeConversionITCase
This closes #14849
Co-authored-by: xiaozilong <xi...@bigo.sg>
---
.../flink/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 6e90660..4c05a95 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 class UnsignedTypeConversionITCase extends AbstractTestBase {
}
}
} 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 class UnsignedTypeConversionITCase extends AbstractTestBase {
if (!initDbSuccess) {
throw new IllegalStateException(
String.format(
- "Initialize MySQL database instance failed after {} attempts,"
+ "Initialize MySQL database instance failed after %d attempts,"
+ " please open an issue.",
INITIALIZE_DB_MAX_RETRY));
}
@@ -249,7 +249,7 @@ public class UnsignedTypeConversionITCase extends AbstractTestBase {
try {
db.stop();
} catch (ManagedProcessException e1) {
- logger.warn("Stop DB instance fail caused by {}", e1);
+ logger.warn("Stop DB instance failed.", e1);
}
}
}