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: Improveme
[
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 canno
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979153#comment-15979153
]
Kaibo Zhou commented on FLINK-6355:
---
Thanks [~fhueske]
I have updated the description
[
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 canno
[
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 canno
[
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 canno
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979723#comment-15979723
]
Kaibo Zhou commented on FLINK-6355:
---
Hi, [~fhueske]
The previous version of the example
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
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
Compone
[
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
complicated
[
https://issues.apache.org/jira/browse/FLINK-6955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055958#comment-16055958
]
Kaibo Zhou commented on FLINK-6955:
---
[~twalthr], thanks for your comments.
The result o
[
https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002689#comment-17002689
]
Kaibo Zhou commented on FLINK-14393:
This problem has been around for a long time. I
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 Typ
[
https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005272#comment-17005272
]
Kaibo Zhou commented on FLINK-15419:
Hi [~baijingjing7449], thank you for sharing t
[
https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005272#comment-17005272
]
Kaibo Zhou edited comment on FLINK-15419 at 12/30/19 12:02 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006031#comment-17006031
]
Kaibo Zhou commented on FLINK-13550:
Hi, [~dmvk] Thank you for your work.
I'm inter
[
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 conveni
[
https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089489#comment-16089489
]
Kaibo Zhou commented on FLINK-6544:
---
Hi all, as discussed in the documentation, I will c
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 T
[
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.)
> Imp
[
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.
> Implementation
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
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
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: https://issues.apache.org/jira/browse/FLINK-72
[
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 supp
[
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 agg(MaxWithRetra
[
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 us
[
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 Scala
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: Improv
[
https://issues.apache.org/jira/browse/FLINK-18875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174323#comment-17174323
]
Kaibo Zhou commented on FLINK-18875:
Good, 'SHOW CREATE TABLE' works for me.
> DESC
[
https://issues.apache.org/jira/browse/FLINK-13779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910473#comment-16910473
]
Kaibo Zhou commented on FLINK-13779:
Hi [~Zentol]
I have implemented it on my local
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
Project:
[
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
[
https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910508#comment-16910508
]
Kaibo Zhou commented on FLINK-13787:
I did some investigate, the reason is that flin
[
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
[do
[
https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910508#comment-16910508
]
Kaibo Zhou edited comment on FLINK-13787 at 8/20/19 9:03 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910508#comment-16910508
]
Kaibo Zhou edited comment on FLINK-13787 at 8/20/19 9:44 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911995#comment-16911995
]
Kaibo Zhou commented on FLINK-13787:
hi, [~lamber-ken]
Thank you for your reminder
[
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
[do
39 matches
Mail list logo
