yinhua.dai created FLINK-10535:
--
Summary: User jar is present in the flink job manager's class path
Key: FLINK-10535
URL: https://issues.apache.org/jira/browse/FLINK-10535
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yinhua.dai updated FLINK-10535:
---
Description:
Run flink on yarn with attach and per-job mode, i.e.
{code:java}
flink run -m yarn-clu
yinhua.dai created FLINK-7246:
-
Summary: Big latency shown on operator.latency
Key: FLINK-7246
URL: https://issues.apache.org/jira/browse/FLINK-7246
Project: Flink
Issue Type: Bug
Compo
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yinhua.dai updated FLINK-9565:
--
Affects Version/s: 1.4.2
> Evaluating scalar UDFs in parallel
> --
>
>
yinhua.dai created FLINK-9565:
-
Summary: Evaluating scalar UDFs in parallel
Key: FLINK-9565
URL: https://issues.apache.org/jira/browse/FLINK-9565
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yinhua.dai updated FLINK-9565:
--
Description:
As per
[https://stackoverflow.com/questions/50790023/does-flink-sql-support-to-run-projec
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517958#comment-16517958
]
yinhua.dai commented on FLINK-9565:
---
[~fhueske] [~twalthr]
Just wondering whether this
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16519054#comment-16519054
]
yinhua.dai commented on FLINK-9565:
---
[~fhueske]
Yes I am.
Could you forward me a cont
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524641#comment-16524641
]
yinhua.dai commented on FLINK-9565:
---
[~fhueske] [~twalthr]
So there are two options:
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395038#comment-16395038
]
yinhua.dai commented on FLINK-6075:
---
[~fhueske]
Sorry to ask it here, but may I ask why
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16397950#comment-16397950
]
yinhua.dai commented on FLINK-6075:
---
[~fhueske]
Thanks for the explanation.
So "ORDER
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16398394#comment-16398394
]
yinhua.dai commented on FLINK-6075:
---
Thanks Fabian. I know the UDAGG will work, but just
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16399779#comment-16399779
]
yinhua.dai commented on FLINK-6075:
---
[~fhueske]
Is there a plan to support the RANK() w
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16400095#comment-16400095
]
yinhua.dai commented on FLINK-6075:
---
Thank you.
> ORDER BY *time ASC
>
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401548#comment-16401548
]
yinhua.dai commented on FLINK-7151:
---
[~yuemeng]
Any update on this functionality, I wou
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401595#comment-16401595
]
yinhua.dai commented on FLINK-7151:
---
That's great, thanks [~suez1224]
> FLINK SQL suppo
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401595#comment-16401595
]
yinhua.dai edited comment on FLINK-7151 at 3/16/18 8:36 AM:
Th
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404280#comment-16404280
]
yinhua.dai commented on FLINK-7151:
---
[~suez1224]
When do you think the feature will be
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408049#comment-16408049
]
yinhua.dai commented on FLINK-6595:
---
I am having a similar issue in Flink 1.4
SELECT
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408903#comment-16408903
]
yinhua.dai commented on FLINK-6595:
---
[~fhueske]
So that means I need separate to two sq
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408905#comment-16408905
]
yinhua.dai commented on FLINK-6595:
---
Is there anyway I can bypass the step?
> Nested SQ
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409640#comment-16409640
]
yinhua.dai commented on FLINK-6595:
---
I didn't notice that, great thanks [~fhueske]
> Ne
[
https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410799#comment-16410799
]
yinhua.dai commented on FLINK-6473:
---
[~fhueske]
Wondering before this feature is implem
[
https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16411052#comment-16411052
]
yinhua.dai commented on FLINK-6473:
---
[~fhueske]
I can't make it work as retract() only
[
https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16411076#comment-16411076
]
yinhua.dai commented on FLINK-6473:
---
My requirement is to calculate based on an incremen
[
https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16411076#comment-16411076
]
yinhua.dai edited comment on FLINK-6473 at 3/23/18 9:31 AM:
My
26 matches
Mail list logo
