flinkLocal DB files directory XXX
does not exist and cannot be created
??
.keyBy.window(TumblingEventTimeWindows.of(Time.minutes(1))).allowedLateness(Time.hours(1)).aggregate(new
AggregateFunction,new ProcessWindowFunctionBloomFilter)
kafka0.10.1.1??flink1.10.1
??
??KeyedProcessFunctionProcessWindowFunction.
----
??:
"user-zh"
1224
----
??:
"user-zh"
1224
--
??:
"user-zh"
??v1.10.1
----
??:
&q
er-zh"
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/cli.html
????~
x <35907...@qq.com ??2020??9??3?? 11:30??
/flink/flink-1.10.1/bin/flink cancel -s
hdfs://nameservice1/user/flink_1.10.1/flink-savepoints
f95e51fd12a83907b6ca8c52
/flink/flink-1.10.1/bin/flink cancel -s
hdfs://nameservice1/user/flink_1.10.1/flink-savepoints
f95e51fd12a83907b6ca8c52eb2614ae -yid application_1583831804206_1106301
Unrecognized option: -yid
??8??
.window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8)))
----
??:
&q
10??1??.window(TumblingEventTimeWindows.of(Time.minutes(10))).trigger(ContinuousEventTimeTrigger.of(Time.minutes(1)))10
----
UV??MapStateBloomFilter??,checkpoint??bloomMapState
ProcessWindowFunction??clearenv.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)??
.window(TumblingEventTimeWindows.of(Time.days(1)))
您说的这种方式，V1.10.1 不支持吧，我看参数只有一个String类型的
void sqlUpdate(String stmt);
--原始邮件--
发件人:"seeksst"https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/query_configuration.html#idle-state-retention-time
gt; gt; x 35907418@qq.comamp;gt; 于2
ntion-time
x <35907...@qq.comgt; ??2020??7??6?? 11:15??
gt; ??1.10.1??sinkwindow??count
gt; distinct??window??count
gt;
distinct??windowgroupamp;nbsp;DATE
/dev/table/streaming/query_configuration.html#idle-state-retention-time
x <35907...@qq.com ??2020??7??6?? 11:15??
??1.10.1??sinkwindow??count
distinct??window??count
distinct???
LECT _1,MAX(_2)
FROM $totaluvTabTmp
GROUP BY _1
""")
----
??:"Benchao Li"https://issues.apache.org/jira/browse/FLINK-17942
x <35907...@qq.com ??2020??7??3?? 4:34??
checkpoint???
apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html
gt; [2]
gt;
gt;
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html
gt;
gt; x <35907...@qq.comamp;gt; ??2020??6??17?? 11:14??
gt
LECT _1,MAX(_2)
FROM $res
GROUP BY _1
""")
----
??:"Jark Wu"https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html
x <35907...@qq.
----
??:"Jark Wu"https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html
enchao Li"https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html
x <35907...@qq.com ??2020??6??17?? 11:14??
??0??UV??UV??
CREATE VIEW uv_per_10min AS
SELECT
MAX(DATE_FORMAT(proctime, '-MM-dd HH:mm:00'))OVER w AS
time_str,
COUNT(DISTINCT user_id) OVER w AS uv
FROM user_behavior
WINDOW w AS (ORDER BY proctime
23 matches
Mail list logo
