Flink HA Flink HA 的HighAvailabilityMode类中定义了是那种高可用性模式枚举: NONE:非HA模式ZOOKEEPER:基于ZK实现HAFA...
Flink HA Flink HA 的HighAvailabilityMode类中定义了是那种高可用性模式枚举: NONE:非HA模式ZOOKEEPER:基于ZK实现HAFA...
请问下博主,flink版本和scala版本是多少?
Flink 使用之 Oracle CDCFlink 使用介绍相关文档目录 Flink 使用介绍相关文档目录[https://www.jianshu.com/p/74f1990d047c] 准备工作 在这一步需要配置...
@dozenx 额,你是?
开启kerberos后HBASE client配置开启了kerberos之后的集群,用hbase client连接需要增加相应的配置,如果配置不正确很容易出现kerberos认证失败的错误,因为网上搜到的错误原因分析五花八门...
Spark 中最基本的数据抽象是 RDD。 RDD:弹性分布式数据集 (Resilient Distributed DataSet)。 1,RDD 有三个基本特性 这三个特性...
本文咱们使用mysql实现开窗函数row_number() over (partition by xxx,xxx order by xxx),废话不多说,直接开干 准备数据 ...
一般格式 下面介绍创建定时任务的2种方法: 方法一: 方法二: 下面列举一些例子
spark-submit脚本: 定时任务:(可以看我另一篇关于定时任务的博客)
工作中可能会遇到这种问题: 集群的spark工作内存太小,比如只有50个G,如果想让spark工作内存变成100个G,则需要在CM控制台修改以下两个参数
Mysql表center_pub_merchant数据导出为center_pub_merchant.tsv Mysql表center_pub_device数据导出为cente...
SparkRDD转DataFrame 映射的方式 SparkRDD转DataFrame 构造元数据的方式
一、Explode用法 hive wiki对于expolde的解释如下: explode() takes in an array (or a map) as an input...
一、准备hdfs、hive基础集群环境,两台虚机hd01、hd02 二、下载Presto相关安装包: https://repo1.maven.org/maven2/com/f...
@guoqian123 嗯嗯,已经知道了,谢谢博主
开启kerberos后HBASE client配置开启了kerberos之后的集群,用hbase client连接需要增加相应的配置,如果配置不正确很容易出现kerberos认证失败的错误,因为网上搜到的错误原因分析五花八门...
String nsName = "mynamespace"; 请问下,这个是什么名字?
开启kerberos后HBASE client配置开启了kerberos之后的集群,用hbase client连接需要增加相应的配置,如果配置不正确很容易出现kerberos认证失败的错误,因为网上搜到的错误原因分析五花八门...
「简书」作为一款「写作软件」在诞生之初就支持了 Markdown,Markdown 是一种「电子邮件」风格的「标记语言」,我们强烈推荐所有写作者学习和掌握该语言。为什么?可以...