一、前言 本文仅代表作者的个人观点； 本文的内容仅限于技术探讨，不能作为指导生产环境的素材； 本文素材是红帽公司产品技术和手册； 本文分为上篇和下篇两部分，本文是下篇； 二、一个飞机购票程序源码解析
java.lang.NoClassDefFoundError: org/apache/kafka/common/serialization/ByteArrayDeserializer at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09.setDeserializer(FlinkKafkaConsumer09.java:271) at org.apache.flink.streamin
1.首先看到的报错信息org.springframework.jdbc.CannotGetJdbcConnectionException: Could not get JDBC Connection; 怀疑是项目配置的链接数据库的地址或者用户名， 密码错误导致，后仔细核查数据库ip ，端口号，数据库用户名，密码均未发现异常。 2.考虑到1中未排查出异常，故继续往下找，发现javax.net.ssl.SSLHandshakeException: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target，查询了一下错误信息的意义，发现这个应该是缺少认证证书的问题，但是连接数据库并不是通过https连接，怎么会触发证书认证的情况？可以错误日志也没有再提供其他的方向了，这个时候跟程序发现报了mysql的08001的错误码，查询得知代表的是数据库连接时区配置问题，再次检查时区配置，并按社区小伙伴提供的时区配置后问题仍然没有解决。 3.基于2中缺少证书的问题，给自己的tomcat安装了认证证书，但是问题仍然存在 4.问题再次回到1，检查数据库连接，发现原来的数据库连接有参数userSSL=true，这个参数是过去到现在一直存在的，查询参数意义发现如果这个参数开启，需要应用端和服务端同时配置证书，查看mysql服务端
NoSuchMethodException: <init> [class android.content.Context, interface android.util.AttributeSet]..... 就是说自定义View的时候，三大领头重载构造函数要好好写好呐，缺了容易出错。 喏，三个补齐给他，就完事了：
而从Stackoverflow上查找，说是通过PowerMockIgnore忽略掉reflect可以通过，但是Ignore后，同样无法运行
-------------------------因为电脑之前装过 17版本 的 现在安装了19版本，17没有卸载，19的会默认集成17的一些配置
1、错误如下所示，启动flume采集文件到hdfs案例的时候，出现如下所示的错误： 大概是说No channel configured for sink，所以应该是sink哪里配置出现了错误，百度了一下，然后检查了一下自己的配置: 1 18/04/24 08:31:02 WARN conf.FlumeConfiguration: Could not configure sink sink1 due to: No channel configured for sink: sink1 2 org.apac
[20210910 10:16:40.107] [DEBUG] [main] [StreamGraph.java:391][addOperator] Vertex: 2 java.lang.IllegalStateException: No ExecutorFactory found to execute the application. at org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFa
线上有3个 API 网关实例，压力均衡，平稳运行3天后，突然有一个实例，CPU飚高，并且响应时间增加很多，从几十毫秒涨到了几分钟。
APP中需要实现LayoutInflater布局加载器动态加载布局，然而开启程序一运行就闪退。。。
今天我们来聊聊 JEP 403: Strongly Encapsulate JDK Internals。这一条对于使用 JDK 内部 API 的应用场景来讲会比较受影响。
目前想把kafka json格式的埋点数据写入OSS存储，但是参考官网文档出现很多异常内容，总结如下：
书接上文 【Flink实时数仓】需求一：用户属性维表处理-Flink CDC 连接 MySQL 至 Hbase 实验及报错分析http://t.csdn.cn/bk96r 我隔了一天跑Hbase中的数据，发现kafka报错，但是kafka在这个代码段中并没有使用，原因就是我在今天的其他项目中添加的kafka依赖导致了冲突。
将hadoop 3.2.1中自带的guava-27.0-jre.jar拷贝到flink的lib目录下即可。
Flink on yarn 常见错误 1 Retrying connect to server 2 Unable to get ClusterClient status from Application Client 3 Cannot instantiate user function 4 Could not resolve substitution to a value: ${akka.stream.materializer} 5 java.lang.NoClassDefFoundError: org/
在 Spring Boot 中，支持了响应式编程，带来了性能和内存使用方面的优化。
最近做一个项目，项目调试基础库的一个调试工具展示设备信息页面使用WebView。有一个应用集成调试基础库展示内容时出现
昨天的排版并不是很满意，而且每天公众号只能发布一篇文章，近期资料看了很多，需要复习巩固一下，在群里，私聊小伙伴问了很多问题，今天都得到了解决。
SO_TIMEOUT只适用于OIO，对于NIO不适用；使用ReadTimeoutHandler 或者block(Duration)都关闭client端，非reactive的服务端无法感知Terminated，reactive的服务端可以感知到Terminated
遇到的问题是在weblogic环境，应用在上传图片的时候报Could not initialize class sun.awt.X11.XToolkit 错误。
5.重启后的网关进程，立刻请求数量激增，每个实例峰值 2000 qps，闲时每个实例 500 qps，忙时由于有扩容也能保持每个实例在 1000 qps 以内，然后健康检查接口就很长时间没有响应，导致实例不断重启
当我们使用java.util.Date作为实体的日期类型时（JAVA没有DateTime这个类，Date类能够同时表示日期和时间），java.util.Date实际上是能够表示MySQL的三种字段类型：
Java堆唯一的作用就是存储对象实例，只要保证不断创建对象并且对象不被回收，那么对象数量达到最大堆容量限制后就会产生内存溢出异常了。所以测试的时候把堆的大小固定住并且让堆不可扩展即可。测试代码如下
针对目前大家对OOM的类型不太熟悉，那么来总结一下各种OOM出现的情况以及解决方法。把各种OOM的情况列出来，然后逐一进行代码编写复现和提供解决方法。
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
报错日志 org.springframework.dao.InvalidDataAccessApiUsageException: Cannot locate field code on class com.ak47.cms.cms.entity.Tree; nested exception is java.lang.IllegalArgumentException: Cannot locate field code on class com.ak47.cms.cms.entity.Tree at o
在 Android 开发中 , 使用 Jetpack 的 Navigation 组件报如下错误 :
在一个fragment中使用时 时没有什么问题的，但是当有几个界面当时都用到这个地图功能时，就会出现上面这个问题。
这里我们可以手动在idea运行启动配置，Run/Debug Configurations的窗口中
在实时数仓的时候，遇到了 org.apache.kudu.client.NonRecoverableException，搞了好长时间，特此记录一下。
Flink1.13.6 MySQL5.7.27 JDK8 Hadoop3.1.4 集成环境Idea2020
最近一直在写开源小项目，遇到了大大小小的BUG，小BUG也就算了，大BUG（指的是花费很多时间才DEBUG的）需要写一个博客记录一下，避免以后再犯这种错误。 切记，不要因为某些错误，乱导jar包！
在 Flutter 混合开发中 , 开发 Android 与 Flutter 信息交互功能 ;
这个时候如果单线程操作，即正常程序流程解析是不会有问题的； 如果走异步多线程解析文件，主线程已经结束了，临时文件会被清空，这时候再来读取文件就会报错
1/在$HADOOP_HOME/lib/native下面放了2.5.0-native-snappy.tar.gz，这是HDFS存储压缩所需的本地lib包。 cd ~/app/hadoop-2.5.0-cdh5.3.6/lib/native/
配置config server动态刷新时报错， 开始以为时因为加入了bus和mq，结果不是，然后看到后面看到ClassNotFoundException，和我上次出的问题一样，很可能时版本问题，我这次用的spring boot版本:2.1.0，cloud：Finchley.SR2，这个cloud版本应对应2.0的所有，降低boot版本到2.0.9可以；这里还有一个问题，就是如果你使用2.0.4或是2.0.6的spring boot版本后面你使用/actuator/bus-refresh 会报错，而且能正常访问~
org.springframework.orm.hibernate3.HibernateQueryException: unexpected token: where near line 1, column 72
spring-cloud-commons-2.0.0.RC1-sources.jar!/org/springframework/cloud/client/loadbalancer/reactive/LoadBalancerExchangeFilterFunction.java
java9新增这个类的目的是提供一个标准API用于访问当前线程栈，之前只有Throwable::getStackTrace、Thread::getStackTrace以及SecurityManager::getClassContext提供了方法可以获取线程栈。
可以看到提供的内容，对应进行maven pom文件去掉flink-connector-kafka就可以了，引用flink-sql-connector就可以解决这个问题。
apollo是一个非常流行的开源的配置中心项目，这里就不多介绍了。接触过apollo和运行过apollo的人肯定都遇到过启动configService时抛异常了，而且100%会抛一个异常。原因是，在apollo的架构中configService既作为config服务，同时也承载了metaService的功能，所以这个模块，既作为eureka的服务端也是eureka的客户端，这就造成了应用启动时，eurekaServer未完全启动，eurekaClient拉取注册表信息时就抛异常了。不过这个拉取动作是在独立的线程中运行的，独立于启动应用的主线程，所以异常并不影响应用的启动，这个问题也就一直从开源到留到了现在。目前，这个问题已被博主解决，正在合并pr中。
转发请注明原创地址：http://www.cnblogs.com/dongxiao-yang/p/7652337.html
异常代码示例 : 如果收集的元素 it <= 1 , 则检查通过 , 否则当 it > 1 时 会报异常 ;
Flume最早是Cloudera开发的实时日志收集系统，最早的时候Flume的版本称为Flume OG（original generation），随着功能的扩展和代码的重构，随之出现了我们熟知的Flume NG（next generation），后来也捐给了Apache基金会成为了Apache的顶级项目。Apache Flume 是一个分布式、高可靠（事务）、高可用（failover）的用来收集、聚合、转移不同来源的大量日志数据到中央数据仓库的工具。
optimistic locking failed; nested exception is org.hibernate.StaleObjectStateException: Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect)
可以发现，崩溃是由于数据越界导致的，具体崩溃的代码，需要配合mapping文件来定位
序 本文主要研究下java9 opens与exports的区别 open及exports open open module 主要用于解决deep reflection问题，open的作用是表示该模块下的所有的包在runtime都允许deep reflection(包括public及private类型) 但是编译时期，仅仅允许该module中声明过exports的包可以访问，如果没有exports则该包的类在编译时期不可读 opens package 用于声明该模块的指定包在runtime允许使用反射访问 e
最近在提交flink项目example下WordCount.jar批处理任务时遇到以下问题：
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
