[jira] [Updated] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

[ 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

[jira] [Updated] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

[ 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

[jira] [Updated] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

[ 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

[jira] [Updated] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

[ 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

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107177#comment-16107177 ] Zhuoluo Yang commented on FLINK-5832: - [~twalthr] Sorry for the delay. I wil update the patch this

[jira] [Updated] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Comment Edited] (FLINK-6226) ScalarFunction and TableFunction do not support parameters of byte, short and float

[ https://issues.apache.org/jira/browse/FLINK-6226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950509#comment-15950509 ] Zhuoluo Yang edited comment on FLINK-6226 at 4/1/17 2:17 AM: - I have tested

[jira] [Commented] (FLINK-6226) ScalarFunction and TableFunction do not support parameters of byte, short and float

[ https://issues.apache.org/jira/browse/FLINK-6226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950509#comment-15950509 ] Zhuoluo Yang commented on FLINK-6226: - I have tested the different types of parameters. Byte, Short

[jira] [Created] (FLINK-6226) ScalarFunction and TableFunction do not support parameters of byte, short and float

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

[jira] [Created] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Updated] (FLINK-6068) Support If() as a built-in function of TableAPI

[ 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

[jira] [Created] (FLINK-6068) Support If() in built in function of TableAPI

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:

[jira] [Updated] (FLINK-6040) 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: Affects Version/s: 1.3.0 > DataStreamUserDefinedFunctionITCase occasionally fails >

[jira] [Updated] (FLINK-6040) 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 >

[jira] [Updated] (FLINK-6040) 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 >

[jira] [Updated] (FLINK-6040) 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 >

[jira] [Created] (FLINK-6040) 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

[jira] [Commented] (FLINK-6039) Row of TableFunction should support flexible number of fields

[ https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923886#comment-15923886 ] Zhuoluo Yang commented on FLINK-6039: - Hi [~fhueske] Thank you for your comments. I'm not sure whether

[jira] [Updated] (FLINK-6039) Row of TableFunction should support flexible number of fields

[ 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

[jira] [Created] (FLINK-6039) Row of TableFunction should support flexible number of fields

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

[jira] [Created] (FLINK-5882) TableFunction (UDTF) should support variable types and variable arguments

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

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877953#comment-15877953 ] Zhuoluo Yang commented on FLINK-5826: - We would like to split the task into two sub-tasks. 1. support

[jira] [Updated] (FLINK-5881) ScalarFunction(UDF) should support variable types and variable arguments

[ 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

[jira] [Created] (FLINK-5881) Scalar should support variable types and variable arguments

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

[jira] [Closed] (FLINK-5739) NullPointerException in CliFrontend

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

[jira] [Commented] (FLINK-5739) NullPointerException in CliFrontend

[ https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873961#comment-15873961 ] Zhuoluo Yang commented on FLINK-5739: - Fixed via 5e32eb549d3bc2195548620005fcf54437e75f48 >

[jira] [Resolved] (FLINK-5739) NullPointerException in CliFrontend

[ 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

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873947#comment-15873947 ] Zhuoluo Yang commented on FLINK-5826: - Thanks [~jark] , I'd like to do some test on this. It seems a

[jira] [Created] (FLINK-5835) Support for Hive's User-defined Aggregation Function (UDAF)

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

[jira] [Assigned] (FLINK-5833) Support for Hive GenericUDF

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

[jira] [Created] (FLINK-5833) Support for Hive GenericUDF

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

[jira] [Created] (FLINK-5832) Support for simple hive UDF

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

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871634#comment-15871634 ] Zhuoluo Yang commented on FLINK-5826: - Thanks [~jiangxw]. After some investigation on

[jira] [Updated] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

[ 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

[jira] [Comment Edited] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871338#comment-15871338 ] Zhuoluo Yang edited comment on FLINK-5826 at 2/17/17 7:33 AM: -- I have already

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871338#comment-15871338 ] Zhuoluo Yang commented on FLINK-5826: - I have already made a small modification in

[jira] [Created] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

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

[jira] [Commented] (FLINK-5792) Improve “UDF/UDTF" to support constructor with parameter.

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871230#comment-15871230 ] Zhuoluo Yang commented on FLINK-5792: - Hi [~sunjincheng121], I think this feature is very important to

[jira] [Updated] (FLINK-5739) 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: Labels: newbie starter (was: ) > NullPointerException in CliFrontend >

[jira] [Assigned] (FLINK-5739) 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 >

[jira] [Updated] (FLINK-5739) 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:

[jira] [Commented] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867625#comment-15867625 ] Zhuoluo Yang commented on FLINK-5802: - Sure. [~fhueske]. Thank you so much. I also would like to make

[jira] [Commented] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867574#comment-15867574 ] Zhuoluo Yang commented on FLINK-5802: - Hi [~fhueske]. Thank you for your comment. I agree with the

[jira] [Updated] (FLINK-5802) 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

[jira] [Updated] (FLINK-5802) 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: Component/s: Table API & SQL > Flink SQL calling Hive User-Defined Functions >

[jira] [Updated] (FLINK-5802) 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 >

[jira] [Updated] (FLINK-5802) 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

[jira] [Updated] (FLINK-5802) 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

[jira] [Updated] (FLINK-5802) 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

[jira] [Created] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

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

[jira] [Commented] (FLINK-5792) Improve “UDTF" to support with parameter constructor

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865221#comment-15865221 ] Zhuoluo Yang commented on FLINK-5792: - [~sunjincheng121] Could you please attach some design documents

[jira] [Updated] (FLINK-5739) 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:

[jira] [Updated] (FLINK-5739) 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:

[jira] [Created] (FLINK-5739) NullPointerException in CliFrontend

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