[
https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248712#comment-17248712
]
badqiu commented on FLINK-19146:
--------------------------------
set `table.exec.mini-batch.enabled`=`true`;
set `table.exec.mini-batch.allow-latency`=`5s`;
set `table.exec.mini-batch.size`=`2000`;
CREATE TABLE test_table (
name STRING
) WITH (
'connector'='datagen',
'rows-per-second'='1',
'fields.name.length'='1'
);
select name,count(*)
from test_table
group by name;
this select sql has no output。
modify
set `table.exec.mini-batch.size`=`2`;
will output result;
> createMiniBatchTrigger() use OR ，table.exec.mini-batch.size and
> table.exec.mini-batch.allow-latency
> ----------------------------------------------------------------------------------------------------
>
> Key: FLINK-19146
> URL: https://issues.apache.org/jira/browse/FLINK-19146
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / Runtime
> Affects Versions: 1.11.1
> Reporter: badqiu
> Priority: Major
> Attachments: mini_batch_trigger_by_latency.png,
> mini_batch_trigger_by_size.png
>
>
> Using *or* conditions, you can control the total data delay and improve
> computing performance.
> Increase the batch size to very large, but the data delay is still within the
> set range.
>
>
> table.exec.mini-batch.size is true
> =>
> (table.exec.mini-batch.size or table.exec.mini-batch.allow-latency) is true
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
