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:01:23 UTC
[3/5] flink git commit: [FLINK-4663] [jdbc] Fix JDBCOutputFormat log
message
[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/335a2826
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/335a2826
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/335a2826
Branch: refs/heads/master
Commit: 335a2826481725aabc86de8068909060894a274b
Parents: 181b545
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 12:26:02 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/335a2826/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 {