flinksql sink to sr often fail because of nullpoint

news/2024/11/15 4:37:08/文章来源:https://blog.csdn.net/IT_liuzhiyuan/article/details/132186546

flinksql or DS sink to starrocks often fail because of nullpoint

flink sql 和 flink ds sink starrocks 经常报NullpointException
重新编译代码并上传到flink 集群验证，有效

flink sql 和 flink ds sink starrocks 经常报NullpointException

使用flink-starrocks-connector 版本: flink-connector-starrocks-1.2.6_flink-1.15.jar

在这里插入图片描述

翻阅StarRocksSink 源码 DefaultStreamLoader 类
在这里插入图片描述
解决方案：到github 上查询目前最新的版本中对该bug 修复下载源码查看 DefaultStreamLoader 类

在这里插入图片描述

重新下载源码到本地打包后打包后的 flink-starrocks-connector 版本: flink-connector-starrocks-1.2.7_flink-1.15.jar

重新编译代码并上传到flink 集群验证，有效

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/60864.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

【Spring】（一）Spring设计核心思想

文章目录一、初识 Spring1.1 什么是 Spring1.2 什么是容器1.3 什么是 IoC 二、对 IoC 的深入理解2.1 传统程序开发方式存在的问题2.2 控制反转式程序的开发2.3 对比总结三、对 Spring IoC 的理解四、DI 的概念4.1 什么是 DI4.2 DI 与 IoC的关系一、初识 Spring 1.1 什么是…

Jenkins+Docker+SpringCloud微服务持续集成

JenkinsDockerSpringCloud微服务持续集成 JenkinsDockerSpringCloud持续集成流程说明SpringCloud微服务源码概述本地运行微服务本地部署微服务 Docker安装和Dockerfile制作微服务镜像Harbor镜像仓库安装及使用在Harbor创建用户和项目上传镜像到Harbor从Harbor下载镜像微服务持…

网盘直链下载助手

一、插件介绍 1.介绍这是一款免费开源获取网盘文件真实下载地址的油猴脚本，基于 PCSAPI，支持 Windows，Mac，Linux 等多平台，支持 IDM，XDown，Aria2 等多线程下载工具，支持 JSON-RPC…

linux_常用命令

一、日常使用命令/常用快捷键命令开关机命令 1、shutdown –h now：立刻进行关机 2、shutdown –r now：现在重新启动计算机 3、reboot：现在重新启动计算机 4、su -：切换用户；passwd：修改用户密码 5、logou…

微服务——elasticsearch

初识ES——什么是elasticsearch elasticsearch的发展初识ES——正向索引和倒排索引初识ES——es与mysql的概念对比类比到mysql中是表结构约束概念对比初始ES——安装es和kibana 1.部署单点es 1.1创建网络要安装es容器和kibana容器并让他们之间相连，这里…

idea - 刷新 Git 分支数据 / 命令刷新 Git 分支数据

一、idea - 刷新 Git 分支数据 idea 找到 fetch 选项，重新获取分支数据二、命令刷新 Git 分支数据 git fetch参考链接 1. 远程Gitlab新建的分支在IDEA里不显示

探讨C语言是否仍然满足现代编程需求

在过去的30年里，有人试图通过引入一门新的语言来取代C语言，其中一位被简称为BS的人也持有类似观点。尽管这门新语言在某些方面表现出色，但它并未能完全取代C语言，而是在特定领域发展出自己的优势。此后，又有一家公司决…

数据结构入门：队列

目录文章目录前言 1.队列 1.1 队列的概念及结构 1.2 队列的实现 1.2.1 队列的定义 1.2.2队列的初始化 1.2.3 入队 1.2.4 判空 1.2.5 出队 1.2.6 队头队尾数据 1.2.7 队列长度 1.2.8 队列销毁总结前言队列，作为一种重要的数据结构，在计算机科学中扮演…

ffmpeg 4.4版本对MP4文件进行AES-CTR加密，和流式加密

对于ffmpeg的AES-CTR加密有两种方式，一个是普通的整个视频做加密，另一个是对视频做切片处理，然后进行加密。一、对于普通的加密方式直接使用下面的命令就行 ffmpeg -i animal.mp4 -vcodec copy -acodec copy -encryption_scheme cenc-aes…

力扣hot100刷题记录

二刷hot100，坚持每天打卡！！！Today：2023-8-10 1. 两数之和 // 先求差，再查哈希表 public int[] twoSum(int[] nums, int target) {Map<Integer,Integer> map new HashMap<>();for(int i 0;i&…

【图像去噪的扩散滤波】基于线性扩散滤波、边缘增强线性和非线性各向异性滤波的图像去噪研究（Matlab代码实现）

💥💥💞💞欢迎来到本博客❤️❤️💥💥 🏆博主优势：🌞🌞🌞博客内容尽量做到思维缜密，逻辑清晰，为了方便读者。 ⛳️座右铭&a…

JVM垃圾回收篇-垃圾回收器

JVM垃圾回收篇-垃圾回收器串行垃圾回收器 Serial串行：为单线程环境设计且只使用一个线程进行垃圾回收，会暂停所有用户的线程，所以不适合服务器环境，适用于堆内存小，适合于个人电脑开启串行垃圾回收 -XX:UseSeria…

flinksql sink to sr often fail because of nullpoint

flinksql or DS sink to starrocks often fail because of nullpoint

flink sql 和 flink ds sink starrocks 经常报NullpointException

重新编译代码 并上传到flink 集群 验证，有效

相关文章

重新编译代码并上传到flink 集群验证，有效