logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

zeppline 连接flink 1.17报错

重新编译zepplin代码,适配当前的flink版本(验证中)

文章图片
#flink#pycharm#大数据
Flink CDC (session模式)

2、配置变更(application在session起来后再调整,客户端配置)1、相关的CDC包需要移动到flink home。

文章图片
#flink#大数据
Flink cdc正确打开方式(flink on yarn)

3、oracle驱动缺失, on yarn缺失的jar需要拷贝到#FLINK_HOME/lib/1、Flink on yarn模式下,flink cdc需要先启动yarn-session模式。2、启动之后进行正常测试。

文章图片
#flink#大数据#前端
deepseek 私域知识库搭建(小白教程)

使用 Streamlit,您可以轻松为 RAG 智能体创建交互式聊天界面。以下是一个简单的 Python 示例,展示如何构建 DeepSeek RAG 聊天机器人。安装超时可以使用下面的方式进行安装。

文章图片
#python
ds 启动flink 任务报错

Flink 总内存taskmanager.memory.flink.sizejobmanager.memory.flink.size。进程总内存taskmanager.memory.process.sizejobmanager.memory.process.size。配置项TaskManager 配置参数JobManager 配置参数。Flink 总内存和进程总内存配置冲突,移除默认conf配置中

文章图片
#flink#大数据
kafka 3.x 配置kerbos

第三步,准备 kafka-server-kerberos-start.sh 文件,添加 Kerberos 认证配置。2.3 准备 kafka-server-kerberos-start.sh 文件,添加 Kerberos 认证配置。拷贝 bin/kafka-server-start.sh 脚本,命名为 kafka-server-kerberos-start.sh,编辑最后一行,在最后一行代码之前,

文章图片
#kafka#分布式
spark连接metastore(kerbors)揭秘

1、hivemeta开启meta后,spark-sql执行报错:解决方案:

文章图片
#spark#前端#大数据
dolphinscheduler 3.2.1 如何访问开启kerbos的hadoop集群

对于api-server/conf/common.properties 进行配置变更。配置后文件管理和资源管理默认会使用hdfs分布式存储。

文章图片
#hadoop#大数据#分布式
    共 14 条
  • 1
  • 2
  • 请选择