id}
# singnal shutdown does`t work
yarn -signal #{container id} GRACEFUL_SHUTDOWN
---
Best,
WuKong
group_id',
'connector' = 'kafka',
'format' = 'json',
'scan.startup.mode' = 'group-offsets',
'properties.bootstrap.servers' = '127.0.0.1:9092'
);
flink sql :
select * from rtdw_db.kafka_table kt left join dim_db.dim_table FOR
SYS
hbase table (must
implement own hbase secondary connectors ？)
---
Best,
WuKong
hi all:
anyone know some project can auto convert DB Table Schema(like Mysql create
table ) to Flink Schema(org.apache.flink.table.api.Schema) tools ，I want
implment dynamic generate Flink Table Schema
---
Best,
WuKong
Hi all:
I have two Flink SQL , the same source from Kafka, and one SQL sink data
into Tidb ,another one SQL sink Kafka to notify downstream system, how can I
control the sink order , I wish If source Kafka data come, first sink Tidb and
after that sink Kafka .
---
Best,
WuKong
