add short asyn help content for plugin field

baisui1981 · baisui1981 · commit 720ecd44d656 · 2025-12-24T13:47:20.000+08:00
diff --git a/tis-incr/tis-flink-cdc-common/src/main/java/com/qlangtech/plugins/incr/debuzium/DebuziumPropAssist.java b/tis-incr/tis-flink-cdc-common/src/main/java/com/qlangtech/plugins/incr/debuzium/DebuziumPropAssist.java
@@ -18,10 +18,11 @@
 
 package com.qlangtech.plugins.incr.debuzium;
 
-import com.google.common.collect.Lists;
 import com.qlangtech.tis.extension.Describable;
 import com.qlangtech.tis.extension.Descriptor;
 import com.qlangtech.tis.extension.util.AbstractPropAssist;
+import com.qlangtech.tis.extension.util.OverwriteProps;
+import com.qlangtech.tis.extension.util.PluginExtraProps;
 import com.qlangtech.tis.manage.common.Option;
 import io.debezium.config.Field;
 import io.debezium.config.Field.EnumRecommender;
@@ -47,7 +48,7 @@ public static <T extends Describable, PLUGIN extends T> Options<PLUGIN, Field> c
 
     @Override
     protected MarkdownHelperContent getDescription(Field configOption) {
-        return new MarkdownHelperContent(configOption.description());
+        return new MarkdownHelperContent(PluginExtraProps.AsynPropHelp.create( configOption.description()));
     }
 
     @Override
@@ -64,7 +65,7 @@ protected List<Option> getOptEnums(Field configOption) {
                 throw new IllegalStateException("unsupported type:" + targetClazz);
             }
             case BOOLEAN: {
-                opts = Lists.newArrayList(new Option("是", true), new Option("否", false));
+                opts = OverwriteProps.ENUM_BOOLEAN;// Lists.newArrayList(new Option("是", true), new Option("否", false));
                 break;
             }
             case CLASS:
diff --git a/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/FlinkPropAssist.java b/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/FlinkPropAssist.java
@@ -26,6 +26,7 @@
 import com.qlangtech.tis.extension.impl.RootFormProperties;
 import com.qlangtech.tis.extension.util.AbstractPropAssist.MarkdownHelperContent;
 import com.qlangtech.tis.extension.util.OverwriteProps;
