[
https://issues.apache.org/jira/browse/FLINK-22938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhagi updated FLINK-22938:
--------------------------
Attachment: flink-taskmanager-6c6d45979-n8vhb.log
flink-jobmanager-59fc59d748-668sc.log
> Slot request bulk is not fulfillable! Could not allocate the required slot
> within slot request timeout
> ------------------------------------------------------------------------------------------------------
>
> Key: FLINK-22938
> URL: https://issues.apache.org/jira/browse/FLINK-22938
> Project: Flink
> Issue Type: Bug
> Components: Deployment / Kubernetes
> Affects Versions: 1.12.4
> Reporter: Bhagi
> Priority: Major
> Attachments: flink-jobmanager-59fc59d748-668sc.log,
> flink-taskmanager-6c6d45979-n8vhb.log
>
>
> Hi team,
> I tested cluster upgrade from Flink Version 1.12.4 to 1.13.1 ,due to 1 job
> issues latest version cluster went into crashloopbackoff with error. hence i
> degraded to old cluster version. from latest upgraded version 1.13.1 to
> 1.12.4 it was successful. But all job executions are failed state.
> with following error."Slot request bulk is not fulfillable! Could not
> allocate the required slot within slot request ".please find the log.
> flink@flink-jobmanager-657cb5d847-5b579:~$ cat conf/flink-conf.yaml
> taskmanager.numberOfTaskSlots: 2
> jobmanager.rpc.address: flink-jobmanager
> blob.server.port: 6124
> jobmanager.rpc.port: 6123
> taskmanager.rpc.port: 6122
> queryable-state.proxy.ports: 6125
> jobmanager.memory.process.size: 1600m
> taskmanager.memory.process.size: 1728m
> parallelism.default: 2
> rest.connection-timeout: 25000
> web.log.path: /opt/flink/log/output.log
> taskmanager.log.path: /opt/flink/log/output.log
> state.backend: rocksdb
> state.checkpoints.dir: file:///persistent/flinkData/checkpoints
> state.backend.rocksdb.log.dir: /persistent/flinkData/rocksdb/logging/
> state.savepoints.dir: file:///persistent/flinkData/savepoints
> state.backend.incremental: true
> state.checkpoints.num-retained: 1
> web.upload.dir: /persistent/flinkData
> classloader.resolve-order: parent-first
> kubernetes.cluster-id: 222
> kubernetes.namespace: flink-mcd
> high-availability:
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory
> high-availability.storageDir: file:///persistent/flinkData/checkpoints
> jobmanager.archive.fs.dir: file:///persistent/flinkData/completed-jobs
> historyserver.archive.fs.refresh-interval: 10000
> historyserver.archive.fs.dir: file:///persistent/flinkData/completed-jobs
> metrics.reporters: prom
> metrics.reporter.prom.class:
> org.apache.flink.metrics.prometheus.PrometheusReporter
> metrics.reporter.prom.port: 9090
> akka.framesize: 10485760b
> flink@flink-jobmanager-657cb5d847-5b579:~$
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
