fix: modify the logger info

elenacliu · elenacliu · commit 0503f21b2ab8 · 2023-05-04T23:44:09.000+08:00
diff --git a/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java b/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java
@@ -51,13 +51,12 @@ public void process(T data) throws Throwable {
             Iterable<? extends VR> convert = valueMapperAction.convert(data);
 
             if (convert == null) {
-                logger.warn("discard data:[{}]", convert);
+                logger.warn("[{}] converts to null, processor returns directly", data);
                 return;
             }
 
             for (VR item : convert) {
                 if (item == null) {
-                    logger.warn("discard data:[{}]", item);
                     continue;
                 }
                 Data<Object, VR> before = new Data<>(this.context.getKey(), item, this.context.getDataTime(), this.context.getHeader());
diff --git a/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java b/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java
@@ -53,7 +53,7 @@ public ValueMapperProcessor(ValueMapperAction<T, O> valueMapperAction) {
         public void process(T data) throws Throwable {
             O convert = valueMapperAction.convert(data);
             if (convert == null) {
-                logger.warn("discard data:[{}]", data);
+                logger.warn("[{}] converts to null, processor returns directly", data);
                 return;
             }
             Data<Object, O> before = new Data<>(this.context.getKey(), convert, this.context.getDataTime(), this.context.getHeader());

Original file line number	Diff line number	Diff line change
`@@ -51,13 +51,12 @@ public void process(T data) throws Throwable {`
`51`	`51`	`Iterable<? extends VR> convert = valueMapperAction.convert(data);`
`52`	`52`
`53`	`53`	`if (convert == null) {`
`54`		`- logger.warn("discard data:[{}]", convert);`
	`54`	`+ logger.warn("[{}] converts to null, processor returns directly", data);`
`55`	`55`	`return;`
`56`	`56`	`}`
`57`	`57`
`58`	`58`	`for (VR item : convert) {`
`59`	`59`	`if (item == null) {`
`60`		`- logger.warn("discard data:[{}]", item);`
`61`	`60`	`continue;`
`62`	`61`	`}`
`63`	`62`	`Data<Object, VR> before = new Data<>(this.context.getKey(), item, this.context.getDataTime(), this.context.getHeader());`
Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,7 @@ public ValueMapperProcessor(ValueMapperAction<T, O> valueMapperAction) {`
`53`	`53`	`public void process(T data) throws Throwable {`
`54`	`54`	`O convert = valueMapperAction.convert(data);`
`55`	`55`	`if (convert == null) {`
`56`		`- logger.warn("discard data:[{}]", data);`
	`56`	`+ logger.warn("[{}] converts to null, processor returns directly", data);`
`57`	`57`	`return;`
`58`	`58`	`}`
`59`	`59`	`Data<Object, O> before = new Data<>(this.context.getKey(), convert, this.context.getDataTime(), this.context.getHeader());`