harbby/sylph

Job needs to add parameter setting function

Closed this issue · 2 comments

harbby commented

Similar to spark:

--executor-memory 2g
--executor-cores 2
--num-executors 2
--driver-memory 2g
--driver-cores 2
harbby commented

Currently support flink runner parameter settings first
They look like this:

type: "StreamSql"
config:
  taskManagerMemoryMb: 1024
  taskManagerCount: 2
  taskManagerSlots: 2
  jobManagerMemoryMb: 1024
  parallelism: 4
  queue: "default"
  appTags:
  - "sylph"
  - "flink"
harbby commented

This feature is already supported