update project's name

build.sbt

 // ThisBuild / scalaVersion     := "2.12.13"
 ThisBuild / scalaVersion     := "2.11.12"
 ThisBuild / version          := "0.1.0"
-ThisBuild / organization     := "com.gmei"
+ThisBuild / organization     := "com.gmei.up"
 
 val esVersion = "7.10.2"
 val es = "org.elasticsearch" % "elasticsearch" % esVersion
@@ -22,7 +22,7 @@ val flinkHadoop = "org.apache.flink" %% "flink-hadoop-compatibility" % flinkVers
 
 lazy val root = (project in file("."))
   .settings(
-    name := "tryFlink",
+    name := "streamingUserPortrait",
 
     // libraryDependencies += "com.alibaba" % "fastjson" % "1.2.75",
     libraryDependencies += es,

src/main/scala/com.gmei/Main.scala → src/main/scala/com.gmei.up/Main.scala

-package com.gmei
+package com.gmei.up
 
-// import org.apache.flink.api.scala._
 import org.apache.flink.streaming.api.scala._
 
 object Main {
@@ -8,20 +7,10 @@ object Main {
     println("hello")
     val env = StreamExecutionEnvironment.getExecutionEnvironment
 
-    val socketStream = env.socketTextStream("localhost", 9000)
+    val a = env.fromElements(1, 2, -3, 0, 5, -9, 8)
+    val b = a.map(_ + 1)
 
-    // val a = env.fromElements(1, 2, -3, 0, 5, -9, 8)
-    // val b = a.map(_ + 1)
-
-    // b.print()
-
-    val wordsStream = socketStream.flatMap(value => value.split("\\s+")).map(value => (value, 1))
-
-    val keyValuePair = wordsStream.keyBy(0)
-
-    val countPair = keyValuePair.sum(1)
-
-    countPair.print
+    b.print()
 
     env.execute
   }