本文主要介绍了 如何利用jstack 定位问题，并通过断点了解到flink sql （flinksql）执行慢的原因，重在排查问题的技巧和思路。最终定位到 flink sql （jdbc）执行慢的原因是 因为sql中的 where条件没有下推到数据库执行，而是全量加载数据，在内存里过滤。

本文通过一个具体案例，说明 flink sql 如何实现 connector 加载、source/sink 端操作、数据库连接等。可以帮助大家了解其原理，并在代码中找到落库执行SQL生成逻辑，得到where条件并没有下推到库执行的结论。

本文主要介绍了 如何利用jstack 定位问题，并通过断点了解到flink sql （flinksql）执行慢的原因，重在排查问题的技巧和思路。最终定位到 flink sql （jdbc）执行慢的原因是 因为sql中的 where条件没有下推到数据库执行，而是全量加载数据，在内存里过滤。

最近在开发过程中，由于涉及的库太多，有时候知道关联的列名 或者表名，找不到源库了。所以整理了下面的文章，希望对你有帮助。有用的话记得点赞哟~~~**1、通过表名找到所在库**例子：有一张 STUDENT_BASE_INFO 表，但是库太多了，不知道在哪个库。执行sql：select * from all_tables where table_name = 'STUDENT_BASE_INFO';结

本文通过一个具体案例，说明 flink sql 如何实现 connector 加载、source/sink 端操作、数据库连接等。可以帮助大家了解其原理，并在代码中找到落库执行SQL生成逻辑，得到where条件并没有下推到库执行的结论。

问题背景某天 跑 sparkSQL 的时候，遇到报错：org.apache.spark.SparkException: Job aborted.at org.apache.spark.sql.execution.datasources.FileFormatWriter.write(FileFormatWriter.scala:198)atorg.apache.spark.sql.hive.exec

token单点登入原理及实现过程什么是单点登入（SSO）token单点原理安全性代码演示什么是单点登入（SSO）首先举个例子：对于某个银行系统，本身有开发自己的系统，比如门户之类的。最近有新的新的需求，比如数据分析的业务需求，于是购买了一套数据分析系统、，之后又上线了一套贷款系统等等，如下图。那么用户在在登入操作的时候，就会面临一个问题，多个系统之间是不是需要登入多次呢？比如我从门户页面进入系统，

最近在学习 flink，通过 nc 模拟实时数据。但是在windows下输入 nc -lk 7777 出现如下报错：C:\Users\7371>nc -lk 7777nc: invalid option -- knc -h for help经过一番查找，终于得到解决。windows不同于linux， win+R，cmd 后直接输入nc -l -p 7777即可...

最新开发的业务中，涉及到计算两个经纬度之间的距离。已知A点和B点的 经纬度，计算A点到B点之间的距离。最开始使用的是Haversine公式来进行计算，但上线后出现严重的性能问题，主要原因是业务数据量太大，每天PB级的数据量。因此，需要研究一个更高效便捷的计算方法，下面将介绍Haversine公式和实现代码，以及新的计算公式&代码，并对他们的性能及精度进行分析。