[jira] [Commented] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

2020-04-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081616#comment-17081616 ] Dian Fu commented on FLINK-17092: - Update: there are two test failures: BlinkStreamDependencyTests and 

[jira] [Created] (FLINK-17093) Python UDF doesn't work when the input column is of composite type

2020-04-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-17093: --- Summary: Python UDF doesn't work when the input column is of composite type Key: FLINK-17093 URL: https://issues.apache.org/jira/browse/FLINK-17093 Project: Flink

[jira] [Assigned] (FLINK-17124) The PyFlink Job runs into infinite loop if the UDF file imports job code.

2020-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17124: --- Assignee: Huang Xingbo > The PyFlink Job runs into infinite loop if the UDF file imports job code.

[jira] [Updated] (FLINK-17124) The PyFlink Job runs into infinite loop if the Python UDF imports job code

2020-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17124: Summary: The PyFlink Job runs into infinite loop if the Python UDF imports job code (was: The PyFlink

[jira] [Updated] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17135: Labels: test-stability (was: ) >

[jira] [Comment Edited] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083102#comment-17083102 ] Dian Fu edited comment on FLINK-17093 at 4/14/20, 10:51 AM: [~chesnay] I'm

[jira] [Comment Edited] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083122#comment-17083122 ] Dian Fu edited comment on FLINK-17068 at 4/14/20, 11:22 AM: [~rmetzger] I

[jira] [Comment Edited] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083122#comment-17083122 ] Dian Fu edited comment on FLINK-17068 at 4/14/20, 11:21 AM: [~rmetzger] I

[jira] [Commented] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083122#comment-17083122 ] Dian Fu commented on FLINK-17068: - [~rmetzger] I observe another instance which maybe helpful: 

[jira] [Commented] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083111#comment-17083111 ] Dian Fu commented on FLINK-17093: - Thanks for the sharing:) Then it's not related to this JIRA as the PR

[jira] [Commented] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083117#comment-17083117 ] Dian Fu commented on FLINK-17135: - [~dwysakowicz] Thanks for sharing this information. Seems an instable

[jira] [Closed] (FLINK-17124) The PyFlink Job runs into infinite loop if the Python UDF imports job code

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17124. --- Resolution: Fixed Merged to master via ec1e863cf21b8381b4d7937e7b4e8f7add3145cf and release-1.10 via 

[jira] [Updated] (FLINK-17124) The PyFlink Job runs into infinite loop if the Python UDF imports job code

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17124: Fix Version/s: 1.11.0 1.10.1 > The PyFlink Job runs into infinite loop if the Python

[jira] [Updated] (FLINK-17124) The PyFlink Job runs into infinite loop if the Python UDF imports job code

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17124: Affects Version/s: (was: 1.11.0) > The PyFlink Job runs into infinite loop if the Python UDF imports

[jira] [Updated] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17114: Affects Version/s: (was: 1.11.0) > When the pyflink job runs in local mode and the command "python"

[jira] [Updated] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17114: Fix Version/s: 1.11.0 1.10.1 > When the pyflink job runs in local mode and the command

[jira] [Commented] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083035#comment-17083035 ] Dian Fu commented on FLINK-17114: - Merged to master via 76064f5294d245fc5d741994f50cb32e004bdd8b > When

[jira] [Commented] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083102#comment-17083102 ] Dian Fu commented on FLINK-17093: - [~chesnay] I'm not sure. Can I know which branch is this test failure

[jira] [Commented] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083112#comment-17083112 ] Dian Fu commented on FLINK-17093: - [~chesnay] Thanks a lot for reporting this issue. I have created 

[jira] [Updated] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17135: Summary: PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed (was:

[jira] [Created] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed on master

2020-04-14 Thread Dian Fu (Jira)
Dian Fu created FLINK-17135: --- Summary: PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed on master Key: FLINK-17135 URL: https://issues.apache.org/jira/browse/FLINK-17135

[jira] [Assigned] (FLINK-15971) Adjust the default value of bundle size and bundle time

2020-04-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-15971: --- Assignee: Huang Xingbo > Adjust the default value of bundle size and bundle time >

[jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink

2020-04-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16762: Fix Version/s: 1.11.0 > Relocation Beam dependency of PyFlink > - > >

[jira] [Assigned] (FLINK-16762) Relocation Beam dependency of PyFlink

2020-04-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16762: --- Assignee: Dian Fu > Relocation Beam dependency of PyFlink > -

[jira] [Commented] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

2020-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082084#comment-17082084 ] Dian Fu commented on FLINK-17092: - Thanks [~zhongwei]! > Pyflink failure for BlinkStreamDependencyTests

[jira] [Commented] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083261#comment-17083261 ] Dian Fu commented on FLINK-17114: - Merged to release-1.10 via 6227f0815e9db9956f1d9e1d7548d9c8efe8d895

[jira] [Closed] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17114. --- Resolution: Fixed > When the pyflink job runs in local mode and the command "python" points to > Python

[jira] [Closed] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17068. --- Resolution: Fixed Merged to master via 6e613398ef5bb9654fe8595fb9ff09c062389bb4 > ERROR at teardown of

[jira] [Closed] (FLINK-17118) Add Cython support for primitive data types

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17118. --- Resolution: Resolved > Add Cython support for primitive data types >

[jira] [Commented] (FLINK-17118) Add Cython support for primitive data types

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087008#comment-17087008 ] Dian Fu commented on FLINK-17118: - Merged to master via c874700d35fc28cb9af4fc4255c54afa3aaf455e and

[jira] [Commented] (FLINK-17188) Failed to download conda when running python tests

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086947#comment-17086947 ] Dian Fu commented on FLINK-17188: - Another instance:

[jira] [Commented] (FLINK-17220) It reports "No space left on device" on azure pipeline

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086866#comment-17086866 ] Dian Fu commented on FLINK-17220: - [~rmetzger] Thanks for working on FLINK-17223. I think so. I will

[jira] [Closed] (FLINK-17220) It reports "No space left on device" on azure pipeline

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17220. --- Resolution: Invalid > It reports "No space left on device" on azure pipeline >

[jira] [Commented] (FLINK-17188) Failed to download conda when running python tests

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086948#comment-17086948 ] Dian Fu commented on FLINK-17188: - The following instance report "Maven produced no output for 300

[jira] [Closed] (FLINK-17120) Support Cython Optimizing Python Operations

2020-04-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17120. --- Resolution: Resolved Merged to master via 6b80935b28756122cb43053494abd765a1508934 > Support Cython

[jira] [Closed] (FLINK-14269) The close method does not work for Python UserDefinedFunction

2020-04-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-14269. --- Resolution: Invalid Closed as it should have been resolved in FLINK-15875 after bump Beam to 2.19.0 > The

[jira] [Closed] (FLINK-15078) Report Python version exceptions in time

2020-04-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-15078. --- Resolution: Invalid Close this issue as it should doesn't exist any more after bump Beam to 2.19.0

[jira] [Updated] (FLINK-16943) Support adding jars in PyFlink

2020-04-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16943: Fix Version/s: 1.11.0 > Support adding jars in PyFlink > -- > >

[jira] [Closed] (FLINK-16943) Support adding jars in PyFlink

2020-04-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16943. --- Resolution: Resolved Merged to master via 68142e5fc3855d3972ea749a766e9ecca97bcc5e > Support adding jars

[jira] [Assigned] (FLINK-16943) Support adding jars in PyFlink

2020-04-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16943: --- Assignee: Wei Zhong > Support adding jars in PyFlink > -- > >

[jira] [Assigned] (FLINK-17120) Support Cython Optimizing Python Operations

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17120: --- Assignee: Huang Xingbo > Support Cython Optimizing Python Operations >

[jira] [Updated] (FLINK-14020) User Apache Arrow as the serializer for data transmission between Java operator and Python harness

2020-04-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14020: Fix Version/s: (was: 1.11.0) > User Apache Arrow as the serializer for data transmission between Java

[jira] [Closed] (FLINK-14020) User Apache Arrow as the serializer for data transmission between Java operator and Python harness

2020-04-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-14020. --- Resolution: Invalid > User Apache Arrow as the serializer for data transmission between Java > operator

[jira] [Assigned] (FLINK-15973) Optimize the execution plan where it refers the Python UDF result field in the where clause

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-15973: --- Assignee: Dian Fu > Optimize the execution plan where it refers the Python UDF result field in >

[jira] [Closed] (FLINK-16484) Support all the data types in vectorized Python UDF

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16484. --- Resolution: Resolved > Support all the data types in vectorized Python UDF >

[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12991: Fix Version/s: 1.9.0 > Correct the implementation of Catalog.get_table_factory >

[jira] [Closed] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-12991. --- Assignee: Dian Fu Resolution: Resolved Merged to 1.9.0 via 86fd4b5722414b0255f9e1a31492824d5ec5b126

[jira] [Closed] (FLINK-14024) Support use-defined metrics in Python user-defined functions

2020-04-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-14024. --- Fix Version/s: (was: 1.11.0) Resolution: Duplicate > Support use-defined metrics in Python

[jira] [Closed] (FLINK-17119) Add Cython support for composite types

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17119. --- Resolution: Resolved Merged to master via 54563600b1b760da365edca75be602aee8c475f7 > Add Cython support

[jira] [Updated] (FLINK-15861) Change TableEnvironmentImpl to StreamTableEnvironmentImpl in python blink batch mode

2020-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15861: Summary: Change TableEnvironmentImpl to StreamTableEnvironmentImpl in python blink batch mode (was:

[jira] [Assigned] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17068: --- Assignee: Dian Fu > ERROR at teardown of TableConfigTests.test_get_set_decimal_context >

[jira] [Commented] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086740#comment-17086740 ] Dian Fu commented on FLINK-17068: - Just make it clear: this issue is because the permission of the

[jira] [Comment Edited] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086740#comment-17086740 ] Dian Fu edited comment on FLINK-17068 at 4/19/20, 4:37 AM: --- Just make it

[jira] [Updated] (FLINK-17148) Support converting pandas dataframe to flink table

2020-04-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17148: Fix Version/s: 1.11.0 > Support converting pandas dataframe to flink table >

[jira] [Closed] (FLINK-16763) Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10

2020-04-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16763. --- Resolution: Fixed Merged to release-1.10 via 9b812d77fa517af0cf152370b2f86c904a2c83a2 > Should not use

[jira] [Commented] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

2020-04-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079176#comment-17079176 ] Dian Fu commented on FLINK-17068: - I found logs like the following: {code} PermissionError: [Errno 13]

[jira] [Updated] (FLINK-17066) Update pyarrow version bounds less than 0.14.0

2020-04-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17066: Affects Version/s: 1.10.0 > Update pyarrow version bounds less than 0.14.0 >

[jira] [Closed] (FLINK-17062) Fix the conversion from Java row type to Python row type

2020-04-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17062. --- Resolution: Fixed Merged via * master: 36e597277014f41b4eca1dae14e3d247e8ab17e5 * release-1.10:

[jira] [Assigned] (FLINK-17115) Support Cython Optimizing Python User Defined Function(FLIP-121)

2020-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17115: --- Assignee: Huang Xingbo > Support Cython Optimizing Python User Defined Function(FLIP-121) >

[jira] [Updated] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17114: Component/s: API / Python > When the pyflink job runs in local mode and the command "python" points to >

[jira] [Assigned] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17114: --- Assignee: Wei Zhong > When the pyflink job runs in local mode and the command "python" points to

[jira] [Commented] (FLINK-15347) ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange failed on Travis

2020-04-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081115#comment-17081115 ] Dian Fu commented on FLINK-15347: - Another instance: 

[jira] [Commented] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084133#comment-17084133 ] Dian Fu commented on FLINK-17135: - Status update: I found that this issue could be reproduced every time

[jira] [Updated] (FLINK-14614) add annotation location javastyle rule

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14614: Fix Version/s: (was: 1.9.3) 1.9.4 > add annotation location javastyle rule >

[jira] [Updated] (FLINK-17073) Slow checkpoint cleanup causing OOMs

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17073: Fix Version/s: (was: 1.9.3) 1.9.4 > Slow checkpoint cleanup causing OOMs >

[jira] [Commented] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084686#comment-17084686 ] Dian Fu commented on FLINK-17135: - I have reproduced this issue in my local machine and I think it's a

[jira] [Updated] (FLINK-13083) Various improvements PubSub Connector

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13083: Fix Version/s: (was: 1.9.3) 1.9.4 > Various improvements PubSub Connector >

[jira] [Updated] (FLINK-14739) add failOnCastException Configuration to Json FormatDescriptor

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14739: Fix Version/s: (was: 1.9.3) 1.9.4 > add failOnCastException Configuration to Json

[jira] [Updated] (FLINK-14537) Improve influxdb reporter performance for kafka source/sink

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14537: Fix Version/s: (was: 1.9.3) 1.9.4 > Improve influxdb reporter performance for

[jira] [Updated] (FLINK-15861) Change TableEnvironmentImpl to StreamTableaEnvironmentImpl in python blink batch mode

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15861: Fix Version/s: (was: 1.9.3) 1.9.4 > Change TableEnvironmentImpl to

[jira] [Commented] (FLINK-17205) test_ci Python fails with unable to execute 'gcc': No such file or directory

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085479#comment-17085479 ] Dian Fu commented on FLINK-17205: - Sorry about this. Will look into it ASAP. > test_ci Python fails

[jira] [Updated] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16766: Fix Version/s: (was: 1.9.3) 1.9.4 > Support create StreamTableEnvironment without

[jira] [Updated] (FLINK-13357) Add documentation for PartitionableTableSource and PartitionableTableSink

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13357: Fix Version/s: (was: 1.9.3) 1.9.4 > Add documentation for PartitionableTableSource

[jira] [Updated] (FLINK-14827) Add thread dump feature for jobmanager

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14827: Fix Version/s: (was: 1.9.3) 1.9.4 > Add thread dump feature for jobmanager >

[jira] [Updated] (FLINK-15801) Timestamp extractor created from properties does not work for some physical fields

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15801: Fix Version/s: (was: 1.9.3) 1.9.4 > Timestamp extractor created from properties

[jira] [Updated] (FLINK-13358) Add documentation for InputFormatTableSource and OutputFormatTableSink

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13358: Fix Version/s: (was: 1.9.3) 1.9.4 > Add documentation for InputFormatTableSource

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15471: Fix Version/s: (was: 1.9.3) 1.9.4 > HA e2e check for empty .out files does not

[jira] [Updated] (FLINK-13086) add Chinese documentation for catalogs

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13086: Fix Version/s: (was: 1.9.3) 1.9.4 > add Chinese documentation for catalogs >

[jira] [Updated] (FLINK-13278) add Chinese documentation for Hive source/sink

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13278: Fix Version/s: (was: 1.9.3) 1.9.4 > add Chinese documentation for Hive source/sink

[jira] [Updated] (FLINK-12894) add Chinese documentation of how to configure and use catalogs in SQL CLI

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12894: Fix Version/s: (was: 1.9.3) 1.9.4 > add Chinese documentation of how to configure

[jira] [Closed] (FLINK-17207) Lots of test_ci Python tests failing with OSError: [Errno 9] Bad file descriptor

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17207. --- Resolution: Duplicate [~pnowojski] This issue duplicates with FLINK-17068. I'm closing it. > Lots of

[jira] [Updated] (FLINK-13271) Add documentation for all the new features of blink planner

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13271: Fix Version/s: (was: 1.9.3) 1.9.4 > Add documentation for all the new features of

[jira] [Updated] (FLINK-14328) JobCluster cannot reach TaskManager in K8s

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14328: Fix Version/s: (was: 1.9.3) 1.9.4 > JobCluster cannot reach TaskManager in K8s >

[jira] [Updated] (FLINK-15414) KafkaITCase#prepare failed in travis

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15414: Fix Version/s: (was: 1.9.3) 1.9.4 > KafkaITCase#prepare failed in travis >

[jira] [Updated] (FLINK-13692) Make CompletedCheckpointStore backwards compatible?

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13692: Fix Version/s: (was: 1.9.3) 1.9.4 > Make CompletedCheckpointStore backwards

[jira] [Updated] (FLINK-14385) There are ClassNotFoundException when run the example in Local Setup Tutorial

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14385: Fix Version/s: (was: 1.9.3) 1.9.4 > There are ClassNotFoundException when run the

[jira] [Updated] (FLINK-14327) Getting "Could not forward element to next operator" error

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14327: Fix Version/s: (was: 1.9.3) 1.9.4 > Getting "Could not forward element to next

[jira] [Updated] (FLINK-13298) write Chinese documentation and quickstart for Flink-Hive compatibility

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13298: Fix Version/s: (was: 1.9.3) 1.9.4 > write Chinese documentation and quickstart for

[jira] [Updated] (FLINK-13230) Retry acknowledgement calls

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13230: Fix Version/s: (was: 1.9.3) 1.9.4 > Retry acknowledgement calls >

[jira] [Closed] (FLINK-17118) Support Primitive DataTypes in Cython

2020-04-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17118. --- Assignee: Huang Xingbo Resolution: Resolved Merged to master via

[jira] [Comment Edited] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084686#comment-17084686 ] Dian Fu edited comment on FLINK-17135 at 4/16/20, 9:16 AM: --- I have reproduced

[jira] [Comment Edited] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084686#comment-17084686 ] Dian Fu edited comment on FLINK-17135 at 4/16/20, 9:17 AM: --- I have reproduced

[jira] [Updated] (FLINK-17118) Add Cython support for primitive data types

2020-04-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17118: Summary: Add Cython support for primitive data types (was: Support Primitive DataTypes in Cython) > Add

[jira] [Updated] (FLINK-16031) Improve the description in the README file of PyFlink 1.9.x

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16031: Summary: Improve the description in the README file of PyFlink 1.9.x (was: Improve the description in

[jira] [Created] (FLINK-17220) It reports "No space left on device" on azure pipeline

2020-04-17 Thread Dian Fu (Jira)
Dian Fu created FLINK-17220: --- Summary: It reports "No space left on device" on azure pipeline Key: FLINK-17220 URL: https://issues.apache.org/jira/browse/FLINK-17220 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-17220) It reports "No space left on device" on azure pipeline

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17220: --- Assignee: Huang Xingbo > It reports "No space left on device" on azure pipeline >

[jira] [Commented] (FLINK-17205) test_ci Python fails with unable to execute 'gcc': No such file or directory

2020-04-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085806#comment-17085806 ] Dian Fu commented on FLINK-17205: - [~pnowojski] The reason is that gcc is not installed in the azure

[jira] [Updated] (FLINK-16524) Optimize the execution of Python UDF to use generator to eliminate unnecessary function calls

2020-03-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16524: Summary: Optimize the execution of Python UDF to use generator to eliminate unnecessary function calls

[jira] [Updated] (FLINK-16524) Optimize the execution of Python UDF to ues generator to eliminate unnecessary function calls

2020-03-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16524: Summary: Optimize the execution of Python UDF to ues generator to eliminate unnecessary function calls

[jira] [Closed] (FLINK-16524) Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16524. --- Resolution: Resolved Merged to master via d6038cc62f2d04cf078f0ac38cb8bc6fd7d9bb8e > Optimize the result

<    2   3   4   5   6   7   8   9   10   11   >