tables:
- name: TimestampTable
    type: source
    schema:
      - name: name
        type: ROW(firstname VARCHAR, lastname VARCHAR)
      - name: number
        type: INT
      - name: rowTime
        type: TIMESTAMP
        rowtime:
          timestamps:
            type: "from-field"
            from: "event_time"
          watermarks:
            type: "from-source"
    connector:
      property-version: 1
      type: kafka
      version: 0.11
      topic: test_flink_state_check
      startup-mode: earliest-offset
      properties:
        - key: zookeeper.connect
          value: zookeeper01.prod.xxxxxx.com:2181
        - key: bootstrap.servers
          value: kafka01.prod.xxxxxx.com:9092
        - key: group.id
          value: test_flink_sql_03
	format:
      property-version: 1
      type: json
      schema: "ROW(name ROW(firstname VARCHAR, lastname VARCHAR), number INT, event_time TIMESTAMP)"

execution:
  # 'batch' or 'streaming' execution
  type: streaming
  # allow 'event-time' or only 'processing-time' in sources
  time-characteristic: event-time
  # 'changelog' or 'table' presentation of results
  result-mode: table
  # parallelism of the program
  parallelism: 1
  # maximum parallelism
  max-parallelism: 128
  # minimum idle state retention in ms
  min-idle-state-retention: 0
  # maximum idle state retention in ms
  max-idle-state-retention: 0

deployment:
  # general cluster communication timeout in ms
  response-timeout: 5000
  # (optional) address from cluster to gateway
  gateway-address: ""
  # (optional) port from cluster to gateway
  gateway-port: 0