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

[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248712#comment-17248712 ] badqiu edited comment on FLINK-19146 at 12/14/20, 2:00 AM: --- se

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

[ 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.

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

[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247717#comment-17247717 ] badqiu commented on FLINK-19146: As you said, it seems to work. But the actual test foun

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

[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247607#comment-17247607 ] badqiu commented on FLINK-19146: This problem is repeated if the output result set is sm

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

[ https://issues.apache.org/jira/browse/FLINK-19390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201448#comment-17201448 ] badqiu commented on FLINK-19390: yes, But why use BigInteger, convert it to avoid errors

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

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-19146) createMiniBatchTrigger() use OR ，table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191534#comment-17191534 ] badqiu commented on FLINK-19146: My test result is not like this.   search result : *t

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

[ 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 > createMiniBat

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

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-19048) support line format for table connector

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

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

[ 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

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