[Bug][Manager] NPE is thrown when startup the Sort task in the InlongStream workflow

[haifxu]

What happened

error log:

java.lang.NullPointerException: null
        at org.apache.inlong.manager.plugin.listener.StartupStreamListener.listen(StartupStreamListener.java:100) ~[manager-plugins-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.event.LogableEventListener.executeListenerWithLog(LogableEventListener.java:78) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.event.LogableEventListener.listen(LogableEventListener.java:59) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.event.task.TaskEventNotifier.notify(TaskEventNotifier.java:56) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.processor.ServiceTaskProcessor.complete(ServiceTaskProcessor.java:115) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeComplete(ProcessorExecutorImpl.java:97) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeStart(ProcessorExecutorImpl.java:90) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeComplete(ProcessorExecutorImpl.java:102) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeStart(ProcessorExecutorImpl.java:90) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeComplete(ProcessorExecutorImpl.java:102) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeStart(ProcessorExecutorImpl.java:90) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeComplete(ProcessorExecutorImpl.java:102) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessorExecutorImpl.executeStart(ProcessorExecutorImpl.java:90) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.workflow.core.impl.ProcessServiceImpl.start(ProcessServiceImpl.java:62) ~[manager-workflow-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.service.workflow.WorkflowServiceImpl.start(WorkflowServiceImpl.java:89) ~[manager-service-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at org.apache.inlong.manager.service.listener.queue.QueueResourceListener.lambda$createQueueForStreams$0(QueueResourceListener.java:147) ~[manager-service-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
        at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_312]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312]
        at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_312]

What you expected to happen

Fix this bug.

How to reproduce

Startup stream sort.

Environment

No response

InLong version

master

InLong Component

InLong Manager

Are you willing to submit PR?

• Yes, I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[gosonzhang]

Thanks @haifxu, I got it!

[fuweng11]

I will deal with this problem!

[gosonzhang]

Thanks @fuweng11