+import com.qlangtech.tis.extension.util.PluginExtraProps;
 import com.qlangtech.tis.manage.common.Option;
 import org.apache.commons.lang3.EnumUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -201,7 +202,7 @@ protected void addFieldDescriptor(String fieldName, ConfigOption<?> configOption
         Object dftVal = overwriteProps.processDftVal(configOption.defaultValue());
 
 
-        MarkdownHelperContent helperContent = new MarkdownHelperContent(htmlFormatter.format(desc));
+        MarkdownHelperContent helperContent = new MarkdownHelperContent(PluginExtraProps.AsynPropHelp.create(htmlFormatter.format(desc)));
         if (overwriteProps.appendHelper.isPresent()) {
             helperContent.append(overwriteProps);
             // helperContent.append("\n\n").append(overwriteProps.appendHelper.get());
@@ -214,22 +215,22 @@ protected void addFieldDescriptor(String fieldName, ConfigOption<?> configOption
             if (dftVal != null) {
                 dftVal = ((Duration) dftVal).getSeconds();
             }
-            helperContent.append(new MarkdownHelperContent("单位：`秒`"));
+            helperContent.append(new MarkdownHelperContent(PluginExtraProps.AsynPropHelp.create("单位：`秒`")));
         } else if (targetClazz == MemorySize.class) {
             if (dftVal != null) {
                 dftVal = ((MemorySize) dftVal).getMebiBytes();
             }
-            helperContent.append(new MarkdownHelperContent("单位：`" + MemoryUnit.MEGA_BYTES.getUnits()[1] + "`"));
+            helperContent.append(new MarkdownHelperContent(PluginExtraProps.AsynPropHelp.create("单位：`" + MemoryUnit.MEGA_BYTES.getUnits()[1] + "`")));
         } else if (targetClazz.isEnum()) {
             List<Enum> enums = EnumUtils.getEnumList((Class<Enum>) targetClazz);
             opts = enums.stream().map((e) -> new Option(e.name())).collect(Collectors.toList());
         } else if (targetClazz == Boolean.class) {
-            opts = Lists.newArrayList(new Option("是", true), new Option("否", false));
+            opts = OverwriteProps.ENUM_BOOLEAN;
         }
 
         Optional<List<Option>> optsOp = overwriteProps.opts.isPresent() ? overwriteProps.opts : Optional.ofNullable(opts);
 
-        descriptor.addFieldDescriptor(fieldName, dftVal, null, helperContent, optsOp, overwriteProps.getDisabled());
+        descriptor.addFieldDescriptor(fieldName, dftVal, null, helperContent, optsOp, overwriteProps);
     }
 
     private static Method getClazzMethod;
diff --git a/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/TISFlinkCDCStreamFactory.java b/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/TISFlinkCDCStreamFactory.java
@@ -61,7 +61,7 @@
 import java.util.function.Consumer;
 import java.util.stream.Collectors;
 
-import static com.qlangtech.tis.extension.Descriptor.SWITCH_ON;
+import static com.qlangtech.tis.extension.Descriptor.SWITCH_OFF;
 
 /**
  * @author: 百岁（baisui@qlangtech.com）
@@ -112,7 +112,7 @@ public static List<Descriptor<CheckpointFactory>> filterCheckpoint(List<Descript
         BaseDataxWriterDescriptor desc = (BaseDataxWriterDescriptor) dataxWriter.getDescriptor();
         if (desc.getEndType() == EndType.Paimon) {
             // paimon端必须要开启checkpoint
-            return descs.stream().filter((d) -> SWITCH_ON.equals(d.getDisplayName())).collect(Collectors.toList());
+            return descs.stream().filter((d) -> !SWITCH_OFF.equals(d.getDisplayName())).collect(Collectors.toList());
         }
         return descs;
     }
diff --git a/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/ckpt/CKOff.java b/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/ckpt/CKOff.java
@@ -32,7 +32,7 @@
 public class CKOff extends CheckpointFactory {
     @Override
     public void setProps(StreamExecutionEnvironment env) {
-
+        env.enableCheckpointing(-1);
     }
 
     @Override
diff --git a/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/ckpt/DefaultCK.java b/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/ckpt/DefaultCK.java
@@ -0,0 +1,76 @@
+package com.qlangtech.plugins.incr.flink.launch.ckpt;
+
+import com.alibaba.citrus.turbine.Context;
+import com.qlangtech.plugins.incr.flink.launch.CheckpointFactory;
+import com.qlangtech.plugins.incr.flink.launch.FlinkPropAssist;
+import com.qlangtech.tis.extension.Descriptor;
+import com.qlangtech.tis.extension.TISExtension;
+import com.qlangtech.tis.extension.util.OverwriteProps;
+import com.qlangtech.tis.plugin.annotation.FormField;
+import com.qlangtech.tis.plugin.annotation.FormFieldType;
+import com.qlangtech.tis.plugin.annotation.Validator;
+import com.qlangtech.tis.runtime.module.misc.IFieldErrorHandler;
+import org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions;
+import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+
+import java.time.Duration;
+
+/**
+ *
+ * @author 百岁 (baisui@qlangtech.com)
+ * @date 2025/12/24
+ */
+public class DefaultCK extends CheckpointFactory {
+
+    @FormField(ordinal = 1, type = FormFieldType.INT_NUMBER, validate = {Validator.require, Validator.integer})
+    public Integer ckpointInterval;
+
+    @Override
+    public final boolean isOn() {
+        return true;
+    }
+
+    @Override
+    public void setProps(StreamExecutionEnvironment env) {
+        env.enableCheckpointing(Duration.ofSeconds(this.ckpointInterval).toMillis());
+    }
+
+    @TISExtension()
+    public static class DefaultDescriptor extends Descriptor<CheckpointFactory> {
+        protected final FlinkPropAssist.Options<CheckpointFactory> opts = FlinkPropAssist.createOpts(this);
+
+        public DefaultDescriptor() {
+            super();
+            opts.addFieldDescriptor("ckpointInterval"
+                    , ExecutionCheckpointingOptions.CHECKPOINTING_INTERVAL
+                    , OverwriteProps.dft(Duration.ofSeconds(200)).setReadOnly(this.ckpointIntervalReadOnly()));
+        }
+
+        protected boolean ckpointIntervalReadOnly() {
+            return true;
+        }
+
+        @Override
+        public String getDisplayName() {
+            return SWITCH_ON;
+        }
+
+        private static final int MIN_INTERVAL = 5;
+
+        public final boolean validateCkpointInterval(
+                IFieldErrorHandler msgHandler, Context context, String fieldName, String val) {
+            int interval = 0;
+            try {
+                interval = Integer.parseInt(val);
+            } catch (Throwable e) {
+
+            }
+            if (interval < MIN_INTERVAL) {
+                msgHandler.addFieldError(context, fieldName, "不能小于最小值：" + MIN_INTERVAL);
+                return false;
+            }
+            return true;
+
+        }
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@`
`32`	`32`	`public class CKOff extends CheckpointFactory {`
`33`	`33`	`@Override`
`34`	`34`	`public void setProps(StreamExecutionEnvironment env) {`
`35`		`-`
	`35`	`+ env.enableCheckpointing(-1);`
`36`	`36`	`}`
`37`	`37`
`38`	`38`	`@Override`