简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
1.指令df -h2.演示该指令可查看:空间大小、已用空间、可用空间、占用比例以及挂载位置
1.指令ps -aux:查看进程|:管道符grep:过滤2.实操演示
1.docker指令docker ps该指令用来显示当前运行的所有容器,包含容器ID 状态 端口等信息。2.实操演示
1.场景在实时流处理工程里,既有spark代码,又有kafka代码,二者之间的依赖,依赖的依赖,把idea搞蒙了。依赖也正确写了,就是找不到类,清除缓存反复加载,也解决不了。Caused by: java.lang.ClassNotFoundException。。。。2.代码如下import com.tk.dwd.etltools.DateJudge;import org.apache.kafka
1.问题描述新启用了一个集群,正常启动kafka和zookeeper后,jps查看所有节点kafka和zookeeper都正常工作。当使用命令行创建topic时./kafka-topics.sh --zookeeper linux1:2181 --create --replication-factor 3 --partitions 1 --topic test-topic,报了如下错误:Error
1.指令[root@hadoop101 kafka_2.11-2.4.0]# bin/kafka-topics.sh --zookeeper hadoop102:2181--create --replication-factor 2 --partitions 10--topic course_learn2.参数解读kafka-topics.sh:kafka自带主题相关操作shell脚本–zooke
1.报错场景加载数据[starcross@app1 FLink-test-LT]$ curl --location-trusted -u root:aba -T 'data_2022-04-11.csv' -H "label:testdoris201" -H "column_separator:," -XPUT http://10.22.33.69:8030/api/os/ws/_stream_l
1.指令cd ..2.实操演示
代码:package com.atguigu.tabletestimport com.atguigu.apitest.SensorReadingimport org.apache.flink.streaming.api.scala._import org.apache.flink.table.api.{DataTypes, Table}import org.apache.flink.table.a