This commit is contained in:
judy0131 2019-02-28 14:19:47 +08:00
parent c28fee4c1e
commit 87a3b002e4
2 changed files with 2 additions and 1 deletions

View File

@ -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 =

View File

@ -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