sideOutput对于当前处理流中的部分或者全部数据单独输出到另外的流中作用：数据选择​对于当前处理的流可以进行自定义选择然后输出到独立的侧流中异常数据保留对于异常数据，输出到独立的侧流中，进行单独处理。如窗口中过期的延迟数据保留。使用心法可在如下算子中使用（别的方法貌似没有 Context 对象提供）：ProcessFunctionKeyedProcessFunctionCoProcessFu

flink 空闲窗口flink多并行时，如果有窗口中没数据，那么有数据的窗口即使watermark到达了触发边界，barren没对齐，窗口也不会触发计算。这样的空窗口即空闲窗口。可通过设置空闲时间（withIdleness）来使有数据的窗口进行触发。parallellism：2windowSize: 10sforBoundOutofOrderness: 5swithIdleness：10s窗口数据

fileSystemhttps://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/connectors/table/filesystem/CREATE TABLE MyUserTable (column_name1 INT,column_name2 STRING,...part_name1 INT,part_name2 STR

hive UDF 根据ip查询对应地理位置信息hive UDF 根据ip查询对应地理位置信息具体实现源码hive UDF 根据ip查询对应地理位置信息基本原理：ip地址为四段字符串组成，一般同一个子网的ip同属于一个区域。如202.203.78.210/24 和202.203.78.220/24同属于202.203.78.0这个子网 属于云南昆明这个区域。所以为了方便查找我们就可以将ip字符串转为

脆弱的 wordCountStreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());env.addSource(new RichSourceFunction<Tuple2<String, Integer>>(

【代码】spark sql本地测试Demo。

doris 客户端连接Doris 采用 MySQL 协议进行通信，用户可通过 MySQL client 或者 MySQL JDBC连接到 Doris 集群。选择 MySQL client 版本时建议采用5.1 之后的版本，因为 5.1 之前不能支持长度超过 16 个字符的用户名。Doris 内置 root 和 admin 用户，密码默认都为空。启动完 Doris 程序之后，可以通过 root 或

flink BoundedOutOfOrderness对于乱序数据，flink window 可以延迟一定的时间来进行触发,从而规避一定程度的乱序数据影响。如下：如图蓝色窗口大小为10s, 没有设置乱序延迟时间，其中数据为Tuple2<String, timestamp>对于第二个窗口中的黄色框数据 a, 3，和红色框中的数据a,7 , 由于第二个窗口的范围为[10,20），所以其在窗

doris 客户端连接Doris 采用 MySQL 协议进行通信，用户可通过 MySQL client 或者 MySQL JDBC连接到 Doris 集群。选择 MySQL client 版本时建议采用5.1 之后的版本，因为 5.1 之前不能支持长度超过 16 个字符的用户名。Doris 内置 root 和 admin 用户，密码默认都为空。启动完 Doris 程序之后，可以通过 root 或

bug:mybatis-generator-maven-plugin 插件在自动生成代码时配置不当，会生成别的数据库同名数据库表相关内容。原因：使用 mysql-connector-java 8.x 版本，generator 会为MySql中信息数据库(sys, information_schema, performance_schema)的表生成代码，若要避免这种操作，请在 JDBC URL中加