Review the stop

piflow-bundle/src/main/resources/flow/redis/WriteToRedis.json

@@ -16,7 +16,7 @@
         "name":"WriteToRedis",
         "bundle":"cn.piflow.bundle.redis.WriteToRedis",
         "properties":{
-          "redis_host":"10.0.88.9",
+          "redis_host":"192.168.3.138",
           "port":"7000",
           "password":"bigdata",
           "column_name":"title",

piflow-bundle/src/main/scala/cn/piflow/bundle/hive/SelectHiveQLByJDBC.scala

@@ -48,6 +48,7 @@ class SelectHiveQLByJDBC extends ConfigurableStop {
       .defaultValue("123456")
       .required(true)
       .example("123456")
+      .sensitive(true)
     descriptor = hivePassword :: descriptor
 
     val jdbcUrl = new PropertyDescriptor().

piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/ImpalaRead.scala

@@ -72,16 +72,39 @@ class ImpalaRead extends ConfigurableStop{
   override def getPropertyDescriptor(): List[PropertyDescriptor] = {
     var descriptor : List[PropertyDescriptor] = List()
 
-    val url=new PropertyDescriptor().name("url").displayName("url").description("IP and port number, you need to write like this -- ip:port").defaultValue("").required(true)
+    val url=new PropertyDescriptor().name("url")
+      .displayName("url")
+      .description("IP and port number, you need to write like this -- ip:port")
+      .defaultValue("")
+      .required(true)
     descriptor = url :: descriptor
-    val user=new PropertyDescriptor().name("user").displayName("user").description("user").defaultValue("").required(false)
+    val user=new PropertyDescriptor()
+      .name("user")
+      .displayName("user")
+      .description("user")
+      .defaultValue("")
+      .required(false)
     descriptor = user :: descriptor
-    val password=new PropertyDescriptor().name("password").displayName("password").description("password").defaultValue("").required(false)
+    val password=new PropertyDescriptor()
+      .name("password")
+      .displayName("password")
+      .description("password")
+      .defaultValue("")
+      .required(false)
     descriptor = password :: descriptor
-    val sql=new PropertyDescriptor().name("sql").displayName("sql").description("The name of the table has not changed.But you have to specify which database," +
+    val sql=new PropertyDescriptor()
-      " such as database.table.").defaultValue("").required(true)
+      .name("sql")
+      .displayName("sql")
+      .description("The name of the table has not changed.But you have to specify which database,such as database.table.")
+      .defaultValue("")
+      .required(true)
     descriptor = sql :: descriptor
-    val schameString=new PropertyDescriptor().name("schameString").displayName("schameString").description("The field of SQL statement query results is divided by ,").defaultValue("").required(true)
+    val schameString=new PropertyDescriptor()
+      .name("schameString")
+      .displayName("schameString")
+      .description("The field of SQL statement query results is divided by ,")
+      .defaultValue("")
+      .required(true)
     descriptor = schameString :: descriptor
 
     descriptor

piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/MysqlRead.scala

@@ -73,6 +73,7 @@ class MysqlRead extends ConfigurableStop  {
       .defaultValue("")
       .required(true)
       .example("12345")
+      .sensitive(true)
     descriptor = password :: descriptor
 
     val sql=new PropertyDescriptor()

piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/MysqlReadIncremental.scala

@@ -73,6 +73,7 @@ class MysqlReadIncremental extends ConfigurableIncrementalStop{
       .defaultValue("")
       .required(true)
       .example("")
+      .sensitive(true)
     descriptor = password :: descriptor
 
     val sql=new PropertyDescriptor()

piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/MysqlWrite.scala

@@ -71,6 +71,7 @@ class MysqlWrite extends ConfigurableStop{
       .defaultValue("")
       .required(true)
       .example("123456")
+      .sensitive(true)
     descriptor = password :: descriptor
 
     val dbtable=new PropertyDescriptor()

piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/OracleRead.scala

@@ -70,6 +70,7 @@ class OracleRead extends ConfigurableStop{
       .required(true)
       .example("123456")
       .sensitive(true)
+      .sensitive(true)
     descriptor = password :: descriptor
 
     val sql=new PropertyDescriptor()

piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/OracleReadByPartition.scala

@@ -63,6 +63,7 @@ class OracleReadByPartition extends ConfigurableStop{
       .defaultValue("")
       .required(true)
       .example("123456")
+      .sensitive(true)
     descriptor = password :: descriptor
 
     val sql=new PropertyDescriptor()

piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/OracleWrite.scala

@@ -91,6 +91,7 @@ class OracleWrite extends ConfigurableStop{
       .defaultValue("")
       .required(true)
       .example("123456")
+      .sensitive(true)
     descriptor = password :: descriptor
 
     val table=new PropertyDescriptor()