[flink] splitAssigner adds a thread-safe interface for obtaining the number of remaining splits.

[flink] splitAssigner adds a thread-safe interface for obtaining the number of remaining splits. #2576