代码提交

src/main/java/com/jz/dmp/cmdexectool/scheduler/common/task/sql/SqlParameters.java

@@ -210,7 +210,7 @@ public class SqlParameters extends AbstractParameters {
 		sinkApiModel.put("method", apiObj.getString("method"));
 		sinkApiModel.put("signType", apiObj.getString("signType"));
 		sinkApiModel.put("authCode", apiObj.getString("authCode"));
-		sinkApiModel.put("slat", apiObj.getString("slat"));
+		sinkApiModel.put("salt", apiObj.getString("salt"));
 		sink = FreeMarkerUtils.freemakerJson(CommConstant.WATERDROP_FTL_SINK_API, sinkApiModel, freeMarkerConfig);
 	}
 

src/main/resources/templates/sink_api.ftl

 Api {
+<#if source_table_name??>
+    source_table_name="${source_table_name!}"
+</#if>
 <#if url??>
     url = "${url!}"
 </#if>

src/main/resources/templates/sink_kafka.ftl

 Kafka {
+<#if source_table_name??>
+	source_table_name="${source_table_name!}"
+</#if>
 <#if topic??>
 	# Kafka 主题
 	topic = "${topic!}"