DataStream problem

Hi all Using DataStream, How to implement a message and the same message appears again 10 minutes later? Thanks, Jiazhi

Flink sql problem

Hi all After grouping by users, message A arrives. If message B also arrives later, and the time of message B is less than that of message A within 10 minutes, mark the field in message A with Tag = True. How to achieve this? Thanks Jiazhi

rowtime??????????

Hi ?? DataStreamtableeventTimerowtime??rowtime8??

table rowtime timezome problem

Hi all When DataStream is converted to table, eventTime is converted to rowTime. Rowtime is 8 hours slow. How to solve this problem? Thanks Jiazhi

Table api ??????rowtime??????

??DataStream??Tablerowtime??udtf??sqltableEnv.sql()Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP

EventTime problem

Hi all When I use SQL with UDTF, when I call the tableEnv.sqlQuery () method, I throw the following error: Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before. I used the to_timestamp function

Flink eventTIme????

Hi all When I use SQL with UDTF, when I call the tableEnv.sqlQuery () method, I throw the following error: Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before.I used the to_timestamp function

Flink eventTIme????

Hi all When I use SQL with UDTF, when I call the tableEnv.sqlQuery () method, I throw the following error: Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before.I used the to_timestamp function

slot????

Hi ?? slot1??slot?? ??

slot problem

Hi all Can only one thread run at a time for a slot? Or one slot can run multiple threads in parallel at the same time? Thanks, Jiazhi

????????mysql??????flink????????

DataStreammysql??flinkdemo?? ?? jiazhi

How do i load mysql data into task

Hi all How to use DataStream to load mysql data into the memory of flink task when the task is initialized? Please give me a demo. Thanks, Jiazhi

windowsState() and globalState()

Dear all: How do I use the windowsState() method and the globalState() method in process Windows Function?Can I give a demo? Thanks, Jiazhi

??????????reduce????????

?? ??windowreducereduce??2??reduce Thanks

time window and reduce problem

Deal All I use the reduce operator after the TimeWindow operator, whether to output one element after all elements in the current window have been calculated according to reduce logic?? Thanks Jiazhi

How do i get processingTime in keyedPrcessFounction

Hi all When I get the processingTime in the processElement method of the KeyedProcessFunction, like ctx.timestamp(), which returns null, how do I get the processingTime in processElement methoed? Thanks, Jiazhi

API Performance

Hi all I want to know which performance is faster, the DataStream API or the Table API + SQL. Thanks, Jiazhi

??????ProcessAllWindowFunction??????????????????ValueState????

?? ProcessAllWindowFunction??ValueStateKeydProcessFounctiononTimerProcessAllWindowFunction?? ??

How do I trigger clear custom state in ProcessWindowsFunction

Dear all: How do I clear custom state in ProcessWindowsFunction? Because there is no onTimer method in ProcessAllWindowFunction. Thanks Jiazhi

State 0????????????

ProcessAllWindowFunction0??state?? Thanks

?????? ?????? DataStream????uv????

?? ---- ??:"1193216154"<1193216...@qq.com; :2020??7??9??(??) 10:25 ??:"user-zh"

?????? DataStream????uv????

stateDescriptornull?? ---- ??:"Yun Gao"

Use state problem

Deal all Keyed state (ValueState, ReducingState, ListState, AggregatingState, MapState) Supported in Keyed Stream, meaning only in KeyedProcessFunction? But in practice, I can also use these states in ProcessAllWindowFunction and ProcessWindowFunction. Why? thank you jiazhi

DataStream????uv????

DataStream??apiUV??2 1Tumbling??1Time.days(1)??uv trigger

Flink DataStream ????UV????

DataStream??apiUV??2 1Tumbling??1Time.days(1)??uv trigger

DataStream??state????

Deal all: ??,statettl?? StateTtlConfig ttlConfig = StateTtlConfig .newBuilder(Time.days(1)) .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)