$ $FLINK_HOME/bin/start-cluster.sh
$ mvn clean package
$ $FLINK_HOME/bin/flink run target/flink-2.0-SNAPSHOT.jar
jean-pasquier/flink-scala-processor
Folders and files
| Name | Name | Last commit date | ||
|---|---|---|---|---|
| Name | Name | Last commit date | ||
|---|---|---|---|---|
$ $FLINK_HOME/bin/start-cluster.sh
$ mvn clean package
$ $FLINK_HOME/bin/flink run target/flink-2.0-SNAPSHOT.jar