support int

Author: yanxi0227

redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/RedisOutputFormat.java

@@ -166,7 +166,7 @@ public void writeRecord(Tuple2 record) throws IOException {
         for (int i = 0; i < fieldNames.length; i++) {
             StringBuilder key = new StringBuilder();
             key.append(tableName).append(":").append(perKey).append(":").append(fieldNames[i]);
-            jedis.set(key.toString(), (String) row.getField(i));
+            jedis.set(key.toString(), row.getField(i).toString());
         }
         outRecords.inc();
     }