Fraud Detection with the DataStream API

我的版本时 1.13.5 （需要结合CDC来使用所有选择了1.13.x）

maven 命令方式

我没测试，直接用idea

  1. $ mvn archetype:generate \
  2.  -DarchetypeGroupId=org.apache.flink \
  3.  -DarchetypeArtifactId=flink-walkthrough-datastream-java \
  4.  -DarchetypeVersion=1.13.5 \
  5.  -DgroupId=frauddetection \
  6.  -DartifactId=frauddetection \
  7.  -Dversion=0.1 \
  8.  -Dpackage=spendreport \
  9.  -DinteractiveMode=false

Idea直接创建

image.png
image.png
image.png

修改pom 中的 scala.binary.version

  1. <scala.binary.version>2.12</scala.binary.version>

测试

使用内置的方法测试是否能正常跑 我这初始化出来的是叫 FraudDetectionJob

image.png

其他功能说明

打开 webUI

默认访问地址： http://localhost:8081/ 1.13.5 不会在控制台打印，想要开启:rootLogger.level = WARN -> rootLogger.level = INFO

  1. StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());

修改默认端口

配置参数详情

  1. Configuration configuration = new Configuration();
  2. configuration.setString("rest.bind-port", "1234");
  3. ## 如果多个端口呗占用，但又不清楚那几个，那就直接端口绑定的范围
  4. //configuration.setString(RestOptions.BIND_PORT, "8081-8089");   
  5. StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);



Flink项目错误集合

Flink项目错误集合