hbtszyt

你好，请问eventInputDT是定义的数据源吗？如果我想从mysql获取数据，来定时或者根据窗口内的数据条数触发呢

flink 自定义触发器 定时或达到数量触发

flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。如果默认触发器不适合需求，我们就需要自定...

利伊奥克儿

5769 4 7

hbtszyt

不错

数据治理篇-元数据: datahub概述

前言. 元数据是数据治理的灵魂 1. 元数据之于数据治理 数据治理是一个庞大的系统，其中主要包括数据管控，数据质量，数据安全，数据标准。a) 数据管控：每一项数据变更都能得到...

larluo_罗浩

29115 7 15

hbtszyt

参考：https://blog.csdn.net/CPP_MAYIBO/article/details/88085414 最近发现好多小伙伴提交的sql质量不是太好，通过hu...

hbtszyt

==================针对线上使用场景主要做了以下操作================== jvm调整 es初始化索引参数修改 "refresh_interva...

hbtszyt

遇到一样的嗯题

Missing required property 'azkaban.native.lib'问题

解决方法 在编译好的 azkaban-solo-server 中将plugins/jobtypes/commonprivate.properties连带目录直接拷贝到azka...

尼小摩

4841 2 0

hbtszyt

Clickhouse是一个用于联机分析处理（OLAP）的列式数据库管理系统（columnar DBMS）。传统数据库在数据大小比较小，索引大小适合内存，数据缓存命中率足够高的...

hbtszyt

yum install https://s3-us-west-2.amazonaws.com/grafana-releases/release/grafana-5.3.2-1...

hbtszyt

出现问题： 1.Too many open files 2.java.lang.OutOfMemoryError thrown from the UncaughtExcept...

hbtszyt

lsof -n|awk '{print $2}'|sort|uniq -c|sort -nr | grep 4025

hbtszyt

前言： 上手kafka已有2年的时间，我们的数据处理量也从最初的300g/day发展到今天的T量级在这个过程中也踩了不少坑，在这里分享出来和大家共勉。 一、硬件考量 1.1、...

hbtszyt

ips=(10.1.1.1 10.1.1.2 ) password="yourpasswd" for ip in ${ips[@]} do echo $ip sshp...