1.10版本无法使用WATERMARK ，报空指针。

Open

#334 opened on Jun 19, 2020 2 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

Assessment

Difficulty: 4/5
Estimated time: 3-5 days
Newbie friendliness: 25/100

Issue type: Bug
Clarity: Mostly clear
Activity status: Stale
Tech stack: java, sql
Domain: stream-processing

Research direction

Start with the issue's CREATE TABLE statement and the CustomerWaterMarkerForLong error from the Flink 1.10 log. Compare the UNIX_TIMESTAMP-derived bigint field and WATERMARK syntax with the supported 1.10 behavior. Done means the reported schema has a complete working WATERMARK example and no longer produces the null-pointer error.

Written by the indexing model from the issue text.

Description

日志样例
{"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 语法案例。实际测试中无法使用

Dominant language: Java
Stars: 2k
Forks: 913
PR merge metrics: No merged PRs in 30d

Contributor guide

No contributing guide indexed for this repository

First steps

Read the whole issue, then the project's contributing guide.
Comment on the issue to say you are picking it up — it saves two people doing the same work.
Fork the repository and make your change on a branch.
Open a pull request that references the issue number.

Similar issues

[BUG] Unified agent on Bedrock Converse with no tools is unusable: an empty `toolConfig` is emitted and Bedrock rejects the request Open

bug untriaged

Difficulty 2/5 1-3 hours Newbie friendliness 84/100

opensearch-project/ml-commons#5094 · Opened Sep 22, 2026
[Bug report] iceberg rest server load_table with refs fails precondition check "Cannot set metadata location with changes to table metadata: %s changes" for snapshots with statistics Open

bug

Difficulty 2/5 1-3 hours Newbie friendliness 85/100

apache/gravitino#13452 · Opened Sep 22, 2026
Support Test Project Creation for New Projects Open

emitter:client:csharp feature

Difficulty 2/5 1-3 hours Newbie friendliness 72/100

microsoft/typespec#12027 · 1 comment · 1 reaction · Opened Sep 22, 2026
Job worker stops polling silently when a poll throws an Error Open

affects/8.10 affects/8.9 component/clients kind/bug likelihood/mid severity/mid

Difficulty 2/5 1-3 hours Newbie friendliness 78/100

camunda/camunda#63825 · Opened Sep 22, 2026
Two open-case totals on one screen: the Programs tile says 15,858 and the nav badge says 15,868 Open

bug frontend maui-pilot

Difficulty 2/5 1-3 hours Newbie friendliness 72/100

Taleef7/workwell#651 · 1 comment · Opened Sep 22, 2026

More Java issues

1.10版本 无法使用WATERMARK ，报空指针。