blob: 0d95dc7e9a441cc01d27388454868b67d0905d1b [file] [log] [blame]
################################################################################
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
################################################################################
apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
metadata:
name: autoscaling-dynamic
spec:
image: autoscaling-example
flinkVersion: v1_20
flinkConfiguration:
job.autoscaler:
enabled: true
stabilization.interval: 1m
metrics.window: 15m
utilization.target: 0.5
target.utilization.boundary: 0.3
pipeline.max-parallelism: 32
taskmanager.numberOfTaskSlots: 4
serviceAccount: flink
jobManager:
resource:
memory: "2048m"
cpu: 0.5
taskManager:
resource:
memory: "2048m"
cpu: 1
podTemplate:
spec:
containers:
- name: flink-main-container
job:
jarURI: local:///opt/flink/usrlib/autoscaling.jar
entryClass: autoscaling.LoadSimulationPipeline
parallelism: 1
upgradeMode: stateless
args:
- --maxLoadPerTask "1;2;4;8;16;\n16;8;4;2;1\n8;4;16;1;2" --repeatsAfterMinutes "60"