From 87a3b002e46d1200f5c1afe5a5f6a689533e9f66 Mon Sep 17 00:00:00 2001
From: judy0131 <xiaojie.zhu@163.com>
Date: Thu, 28 Feb 2019 14:19:47 +0800
Subject: [PATCH] fix bug

---
 .../main/scala/cn/piflow/api/HTTPClientStartFlowStreaming.scala | 2 +-
 readMe.txt                                                      | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

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
       <value>3600</value>
      </property>
 
+5.kafka related jars are needed to put on the spark cluster