实践flink

Posted on | In | Visitors 
1
2
3
4
5
wget -P ./lib/ https://repo1.maven.org/maven2/org/apache/flink/flink-json/1.10.1/flink-json-1.10.1.jar | \
    wget -P ./lib/ https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka_2.11/1.10.1/flink-sql-connector-kafka_2.11-1.10.1.jar | \
    wget -P ./lib/ https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch6_2.11/1.10.1/flink-sql-connector-elasticsearch6_2.11-1.10.1.jar | \
    wget -P ./lib/ https://repo1.maven.org/maven2/org/apache/flink/flink-jdbc_2.11/1.10.1/flink-jdbc_2.11-1.10.1.jar | \
    wget -P ./lib/ https://repo1.maven.org/maven2/mysql/mysql-connector-java/5.1.48/mysql-connector-java-5.1.48.jar

命令

1
$ bin/start-cluster.sh

http://localhost:8081