diff --git a/piflow-server/src/main/scala/cn/piflow/api/HTTPClientStartFlowStreaming.scala b/piflow-server/src/main/scala/cn/piflow/api/HTTPClientStartFlowStreaming.scala index 2a13f73..f87623d 100644 --- a/piflow-server/src/main/scala/cn/piflow/api/HTTPClientStartFlowStreaming.scala +++ b/piflow-server/src/main/scala/cn/piflow/api/HTTPClientStartFlowStreaming.scala @@ -5,7 +5,7 @@ import org.apache.http.entity.StringEntity import org.apache.http.impl.client.HttpClients import org.apache.http.util.EntityUtils -object HTTPClientStartFlow { +object HTTPClientStartFlowStreaming { def main(args: Array[String]): Unit = { val json = diff --git a/readMe.txt b/readMe.txt index 0f4f2f2..9481fd4 100644 --- a/readMe.txt +++ b/readMe.txt @@ -30,4 +30,5 @@ clean package -Dmaven.test.skip=true -U 3600 +5.kafka related jars are needed to put on the spark cluster