去除多余打印

flink.py

@@ -107,7 +107,20 @@ class MyTest(unittest.TestCase):
         --redisIp redis-master.rxdptest.svc.k5.bigtree.zone
         --redisPassword SB6vdem
         """))
-
+    def test_upload_start_dev(self):
+        flink = MyFlink("https://flink.rxdpdev.k5.bigtree.tech")
+        jar_id = flink.upload_jar("/Users/alvin/bigtree/rxdp-dm-jobs/rxdp-dm-jobs-flink/target/rxdp-dm-jobs-flink-1.6.0-SNAPSHOT.jar")
+        print(f"jar_id: {jar_id}")
+        flink.stop_all()
+        print(flink.start_job(jar_id, """
+        --kafkaServer kafka-0.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-1.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-2.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092
+        --esServer elasticsearch-master.rxdpdev.svc.k5.bigtree.zone
+        --esPort 9200 
+        --pythonUrl http://py-invoke-svc:8000
+        --redisIp redis-master.rxdpdev.svc.k5.bigtree.zone
+        --redisPassword SB6vdem
+        """))
 
 if __name__ == '__main__':
+    MyTest.test_upload_start()
     pass