logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Postgresql中常用的时间戳与日期的相互转换

时间戳转日期、日期时间1.不带时区的时间格式。我开发中经常用的select to_char(to_timestamp(1628088734), 'yyyy-mm-dd hh24:mi:ss')如果想带毫秒:格式化为:'yyyy-mm-dd hh24:mi:ss.us2.带时区的select to_timestamp(1628088734)3.直接转成日期不带时间select to_timestam

#数据仓库#数据库开发#etl工程师
Flink Caused by: org.apache.flink.runtime.JobException:错误

这里写自定义目录标题欢迎使用Markdown编辑器新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注脚注释也是必不可少的KaTeX数学公式新的甘特图功能,丰富你的文章UML 图表FLowchart流程图导出与导入导出导入欢迎使用Mar

#flink#java
flink状态,对象重用,触发器,数据覆盖相关问题

遇到的问题对于以上代码,我们进行keyby之后,我们new 了对象,我们会以为里面所有的数据都是独一份,和别的key是隔离的。所以利索当然的:这个类型对象的属性:ExitLessonCountMessage有classId,lessonId,studentId 我们也会认为是独一份和别的keyby之后的数据不重用。当我们入下图我们在定时器触发的时候。用了classId,lessonId,stude

#flink#大数据
SpringCloud Nacos 配置注册中心报错 Could not resolve placeholder xxx in value

我的需求是实时加载nacos里面的数据如下:代码中也进行了设置但是启动就会报错修改方法:修改nacos-config-spring-boot-starter的版本为0.2.4即可运行成功修改前:<dependency><groupId>com.alibaba.boot</groupId><artifactId>nacos-config-spring-

#java#eureka#spring boot
Maven maven-compiler-plugin:3.1:compile (default-compile) 或者 JDK无效版本。

对于以上报错分为两种情况:第一种:Fatal error compiling: 无效的目标发行版: 1.8 解决办法这种问题需要你在你的pom文件中加两点就可以解决:第一个点:<properties><java.version>1.8</java.version><!-- 编译时的编码 --><maven.compiler.source>

#maven
Flink Caused by:org.apache.flink.streaming.connectors.kafka.internal.Handover$ClosedException

Flink程序从kafka中读取数据进行计算,FLink程序一启动就报以下错误,看到错误很懵逼。加班到9点没解决,第二天提前来半小时,把如下错误信息又看了一遍。具体错误如下:错误信息1.20/12/17 09:31:07 WARN NetworkClient: [Consumer clientId=consumer-14, groupId=qa_topic_flink_group] Error c

#flink
kafka的两种消费点位设置

flinksql kafka hudi kafka消费方式

文章图片
#kafka#分布式#flink
currentServerAddr:http://localhost:8848, err : Connection refused (Connection refused)

当我们把系统代码部署到服务器上的时候会出现的问题,当我们在本地开发的时候是不会出现问题的。因为我们本地开发的时候基本上nacos地址就是localhost出现问题的日志如下:nohup: ignoring input2022-02-24 14:50:25.598INFO 13070 --- [main] c.a.b.n.c.u.NacosConfigPropertiesUtils: nacosCo

#http#java#spring cloud
到底了