[INLONG-4816][DataProxy] Add warn log when there is no TubeMQ info when start for the first time (apache#4817)

Author: dockerzhang

inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java

@@ -259,14 +259,16 @@ private TubeClientConfig initTubeConfig(String masterUrl) throws Exception {
      * @throws FlumeException if an RPC client connection could not be opened
      */
     private void initCreateConnection() throws FlumeException {
-//        synchronized (tubeSessionLock) {
+        // check the TubeMQ address
+        if (masterHostAndPortLists == null || masterHostAndPortLists.isEmpty()) {
+            logger.warn("Failed to get TubeMQ Cluster, make sure register TubeMQ to manager successfully.");
+            return;
+        }
         // if already connected, just skip
         if (sessionFactories != null) {
             return;
         }
         sessionFactories = new HashMap<>();
-        Preconditions.checkState(masterHostAndPortLists != null && !masterHostAndPortLists.isEmpty(),
-                "No tube service url specified");
         for (String masterUrl : masterHostAndPortLists) {
             createConnection(masterUrl);
         }

inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java

@@ -136,7 +136,7 @@ public void setConfigLogMetric(StreamConfigLogMetric streamConfigLogMetric) {
     }
 
     public void initCreateConnection(CreatePulsarClientCallBack callBack) {
-        if (pulsarUrl2token.isEmpty()) {
+        if (pulsarUrl2token == null || pulsarUrl2token.isEmpty()) {
             logger.warn("Failed to get Pulsar Cluster, make sure register pulsar to manager successfully.");
             return;
         }

pom.xml

@@ -1007,12 +1007,6 @@
                 <artifactId>iceberg-flink-runtime-1.13</artifactId>
                 <version>${iceberg.flink.version}</version>
             </dependency>
-            <dependency>
-                <groupId>org.apache.iceberg</groupId>
-                <artifactId>iceberg-flink-runtime-1.13</artifactId>
-                <version>${iceberg.flink.version}</version>
-            </dependency>
-
             <dependency>
                 <groupId>org.apache.flink</groupId>
                 <artifactId>flink-table-planner-blink_${flink.scala.binary.version}</artifactId>