excerpt CF setup a flink job in Kinesis Analytics service

kinesis-analytics-taxi-consumer-infrastructure.yml

  KinesisAnalyticsFlinkApplication:
    Type: AWS::KinesisAnalyticsV2::Application
    Properties:
      RuntimeEnvironment: FLINK-1_6
      ServiceExecutionRole: !Sub ${KinesisAnalyticsServiceRole.Arn}
      ApplicationConfiguration:
        ApplicationCodeConfiguration:
          CodeContent:
            S3ContentLocation:
              BucketARN: !Ref FlinkApplicationS3BucketArn
              FileKey: !Ref FlinkApplicationS3Path
          CodeContentType: ZIPFILE
        EnvironmentProperties:
          PropertyGroups:
            - PropertyGroupId: FlinkApplicationProperties
              PropertyMap:
                ElasticsearchEndpoint: !Sub https://${ElasticsearchService.DomainEndpoint}
                EventTime: true
                InputStreamName: !Sub ${KinesisStream}
                Region: !Sub ${AWS::Region}
        FlinkApplicationConfiguration:
          MonitoringConfiguration:
            ConfigurationType: CUSTOM
            LogLevel: INFO
            MetricsLevel: TASK
        ApplicationSnapshotConfiguration:
          SnapshotsEnabled: true