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

时间戳转日期、日期时间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

我们通过Flink的执行UI界面可以看到两个参数 ：JVM Heap Size 和Flink Managed Memory两个内存，那我们来看一下是如何算的。JVM Heap Size：也是实际我们Task Manager实际可用的内存。那我们先算出TM可以用的总内存，包括堆内和堆外内存以我们本次测试程序为例：TM总内存：total-taskManager-memory=1536- max[600

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