Shulou(Shulou.com)06/01 Report--

This article introduces the relevant knowledge of "how to use Flink". In the operation of actual cases, many people will encounter such a dilemma, so let the editor lead you to learn how to deal with these situations. I hope you can read it carefully and be able to achieve something!

1. Pull the image first

Docker pull flink

2. Create a network of docker

Docker network create flink-network

3. Run the container

Docker run-rm-name=jobmanager-network flink-network-publish 8081 name=jobmanager 8081-env FLINK_PROPERTIES= "jobmanager.rpc.address: jobmanager" flink:latest jobmanager

4. Then visit http://localhost:8081/ directly and you can access it, and you're done. Use it and supplement it later.

Container submission task can not be submitted for a long time, and then installed one locally, because it is windos, all downloaded a version 1.9.3 download.

1. It's easy to run, go directly to the bin directory, and then double-click to run it.

2. If there is no Entry Class when submitting the task, it means that there is no home directory, that is, if the main function is not specified when packaging, you can set the home directory in the configuration.

3. Then submit the task. Click show plan to report an error, and the submitted task will also report an error. You can see the Logs click in the Job Manage menu, and pull to the bottom to find that there is an error message, but there is a lack of class. this dog problem has been plagued for a long time, but Baidu can not find it. I think it should be a very low-level problem, which may be rarely committed (at least the version problem, but in fact it is not). Later, I found some blogs that said to add reference classes under lib, but the pom I used was not a direct reference to jar. Later, I found that flink had a lib folder, so I threw jar into it and found that although the class was still missing, the missing class had changed. Then I tried to package all the dependencies into a jar, and the error changed, but the class was still missing. After looking for a blog for a long time, I forgot to write down the address, saying that not all dependencies have to be packaged, and then gave a maven packaging information, and then tried it, all right. Just want to say MMP, this question should be recorded by many people, but there is no record, so I will record it. The error message will be added later.

Org.apache.maven.plugins maven-shade-plugin 3.0.0 package shade Com.google.code.findbugs:jsr305 org.slf4j:* log4j:* *: * META-INF/*.SF META-INF/*.DSA META-INF/*.RSA Com.uwith.Application That's all for "how to use Flink". Thank you for your reading. If you want to know more about the industry, you can follow the website, the editor will output more high-quality practical articles for you!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.