From f9c8bfeea74bb5a89243bb13a8aea5f63b750941 Mon Sep 17 00:00:00 2001 From: zhoukunhua Date: Tue, 28 Jun 2022 15:07:27 +0800 Subject: [PATCH] config --- docker-compose.yml | 25 +++++++++++++++++++------ 1 file changed, 19 insertions(+), 6 deletions(-) diff --git a/docker-compose.yml b/docker-compose.yml index cac1863..dc711de 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -12,12 +12,18 @@ services: - ./flink/flink-savepoints:/opt/flink/flink-savepoints - ./flink/log:/opt/flink/log - ./flink/runjob:/opt/flink/usrlib + - ./jindo-flink-4.4.0-full.jar:/opt/flink/lib/jindo-flink-4.4.0-full.jar + - ./jindo-sdk-4.4.0.jar:/opt/flink/lib/jindo-sdk-4.4.0.jar environment: - TZ=Asia/Shanghai - JOB_MANAGER_RPC_ADDRESS=jobmanager - extra_hosts: - - "kafka1:192.168.10.217" - - "kafka2:192.168.10.217" + - | + FLINK_PROPERTIES= + fs.oss.endpoint: oss-cn-shenzhen.aliyuncs.com + fs.oss.accessKeyId: LTAINmC91NqIGN38 + fs.oss.accessKeySecret: Hh10dQPjq1jMLLSpbDAR05ZzR3nXsU + fs.AbstractFileSystem.oss.impl: com.aliyun.jindodata.oss.OSS + fs.oss.impl: com.aliyun.jindodata.oss.JindoOssFileSystem taskmanager: image: flink:1.15-java8 expose: @@ -26,15 +32,22 @@ services: depends_on: - jobmanager command: taskmanager + volumes: - ./flink/flink-checkpoints:/opt/flink/flink-checkpoints - ./flink/flink-savepoints:/opt/flink/flink-savepoints - ./flink/log:/opt/flink/log - ./flink/runjob:/opt/flink/usrlib + - ./jindo-flink-4.4.0-full.jar:/opt/flink/lib/jindo-flink-4.4.0-full.jar + - ./jindo-sdk-4.4.0.jar:/opt/flink/lib/jindo-sdk-4.4.0.jar links: - "jobmanager:jobmanager" environment: - TZ=Asia/Shanghai - JOB_MANAGER_RPC_ADDRESS=jobmanager - extra_hosts: - - "kafka1:192.168.10.217" - - "kafka2:192.168.10.217" \ No newline at end of file + - | + FLINK_PROPERTIES= + fs.oss.endpoint: oss-cn-shenzhen.aliyuncs.com + fs.oss.accessKeyId: LTAINmC91NqIGN38 + fs.oss.accessKeySecret: Hh10dQPjq1jMLLSpbDAR05ZzR3nXsU + fs.AbstractFileSystem.oss.impl: com.aliyun.jindodata.oss.OSS + fs.oss.impl: com.aliyun.jindodata.oss.JindoOssFileSystem \ No newline at end of file