邯郸建设公司网站,网站 租用服务器,天猫网站建设论文,网站开发招商计划书1.下载flink
https://archive.apache.org/dist/flink/flink-1.12.2/
2.修改flink-conf.yaml #根据自己电脑核数修改#xff0c;这里我设置为4#xff0c;因为系统分配了4核 jobmanager.rpc.address: localhost #主机名根据自己设定 taskmanager.numberOfTaskSlots: 4 3.下载…1.下载flink
https://archive.apache.org/dist/flink/flink-1.12.2/
2.修改flink-conf.yaml #根据自己电脑核数修改这里我设置为4因为系统分配了4核 jobmanager.rpc.address: localhost #主机名根据自己设定 taskmanager.numberOfTaskSlots: 4 3.下载flink-sql mysql cdc包
flink-sql-connector-mysql-cdc-1.2.0.jar
https://archiva-maven-storage-prod.oss-cn-beijing.aliyuncs.com/repository/gradle-plugin/com/alibaba/ververica/flink-sql-connector-mysql-cdc/1.2.0/flink-sql-connector-mysql-cdc-1.2.0.jar?spma2c6h.24085988.0.0.101c3054iDT6s8Expires1690131054OSSAccessKeyIdLTAIfU51SusnnfCCSignaturePL4xE68opO%2FTfCwsFW4HdWzjrGw%3D
4.下载fink jdbc包
https://mvnrepository.com/artifact/org.apache.flink/flink-connector-jdbc_2.11/1.12.2 5.下载flink changelog-json数据格式包
https://archiva-maven-storage-prod.oss-cn-beijing.aliyuncs.com/repository/central/com/alibaba/ververica/flink-format-changelog-json/1.2.0/flink-format-changelog-json-1.2.0.jar?Expires1690131326OSSAccessKeyIdLTAIfU51SusnnfCCSignatureWHN7OVw8yGIeREN%2Bgd1Na7EbpC8%3D
6.将以上下载的jar包,上传至lib目录下 6.启动集群以及client端
#启动flink
bin/start-cluster.sh#启动client
bin/sql-client.sh embedded 7.查看flink控制台
