add default database

yanxi0227 · yanxi0227 · commit f8d692354e8b · 2018-12-10T20:36:55.000+08:00
diff --git a/redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/RedisOutputFormat.java b/redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/RedisOutputFormat.java
@@ -108,6 +108,10 @@ private void establishConnection() {
         if (timeout == 0){
             timeout = 10000;
         }
+        if (database == null)
+        {
+            database = "0";
+        }
 
         switch (redisType){
             //单机
@@ -134,7 +138,7 @@ public void writeRecord(Tuple2 record) throws IOException {
             return;
         }
         Row row = tupleTrans.getField(1);
-        if (record.getArity() != fieldNames.length) {
+        if (row.getArity() != fieldNames.length) {
             return;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -108,6 +108,10 @@ private void establishConnection() {`
`108`	`108`	`if (timeout == 0){`
`109`	`109`	`timeout = 10000;`
`110`	`110`	`}`
	`111`	`+ if (database == null)`
	`112`	`+ {`
	`113`	`+ database = "0";`
	`114`	`+ }`
`111`	`115`
`112`	`116`	`switch (redisType){`
`113`	`117`	`//单机`
`@@ -134,7 +138,7 @@ public void writeRecord(Tuple2 record) throws IOException {`
`134`	`138`	`return;`
`135`	`139`	`}`
`136`	`140`	`Row row = tupleTrans.getField(1);`
`137`		`- if (record.getArity() != fieldNames.length) {`
	`141`	`+ if (row.getArity() != fieldNames.length) {`
`138`	`142`	`return;`
`139`	`143`	`}`
`140`	`144`