You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/09/23 12:16:33 UTC
flink git commit: [FLINK-4663] [jdbc] Fix JDBCOutputFormat log message
Repository: flink
Updated Branches:
refs/heads/release-1.1 52a4440d9 -> 8fd08bf29
[FLINK-4663] [jdbc] Fix JDBCOutputFormat log message
This closes #2534
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8fd08bf2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8fd08bf2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8fd08bf2
Branch: refs/heads/release-1.1
Commit: 8fd08bf29fbd3ee8798f52a4196c07bb4363ddd3
Parents: 52a4440
Author: swapnil-chougule <sw...@pubmatic.com>
Authored: Thu Sep 22 18:01:20 2016 +0530
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Sep 23 14:16:01 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8fd08bf2/flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
----------------------------------------------------------------------
diff --git a/flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java b/flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
index 5464a94..da4b1ad 100644
--- a/flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
+++ b/flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
@@ -108,7 +108,7 @@ public class JDBCOutputFormat extends RichOutputFormat<Row> {
@Override
public void writeRecord(Row row) throws IOException {
- if (typesArray != null && typesArray.length > 0 && typesArray.length == row.productArity()) {
+ if (typesArray != null && typesArray.length > 0 && typesArray.length != row.productArity()) {
LOG.warn("Column SQL types array doesn't match arity of passed Row! Check the passed array...");
}
try {