flink打包执行代码

要打包和执行Flink代码，需要进行以下步骤：

1. 在pom.xml中添加Flink依赖，例如：

<dependencies>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-java</artifactId>
        <version>1.12.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
        <version>1.12.2</version>
    </dependency>
</dependencies>

2. 编写Flink代码，例如：

public class MyFlinkJob {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        
        DataStream<String> input = env.socketTextStream("localhost", 9999);
        
        DataStream<String> output = input.map(str -> "Hello, " + str);
        
        output.print();

        env.execute("My Flink Job");
    }
}

3. 在终端中进入代码所在的目录，执行以下命令进行打包：

mvn clean package

4. 打包完成后，在终端中进入target目录，执行以下命令运行Flink任务：

java -jar myflinkjob.jar

其中，`myflinkjob.jar`是打包生成的文件名。

这样，就完成了Flink代码的打包和执行。