Flink报错java.lang.OutOfMemoryError: Direct buffe...
已解决Flink报错java.lang.OutOfMemoryError: Direct buffer memory.
展开
收起
1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答1. 通过配置项 taskmanager.memory.task.off-heap.size 增大 TM 的 direct memory 大小 2. 如果确认是 Kafka 证书问题，则需要修复 kafka 配置，如下 SSL 根证书下载(https://help.aliyun.com/document_detail/68325.html#section-dge-h2n-pf3) 上传到附加依赖中，添加以下 with 参数 'properties.ssl.endpoint.identification.algorithm' = '', 'properties.security.protocol' = 'SASL_SSL', 'properties.ssl.truststore.location' = '/flink/usrlib/kafka.client.truststore.jks', 'properties.sasl.mechanism' = 'SCRAM-SHA-256', 'properties.sasl.jaas.config' = 'org.apache.flink.kafka.shaded.org.apache.kafka.common.security.scram.ScramLoginModule required username=""***"" password=""***"";' 注意： ● 如果 properties.sasl.mechanism 是 SCRAM-SHA-256 的话，properties.sasl.jaas.config 用org.apache.flink.kafka.shaded.org.apache.kafka.common.security.scram.ScramLoginModule 这个 ● 如果 properties.sasl.mechanism 是 PLAINTEXT 的话，properties.sasl.jaas.config 用 org.apache.flink.kafka.shaded.org.apache.kafka.common.security.plain.PlainLoginModule 这个2024-05-30 18:04:43赞同 1 展开评论 打赏
问答分类：
关联地址：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
