[FLINK-4663] [jdbc] Fix JDBCOutputFormat log message

This closes apache#2534
apivovarov · Sep 23, 2016 · 335a282 · 335a282
1 parent 181b545
commit 335a282
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nnectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java b/...nnectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
@@ -108,7 +108,7 @@ private void establishConnection() throws SQLException, ClassNotFoundException {
 	@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 {