??
?? flush ?? mysql
1.11.2??flink
sqlBufferReduceStatementExecutorflush??GenericJdbcSinkFunction
??
----
??:
"user-zh"
??
----
??:
"user-zh"
----
??:
"user-zh"
??sum??mysql??
----
??:
"user-zh"
??
sqlcountcountcount
??hive??count(if(name like '%',1 , null))??flink
sql??count??null
flink1.10.1 blink
??utc??
----
??:
"user-zh"
hi各位，有个问题想请教下：
我想将数据以gz方式写到下游，使用的StreamingFileSink，通过BulkFormat，但是看官方文档里只有OnCheckpointRollingPolicy这一个文件滚动策略，如果我想按照文件大小或者时间滚动该怎么设置呢？
打扰各位。
Hi??flink1.11.1??s3S3plugins/s3-fs-hadoop/flink-s3-fs-hadoop-1.11.1.jar
2020-09-10 22:23:07
java.lang.UnsupportedOperationException: This s3 file system implementation
does not support recoverable writers.
at
blink-planner??temporal
table??
sqlinsert into mysql_sink select C.log_id, C.vic from (select A.log_id,
case when B.cnt0 and A.server0 then B.cnt+1 else A.server end as vic
from (select log_id, server, PROCTIME() as proctime from
sinksink
----
??:"Benchao Li"
11 matches
Mail list logo
