1.10版本 无法使用WATERMARK ，报空指针。
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Idoneità per principianti
- 25/100
- Tipo di issue
- Bug
- Chiarezza
- Abbastanza chiara
- Stato di attività
- Ferma
- Ambito
- stream-processing
Direzione di ricerca
Iniziare con l’istruzione CREATE TABLE dell’issue e l’errore CustomerWaterMarkerForLong dal log di Flink 1.10. Confrontare il campo bigint derivato da UNIX_TIMESTAMP e la sintassi WATERMARK con il comportamento supportato in 1.10. Il lavoro è completato quando lo schema segnalato contiene un esempio WATERMARK completo e funzionante e non produce più l’errore di puntatore nullo.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
日志样例
{"time":"2020-06-17 23:00:01.211","pushid":"pushback_send-BC110-12392212311","app":"mm"}
由于时间序列是bigint类型，用UNIX_TIMESTAMP进行转换
Flink运行日志报错：
ERROR com.dtstack.flink.sql.watermarker.CustomerWaterMarkerForLong -
java.lang.NullPointerException
建表语句：
CREATE TABLE MyTable (
time varchar ,
pushid varchar ,
app varchar ,
UNIX_TIMESTAMP(time, 'yyyy-MM-dd HH:mm:ss')*1000 bigint AS xctime ,
WATERMARK FOR xctime AS withOffset( xctime , 1000)
)
WITH (
type='kafka11',
bootstrapServers='kafka:9092',
offsetReset='latest',
topic='test_1',
groupId='flink_sql',
parallelism='4',
timezone='Asia/Shanghai',
topicIsPattern ='false',
sourcedatatype ='dt_nest'
);
CREATE TABLE MyResult(
app VARCHAR,
cnt BIGINT,
wStart timestamp
)WITH(
type ='elasticsearch6',
address ='eshost:9200',
cluster='bigdata-es5.6',
estype ='date',
index ='MyResult',
parallelism ='1',
id='0'
);
insert into MyResult
select
d.app ,
count(d.pushid) cnt ,
TUMBLE_START(d.ROWTIME, INTERVAL '3' SECOND) as wStart
from
MyTable as d
group by d.app,TUMBLE(d.ROWTIME, INTERVAL '3' SECOND);
可否提供一份完整的1.10版本 WATERMARK 语法案例。实际测试中无法使用
- Lingua principale
- Java
- Stelle
- 2k
- Fork
- 913
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Guida per i contributori
Nessuna guida per i contributori indicizzata per questo repository
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di DTStack/flinkStreamSQL
-
Difficoltà 5/5 Più di una settimana Idoneità per principianti 20/100
DTStack/flinkStreamSQL#467 · 1 commento ·
-
Difficoltà 4/5 3-5 giorni Idoneità per principianti 25/100
DTStack/flinkStreamSQL#437 · 3 commenti ·
-
Difficoltà 3/5 1-2 giorni Idoneità per principianti 38/100
DTStack/flinkStreamSQL#432 · 1 commento ·
-
Difficoltà 5/5 Più di una settimana Idoneità per principianti 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Aperta
Difficoltà 5/5 Più di una settimana Idoneità per principianti 15/100
DTStack/flinkStreamSQL#430 · 1 commento ·
Tutte le issue di DTStack/flinkStreamSQL
Issue simili
-
bug untriaged
Difficoltà 2/5 1-3 ore Idoneità per principianti 84/100
opensearch-project/ml-commons#5094 ·
-
bug
Difficoltà 2/5 1-3 ore Idoneità per principianti 85/100
-
emitter:client:csharp feature
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
-
affects/8.10 affects/8.9 component/clients kind/bug likelihood/mid severity/mid
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
-
Two open-case totals on one screen: the Programs tile says 15,858 and the nav badge says 15,868 Apertabug frontend maui-pilot
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100