If (!params.has("source") || !params.has("sink") || !params.has("transform")) StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env) StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment() Įnv.getConfig().setGlobalJobParameters(params) Įnv.getConfig().setRestartStrategy(RestartStrategies.fixedDelayRestart(4, 300000)) Įnv.setRuntimeMode(RuntimeExecutionMode.STREAMING) env.getCheckpointConfig().enableExternalizedCheckpoints(_ON_CANCELLATION) WHERE logType='operation' and (componentId='a' or componentId='b' or componentId='c' or componentId='d' )įinal ParameterTool params = omArgs(args) SELECT uuid() as id ,'22' as rule_key ,'4 or condition test' as rule_name ,2 as metric_threshold ,0 as audit_status ,0 as audit_comment_num ,window_start,window_end ,count as metric_countįROM TABLE(TUMBLE(TABLE source22, DESCRIPTOR(ts), INTERVAL '10' Second)) WATERMARK FOR ts AS ts - INTERVAL '10'second Ts as TO_TIMESTAMP(`timestamp`,'yyyy-MM-dd HH:mm:ss.SSS'), program.ProgramInvocationException: The main method caused an error: Currently Flink doesn't support individual window table-valued function TUMBLE(time_col= , size= ). The admin told me that it should be a BUG and suggested starting a issue I have asked for advice from offical community DingDing Group and wechat Group, I have tried more situations,they worked diffrent,Īnd it works well to add a true condition before an or condition,for example: , is OK,īut when or is more than 3 ,like is not OK In most condition,it works well (where clause is simple or without an or operator)īut when i add some conditions with or operator in where clause, the submit go with a exception, and even more surprising is that Then i submit the job to the standalone with rest interface of The package is downloaded from official website: I am working with a standalone deployment of flink-1.14.0-bin-scala_2.11
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |