Flink1.9 upgrade & alink usage

Because you want to use the ml features of the following flink, you need to upgrade flink to 1. 9.

After modifying the version of the pom file, the code reported almost nothing wrong, and for a moment of joy, only the creation of the batch changed.

BatchTableEnvironment tableEnv = new BatchTableEnvironment (env, TableConfig.DEFAULT ()); change to BatchTableEnvironment tableEnv = BatchTableEnvironment.create (env, TableConfig.getDefault ())

(the code didn't run, and hopefully it will run smoothly.)

Get the source code of alink

Git clone https://github.com/alibaba/Alink.git cd Alink & & mvn-Dmaven.test.skip=true clean package shade:shade

Because alink is not available on the maven server, you need to upload it.

Alink_core-0.1-SNAPSHOT.jar to the company's server, perform mvn deploy upload to the company's server under the root directory of the project.

And then introduce

Com.alibaba.alink alink_core 0.1-SNAPSHOT

Then import ALSExample into ide, and then you can study the first example