flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [3/5] flink git commit: [FLINK-4663] [jdbc] Fix JDBCOutputFormat log message
Date Fri, 23 Sep 2016 12:01:23 GMT
[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 <swapnil.chougule@pubmatic.com>
Authored: Thu Sep 22 18:01:20 2016 +0530
Committer: Stephan Ewen <sewen@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 {


Mime
View raw message