|
|
|
@ -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" |
|
|
|
- | |
|
|
|
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 |
