240 发简信
IP属地:浙江
  • FlinkSQL的痛点

    现在FlinkSQL可以source创建一张表,也可以sink也创建一张表 然后直接aggTable1.insertInto("out"); 但...

  • Scala解析JSON

    package com.mlamp.test_json /** * @Author: DaChun777 * @Date: 2021/12/8 ...

  • Spark读取Hive数据

    依赖如下: <dependencies> <!-- mysql --> <dependency> <groupId>mys...

  • Maven明明导入了依赖但是运行报错

    我在运行flink程序时候,就是一个table程序,在编译时候以及写代码都不报错,然后运行就报错少依赖, 卧槽,而且这个依赖这个类我都能够找到,...

  • MySQL获取毫秒值

    select time_to_sec(now()), now(), current_timestamp(), replace(unix_time...

  • Resize,w 360,h 240
    谷歌Octotree插件下载

    推荐一个Github上查看源代码的浏览器插件Octotree 网址:https://pictureknow.com/extensions(偶然发...

  • Resize,w 360,h 240
    Cannot request memory (Xms 0 kb, Xmx 0 kb) from system for job HDFSjob, sleep for 60 secs and ret...

    场景,执行azkaban时候,一个简单的hdfs查询,看任务日志卡主 然后找到看azkaban界面找到日志 然后查看报错 github解决办法 ...

  • 模式匹配

    def say(name:String) = namematch {case "YuiHatano" =>println("波多野结衣")cas...

  • hdfs.DFSClient: DataStreamer Exception org.apache.hadoop.ipc.RemoteException(java.io.IOException)...

    hdfs.DFSClient: DataStreamer Exception org.apache.hadoop.ipc.RemoteExcep...

个人介绍
简书不能搜索文章真杀币