[jira] [Commented] (FLINK-18875) DESCRIBE table can return the table properties

[ https://issues.apache.org/jira/browse/FLINK-18875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174323#comment-17174323 ] Kaibo Zhou commented on FLINK-18875: Good, 'SHOW CREATE TABLE' works for me. > DESCRIBE table can

[jira] [Created] (FLINK-18875) DESCRIBE table can return the table properties

Kaibo Zhou created FLINK-18875: -- Summary: DESCRIBE table can return the table properties Key: FLINK-18875 URL: https://issues.apache.org/jira/browse/FLINK-18875 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13550) Support for CPU FlameGraphs in new web UI

[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006031#comment-17006031 ] Kaibo Zhou commented on FLINK-13550: Hi, [~dmvk] Thank you for your work. I'm interested in this

[jira] [Comment Edited] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

[ https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005272#comment-17005272 ] Kaibo Zhou edited comment on FLINK-15419 at 12/30/19 12:02 PM: --- Hi 

[jira] [Commented] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

[ https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005272#comment-17005272 ] Kaibo Zhou commented on FLINK-15419: Hi  [~baijingjing7449], thank you for sharing the experience.

[jira] [Created] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

Kaibo Zhou created FLINK-15419: -- Summary: Validate SQL syntax not need to depend on connector jar Key: FLINK-15419 URL: https://issues.apache.org/jira/browse/FLINK-15419 Project: Flink Issue

[jira] [Commented] (FLINK-14393) add an option to enable/disable cancel job in web ui

[ https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002689#comment-17002689 ] Kaibo Zhou commented on FLINK-14393: This problem has been around for a long time. I think this

[jira] [Updated] (FLINK-13779) PrometheusPushGatewayReporter support push metrics with groupingKey

[ https://issues.apache.org/jira/browse/FLINK-13779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-13779: --- Description: The Prometheus push gateway java SDK support send metrics with _groupingKey_, see

[jira] [Commented] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911995#comment-16911995 ] Kaibo Zhou commented on FLINK-13787: hi, [~lamber-ken]  Thank you for your reminder, this

[jira] [Comment Edited] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910508#comment-16910508 ] Kaibo Zhou edited comment on FLINK-13787 at 8/20/19 9:44 AM: - I did some

[jira] [Comment Edited] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910508#comment-16910508 ] Kaibo Zhou edited comment on FLINK-13787 at 8/20/19 9:03 AM: - I did some

[jira] [Updated] (FLINK-13779) PrometheusPushGatewayReporter support push metrics with groupingKey

[ https://issues.apache.org/jira/browse/FLINK-13779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-13779: --- Description: The Prometheus push gateway java SDK support send metrics with _groupingKey_, see

[jira] [Commented] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910508#comment-16910508 ] Kaibo Zhou commented on FLINK-13787: I did some investigate, the reason is that flink's jobmanager's

[jira] [Updated] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-13787: --- Description: I have run a flink job on kubernetes and use PrometheusPushGatewayReporter, I can see

[jira] [Created] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

Kaibo Zhou created FLINK-13787: -- Summary: PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes Key: FLINK-13787 URL: https://issues.apache.org/jira/browse/FLINK-13787

[jira] [Commented] (FLINK-13779) PrometheusPushGatewayReporter support push metrics with groupingKey

[ https://issues.apache.org/jira/browse/FLINK-13779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910473#comment-16910473 ] Kaibo Zhou commented on FLINK-13779: Hi [~Zentol] I have implemented it on my local and have done

[jira] [Updated] (FLINK-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself

[ https://issues.apache.org/jira/browse/FLINK-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-7209: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-6544 > Support DataView in Java and

[jira] [Updated] (FLINK-7207) Support getAccumulatorType when use DataView

[ https://issues.apache.org/jira/browse/FLINK-7207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-7207: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-6544 > Support getAccumulatorType when

[jira] [Updated] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-7208: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-6544 > Refactor build-in

[jira] [Updated] (FLINK-7206) Implementation of DataView to support state access for UDAGG

[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-7206: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-6544 > Implementation of DataView to

[jira] [Created] (FLINK-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself

Kaibo Zhou created FLINK-7209: - Summary: Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself Key: FLINK-7209 URL:

[jira] [Created] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

Kaibo Zhou created FLINK-7208: - Summary: Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView Key: FLINK-7208 URL: https://issues.apache.org/jira/browse/FLINK-7208

[jira] [Created] (FLINK-7207) Support getAccumulatorType when use DataView

Kaibo Zhou created FLINK-7207: - Summary: Support getAccumulatorType when use DataView Key: FLINK-7207 URL: https://issues.apache.org/jira/browse/FLINK-7207 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-7206) Implementation of DataView to support state access for UDAGG

[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-7206: -- Description: Implementation of MapView and ListView to support state access for UDAGG. >

[jira] [Updated] (FLINK-7206) Implementation of DataView to support state access for UDAGG

[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-7206: -- Environment: (was: Implementation of MapView and ListView to support state access for UDAGG.) >

[jira] [Created] (FLINK-7206) Implementation of DataView to support state access for UDAGG

Kaibo Zhou created FLINK-7206: - Summary: Implementation of DataView to support state access for UDAGG Key: FLINK-7206 URL: https://issues.apache.org/jira/browse/FLINK-7206 Project: Flink Issue

[jira] [Commented] (FLINK-6544) Expose State Backend Interface for UDAGG

[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089489#comment-16089489 ] Kaibo Zhou commented on FLINK-6544: --- Hi all, as discussed in the documentation, I will create some

[jira] [Updated] (FLINK-6544) Expose State Backend Interface for UDAGG

[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6544: -- Description: Currently UDAGG users can not access state, it's necessary to provide users with a

[jira] [Commented] (FLINK-6955) Add operation log for Table

[ https://issues.apache.org/jira/browse/FLINK-6955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055958#comment-16055958 ] Kaibo Zhou commented on FLINK-6955: --- [~twalthr], thanks for your comments. The result of

[jira] [Updated] (FLINK-6955) Add operation log for Table

[ https://issues.apache.org/jira/browse/FLINK-6955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6955: -- Description: In some of the actual production scenarios, the operation of the Table is very

[jira] [Created] (FLINK-6955) Add operation log for Table

Kaibo Zhou created FLINK-6955: - Summary: Add operation log for Table Key: FLINK-6955 URL: https://issues.apache.org/jira/browse/FLINK-6955 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6544) Expose Backend State Interface for UDAGG

Kaibo Zhou created FLINK-6544: - Summary: Expose Backend State Interface for UDAGG Key: FLINK-6544 URL: https://issues.apache.org/jira/browse/FLINK-6544 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979723#comment-15979723 ] Kaibo Zhou commented on FLINK-6355: --- Hi, [~fhueske] The previous version of the example code did not

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[jira] [Commented] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979153#comment-15979153 ] Kaibo Zhou commented on FLINK-6355: --- Thanks [~fhueske] I have updated the description and add some

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[jira] [Created] (FLINK-6355) TableEnvironment support register TableFunction

Kaibo Zhou created FLINK-6355: - Summary: TableEnvironment support register TableFunction Key: FLINK-6355 URL: https://issues.apache.org/jira/browse/FLINK-6355 Project: Flink Issue Type: