Skip to content
InLong Unit Test For Flink 1.15

[INLONG-10682][Sort] Make pulsar source support to send audit information exactly once and add ExtractNode.INLONG_MSG to helper validate #1142

Sign in to view logs

[INLONG-10682][Sort] Make pulsar source support to send audit information exactly once and add ExtractNode.INLONG_MSG to helper validate

[INLONG-10682][Sort] Make pulsar source support to send audit information exactly once and add ExtractNode.INLONG_MSG to helper validate #1142

This job succeeded