[
https://issues.apache.org/jira/browse/FLINK-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6309:
Description:
Currently, in {{PlanFinalizer}}, we travel all the job vertices to calculate
the consu
[
https://issues.apache.org/jira/browse/FLINK-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6309:
Description:
Currently, in {{PlanFinalizer}}, we travel all the job vertices to calculate
the consu
[
https://issues.apache.org/jira/browse/FLINK-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6309:
Description:
Currently in {{PlanFinalizer}}, we travel all the job vertices to calculate the
consum
[
https://issues.apache.org/jira/browse/FLINK-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6309:
Description:
Currently, in {{PlanFinalizer}}, we travel all the job vertices to calculate
the consu
[
https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107177#comment-16107177
]
Zhuoluo Yang commented on FLINK-5832:
-
[~twalthr] Sorry for the delay. I wil update th
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6196:
Fix Version/s: 1.3.0
> Support dynamic schema in Table Function
> --
[
https://issues.apache.org/jira/browse/FLINK-6226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950509#comment-15950509
]
Zhuoluo Yang edited comment on FLINK-6226 at 4/1/17 2:17 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-6226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950509#comment-15950509
]
Zhuoluo Yang commented on FLINK-6226:
-
I have tested the different types of parameters
Zhuoluo Yang created FLINK-6226:
---
Summary: ScalarFunction and TableFunction do not support
parameters of byte, short and float
Key: FLINK-6226
URL: https://issues.apache.org/jira/browse/FLINK-6226
Proje
Zhuoluo Yang created FLINK-6196:
---
Summary: Support dynamic schema in Table Function
Key: FLINK-6196
URL: https://issues.apache.org/jira/browse/FLINK-6196
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6068:
Description:
Most sql system support if() as a built-in udf. However, we didn't register the
if() i
[
https://issues.apache.org/jira/browse/FLINK-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6068:
Summary: Support If() as a built-in function of TableAPI (was: Support
If() in built in function of
Zhuoluo Yang created FLINK-6068:
---
Summary: Support If() in built in function of TableAPI
Key: FLINK-6068
URL: https://issues.apache.org/jira/browse/FLINK-6068
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Affects Version/s: 1.3.0
> DataStreamUserDefinedFunctionITCase occasionally fails
>
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Fix Version/s: 1.3.0
> DataStreamUserDefinedFunctionITCase occasionally fails
>
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Component/s: Tests
> DataStreamUserDefinedFunctionITCase occasionally fails
> --
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Labels: test (was: )
> DataStreamUserDefinedFunctionITCase occasionally fails
> ---
Zhuoluo Yang created FLINK-6040:
---
Summary: DataStreamUserDefinedFunctionITCase occasionally fails
Key: FLINK-6040
URL: https://issues.apache.org/jira/browse/FLINK-6040
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923886#comment-15923886
]
Zhuoluo Yang commented on FLINK-6039:
-
Hi [~fhueske] Thank you for your comments. I'm
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6039:
Description:
In actual world, especially while processing logs with TableFunction. The
formats of t
Zhuoluo Yang created FLINK-6039:
---
Summary: Row of TableFunction should support flexible number of
fields
Key: FLINK-6039
URL: https://issues.apache.org/jira/browse/FLINK-6039
Project: Flink
Is
Zhuoluo Yang created FLINK-5882:
---
Summary: TableFunction (UDTF) should support variable types and
variable arguments
Key: FLINK-5882
URL: https://issues.apache.org/jira/browse/FLINK-5882
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15877953#comment-15877953
]
Zhuoluo Yang commented on FLINK-5826:
-
We would like to split the task into two sub-ta
[
https://issues.apache.org/jira/browse/FLINK-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5881:
Summary: ScalarFunction(UDF) should support variable types and variable
arguments (was: Scalar s
Zhuoluo Yang created FLINK-5881:
---
Summary: Scalar should support variable types and variable
arguments
Key: FLINK-5881
URL: https://issues.apache.org/jira/browse/FLINK-5881
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang closed FLINK-5739.
---
> NullPointerException in CliFrontend
> ---
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15873961#comment-15873961
]
Zhuoluo Yang commented on FLINK-5739:
-
Fixed via 5e32eb549d3bc2195548620005fcf54437e75
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang resolved FLINK-5739.
-
Resolution: Fixed
Many thanks to [~StephanEwen] for merging.
> NullPointerException in CliFronten
[
https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15873947#comment-15873947
]
Zhuoluo Yang commented on FLINK-5826:
-
Thanks [~jark] , I'd like to do some test on th
Zhuoluo Yang created FLINK-5835:
---
Summary: Support for Hive's User-defined Aggregation Function
(UDAF)
Key: FLINK-5835
URL: https://issues.apache.org/jira/browse/FLINK-5835
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang reassigned FLINK-5833:
---
Assignee: Zhuoluo Yang
> Support for Hive GenericUDF
> ---
>
>
Zhuoluo Yang created FLINK-5834:
---
Summary: Support for Hive User-defined Table-generating Function
(UDTF)
Key: FLINK-5834
URL: https://issues.apache.org/jira/browse/FLINK-5834
Project: Flink
I
Zhuoluo Yang created FLINK-5833:
---
Summary: Support for Hive GenericUDF
Key: FLINK-5833
URL: https://issues.apache.org/jira/browse/FLINK-5833
Project: Flink
Issue Type: Sub-task
Repo
Zhuoluo Yang created FLINK-5832:
---
Summary: Support for simple hive UDF
Key: FLINK-5832
URL: https://issues.apache.org/jira/browse/FLINK-5832
Project: Flink
Issue Type: Sub-task
Repo
[
https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871634#comment-15871634
]
Zhuoluo Yang commented on FLINK-5826:
-
Thanks [~jiangxw]. After some investigation on
[
https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5826:
Description:
In some cases, UDF/UDTF should support variable types and variable arguments.
Many UDF
[
https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871338#comment-15871338
]
Zhuoluo Yang edited comment on FLINK-5826 at 2/17/17 7:33 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871338#comment-15871338
]
Zhuoluo Yang commented on FLINK-5826:
-
I have already made a small modification in
{c
Zhuoluo Yang created FLINK-5826:
---
Summary: UDF/UDTF should support variable types and variable
arguments
Key: FLINK-5826
URL: https://issues.apache.org/jira/browse/FLINK-5826
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871230#comment-15871230
]
Zhuoluo Yang commented on FLINK-5792:
-
Hi [~sunjincheng121], I think this feature is v
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Labels: newbie starter (was: )
> NullPointerException in CliFrontend
>
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang reassigned FLINK-5739:
---
Assignee: Zhuoluo Yang
> NullPointerException in CliFrontend
> --
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Description:
I've run a simple program on a local cluster. It always fails with code
Version: 1.3-S
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867625#comment-15867625
]
Zhuoluo Yang commented on FLINK-5802:
-
Sure. [~fhueske]. Thank you so much. I also wou
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867574#comment-15867574
]
Zhuoluo Yang commented on FLINK-5802:
-
Hi [~fhueske]. Thank you for your comment.
I ag
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Component/s: Table API & SQL
> Flink SQL calling Hive User-Defined Functions
> -
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Labels: features (was: )
> Flink SQL calling Hive User-Defined Functions
>
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
Zhuoluo Yang created FLINK-5802:
---
Summary: Flink SQL calling Hive User-Defined Functions
Key: FLINK-5802
URL: https://issues.apache.org/jira/browse/FLINK-5802
Project: Flink
Issue Type: New Fea
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15865221#comment-15865221
]
Zhuoluo Yang commented on FLINK-5792:
-
[~sunjincheng121] Could you please attach some
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Description:
I've run a simple program on a local cluster. It always fails with code
Version: 1.3-S
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Description:
I've run a simple program on a local cluster. It always fails with code
Version: 1.3-S
Zhuoluo Yang created FLINK-5739:
---
Summary: NullPointerException in CliFrontend
Key: FLINK-5739
URL: https://issues.apache.org/jira/browse/FLINK-5739
Project: Flink
Issue Type: Bug
Com
56 matches
Mail list logo
