Merge branch 'feat_solr' into '1.10_test_4.2.x'

[feat-1584] fix outRecords metrics.

See merge request dt-insight-engine/flinkStreamSQL!279

Author: a49a

solr/solr-sink/src/main/java/com/dtstack/flink/sql/sink/solr/SolrOutputFormat.java

@@ -98,7 +98,11 @@ public void writeRecord(Tuple2<Boolean, Row> record) throws IOException {
             columnIndex++;
         }
         try {
+            if (outRecords.getCount() % ROW_PRINT_FREQUENCY == 0) {
+                LOG.info("Receive data : {}", row);
+            }
             provider.add(solrDocument);
+            outRecords.inc();
         } catch (SolrServerException | PrivilegedActionException e) {
             LOG.error("", e);
         }

solr/solr-sink/src/main/java/com/dtstack/flink/sql/sink/solr/table/SolrSinkParser.java

@@ -109,8 +109,6 @@ public Class dbTypeConvertToJavaType(String fieldType) {
             case "date":
             case "timestamp":
                 return Timestamp.class;
-            case "binary":
-                return byte[].class;
             default:
                 throw new RuntimeException("不支持 " + fieldType + " 类型");
         }