diff --git a/adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/env/IEnvironment.java b/adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/env/IEnvironment.java index e7570833..ab5f3e3c 100644 --- a/adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/env/IEnvironment.java +++ b/adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/env/IEnvironment.java @@ -12,12 +12,12 @@ public interface IEnvironment extends Serializable { void init(); /** - * Submit pipeline by geaflow client. + * Submit pipeline by bridge client. */ IPipelineResult submit(); /** - * Shutdown geaflow client. + * Shutdown bridge client. */ void shutdown();