[jira] [Created] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-09-07 Thread badqiu (Jira)
badqiu created FLINK-19146: -- Summary: 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

[jira] [Commented] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-09-07 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17191534#comment-17191534 ] badqiu commented on FLINK-19146: My test result is not like this.   search result : *trigger by size* 

[jira] [Updated] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-09-07 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] badqiu updated FLINK-19146: --- Attachment: mini_batch_trigger_by_size.png mini_batch_trigger_by_latency.png >

[jira] [Commented] (FLINK-19048) support line format for table connector

2020-08-26 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185081#comment-17185081 ] badqiu commented on FLINK-19048:  这个啥时候支持呢? 用这个 + UDF解析数据方便很多啊。 > support line format for table

[jira] [Updated] (FLINK-19048) support line format for table connector

2020-08-25 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] badqiu updated FLINK-19048: --- Summary: support line format for table connector (was: suuport line format for table connector) > support

[jira] [Created] (FLINK-19048) suuport line format for table connector

2020-08-25 Thread badqiu (Jira)
badqiu created FLINK-19048: -- Summary: suuport line format for table connector Key: FLINK-19048 URL: https://issues.apache.org/jira/browse/FLINK-19048 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-19390) mysql jdbc join error java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long

2020-09-24 Thread badqiu (Jira)
badqiu created FLINK-19390: -- Summary: mysql jdbc join error java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long Key: FLINK-19390 URL: https://issues.apache.org/jira/browse/FLINK-19390

[jira] [Commented] (FLINK-19390) mysql jdbc join error java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long

2020-09-24 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201448#comment-17201448 ] badqiu commented on FLINK-19390: yes, But why use BigInteger, convert it to avoid errors。 > mysql jdbc

[jira] [Commented] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-12-10 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247717#comment-17247717 ] badqiu commented on FLINK-19146: As you said, it seems to work. But the actual test found no effect.

[jira] [Commented] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-12-10 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247607#comment-17247607 ] badqiu commented on FLINK-19146: This problem is repeated if the output result set is small. >

[jira] [Commented] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-12-13 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17248712#comment-17248712 ] badqiu commented on FLINK-19146: set `table.exec.mini-batch.enabled`=`true`; set

[jira] [Comment Edited] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-12-13 Thread badqiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17248712#comment-17248712 ] badqiu edited comment on FLINK-19146 at 12/14/20, 2:00 AM: --- set