目前可以直接部署到 中标麒麟v7和银河麒麟v10系统中，生产环境已运行一年多时间。
--
该邮件从移动设备发送
--原始邮件--
发件人："PxNew "<15701181132mr@gmail.com;
发送时间：2022年7月23日(星期六) 晚上6:47
收件人："user-zh"
flink1.11 datastream elasticsearch sink 写入es需要账号密码验证，目前支持这种操作吗？
elasticsearch7.0
--
--
李世钰
Mail:m...@lishiyu.cn
TEL:18801236165
Motto:让身边的人快乐，你的身边就
您好，请教您一个问题
flink1.11 sql ddl连接kafka,使用事件事件，无法触发窗口，使用process_time系统时间就可以正常触发
create table kafka_table (
`log_id` string,
event_date timestamp(3),
process_time as PROCTIME(),
ts as event_date,
watermark for ts as ts - interval '1' second
) with (
'connector' = 'kafka',
'topic' = 'kafka_table',
flink版本 flink1.11
flink sql连接kafka
create table kafka_table (
log_id string,
event_time bigint,
process_time as PROCTIME(),
ts as TO_TIMESTAMP(FROM_UNIXTIME(event_time)),
watermark for ts as ts - interval '1' second
) with (
'connector' = 'kafka',
'topic' = 'kafka_table',
1. FLINK版本 flink1.11
2. 使用的是useBlinkPlanner
3.执行sql
SELECT FIRST_VALUE(kafka_table.src_ip) AS
kafka_table_src_ip_0,FIRST_VALUE(kafka_table.dest_ip) AS
kafka_table_dest_ip_0,HOP_START(kafka_table.process_time, INTERVAL '30'
SECOND(2), INTERVAL '2' MINUTE(1)) AS
关于flink1.11 新版本使用dataStreamEnv.execute 和tableEnv.execute出现No operators defined
in streaming topology. Cannot generate StreamGraph.的问题
-| 程序内部使用Table API同时也有 Table转为 Datastream的场景。
-|程序内部有使用flinksql 读写kafka，从而执行sqlUpdate
尝试使用新版api 只使用tableEnv.executeSql 从而不加dataStreamEnv.execute
