[jira] [Updated] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15593: Fix Version/s: (was: 1.10.1) (was: 1.11.0) > add doc to remind users not using

[jira] [Updated] (FLINK-15743) Add Flink 1.10 release notes to documentation

[ https://issues.apache.org/jira/browse/FLINK-15743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15743: Fix Version/s: (was: 1.10.1) 1.10.0 > Add Flink 1.10 release notes to

[jira] [Closed] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16142. --- Fix Version/s: (was: 1.10.1) (was: 1.11.0) Resolution: Duplicate Updated

[jira] [Reopened] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reopened FLINK-16142: - > Memory Leak causes Metaspace OOM error on repeated job submission >

[jira] [Updated] (FLINK-15751) RocksDB Memory Management end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-15751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15751: Fix Version/s: (was: 1.10.1) 1.10.0 > RocksDB Memory Management end-to-end test

[jira] [Updated] (FLINK-15751) RocksDB Memory Management end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-15751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15751: Fix Version/s: (was: 1.10.0) 1.10.1 > RocksDB Memory Management end-to-end test

[jira] [Commented] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103784#comment-17103784 ] Dian Fu commented on FLINK-14223: - Removed the fix version to avoid it appears in the release note. >

[jira] [Updated] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14223: Fix Version/s: (was: 1.10.1) (was: 1.11.0) >

[jira] [Updated] (FLINK-15741) Fix TTL docs after enabling RocksDB compaction filter by default (needs Chinese translation)

[ https://issues.apache.org/jira/browse/FLINK-15741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15741: Fix Version/s: (was: 1.10.0) 1.10.1 > Fix TTL docs after enabling RocksDB

[jira] [Commented] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

[ https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103782#comment-17103782 ] Dian Fu commented on FLINK-11072: - Updated the resolution to "Cannot Reproduce" and remove the fix

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17499: Fix Version/s: 1.10.1 > LazyTimerService used to register timers via State Processing API incorrectly >

[jira] [Closed] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

[ https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-11072. --- Resolution: Cannot Reproduce > KafkaITCase.testKeyValueSupport failure >

[jira] [Updated] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

[ https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-11072: Fix Version/s: (was: 1.10.1) (was: 1.11.0) > KafkaITCase.testKeyValueSupport

[jira] [Reopened] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

[ https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reopened FLINK-11072: - > KafkaITCase.testKeyValueSupport failure > --- > >

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17499: Affects Version/s: (was: 1.10.2) 1.10.0 > LazyTimerService used to register

[jira] [Updated] (FLINK-16944) Compile error in. DumpCompiledPlanTest and PreviewPlanDumpTest

[ https://issues.apache.org/jira/browse/FLINK-16944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16944: Fix Version/s: 1.10.1 > Compile error in. DumpCompiledPlanTest and PreviewPlanDumpTest >

[jira] [Updated] (FLINK-15143) Create document for FLIP-49 TM memory model and configuration guide

[ https://issues.apache.org/jira/browse/FLINK-15143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15143: Fix Version/s: (was: 1.10.0) 1.10.1 > Create document for FLIP-49 TM memory model

[jira] [Updated] (FLINK-15743) Add Flink 1.10 release notes to documentation

[ https://issues.apache.org/jira/browse/FLINK-15743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15743: Fix Version/s: 1.10.1 > Add Flink 1.10 release notes to documentation >

[jira] [Updated] (FLINK-15933) update content of how generic table schema is stored in hive via HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15933: Fix Version/s: (was: 1.10.0) 1.10.1 > update content of how generic table schema

[jira] [Updated] (FLINK-15998) In Glossary, clarify Application/Job cluster description

[ https://issues.apache.org/jira/browse/FLINK-15998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15998: Fix Version/s: (was: 1.10.1) > In Glossary, clarify Application/Job cluster description >

[jira] [Commented] (FLINK-16944) Compile error in. DumpCompiledPlanTest and PreviewPlanDumpTest

[ https://issues.apache.org/jira/browse/FLINK-16944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103763#comment-17103763 ] Dian Fu commented on FLINK-16944: - Add fix version of "1.10.1" as I noticed that it has also been

[jira] [Commented] (FLINK-15998) In Glossary, clarify Application/Job cluster description

[ https://issues.apache.org/jira/browse/FLINK-15998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103779#comment-17103779 ] Dian Fu commented on FLINK-15998: - Have removed the fix version of "1.10.1" as actually it's not

[jira] [Assigned] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17454: --- Assignee: shuiqiangchen > test_configuration.py ConfigurationTests::test_add_all failed on travis

[jira] [Closed] (FLINK-17567) Create a dedicated Python directory in release directory to place Python-related source and binary packages

[ https://issues.apache.org/jira/browse/FLINK-17567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17567. --- Resolution: Resolved Merged to master via ce6b97edf8eb44fc92fb7da09e41aac18d710802 > Create a dedicated

[jira] [Closed] (FLINK-17256) Suppport keyword arguments in the PyFlink Descriptor API

[ https://issues.apache.org/jira/browse/FLINK-17256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17256. --- Resolution: Resolved Merged to master via 0d1738bb15c19fb6c4efe4e7fef55543c33edcea > Suppport keyword

[jira] [Created] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable

Dian Fu created FLINK-17576: --- Summary: HiveTableSinkTest and TableEnvHiveConnectorTest are instable Key: FLINK-17576 URL: https://issues.apache.org/jira/browse/FLINK-17576 Project: Flink Issue

[jira] [Updated] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable

[ https://issues.apache.org/jira/browse/FLINK-17576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17576: Labels: test-stability (was: ) > HiveTableSinkTest and TableEnvHiveConnectorTest are instable >

[jira] [Closed] (FLINK-17597) JavaSqlTests#test_java_sql_ddl is instable

[ https://issues.apache.org/jira/browse/FLINK-17597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17597. --- Resolution: Duplicate This cause of this issue should be the same as FLINK-17454 and so should have been

[jira] [Updated] (FLINK-17596) Unstable PyFlinkBlinkStreamUserDefinedFunctionTests testMethod#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-17596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17596: Fix Version/s: 1.11.0 > Unstable PyFlinkBlinkStreamUserDefinedFunctionTests >

[jira] [Assigned] (FLINK-17596) Unstable PyFlinkBlinkStreamUserDefinedFunctionTests testMethod#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-17596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17596: --- Assignee: Wei Zhong > Unstable PyFlinkBlinkStreamUserDefinedFunctionTests >

[jira] [Issue Comment Deleted] (FLINK-17679) Fix the bug of encoding bytes in cython coder

[ https://issues.apache.org/jira/browse/FLINK-17679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17679: Comment: was deleted (was: I mean a specific example job) > Fix the bug of encoding bytes in cython

[jira] [Commented] (FLINK-17679) Fix the bug of encoding bytes in cython coder

[ https://issues.apache.org/jira/browse/FLINK-17679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106835#comment-17106835 ] Dian Fu commented on FLINK-17679: - [~hxbks2ks] could you give an example in which case it will cause

[jira] [Assigned] (FLINK-17646) Reduce the python package size of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17646: --- Assignee: Wei Zhong > Reduce the python package size of PyFlink >

[jira] [Closed] (FLINK-17646) Reduce the python package size of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17646. --- Resolution: Resolved Merged to master via d45985d27dbc44fe414d69baa685e43d877b082c > Reduce the python

[jira] [Closed] (FLINK-17679) Fix the bug of encoding bytes in cython coder

[ https://issues.apache.org/jira/browse/FLINK-17679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17679. --- Assignee: Huang Xingbo Resolution: Fixed Merged to master via

[jira] [Updated] (FLINK-17646) Reduce the python package size of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17646: Fix Version/s: 1.11.0 > Reduce the python package size of PyFlink >

[jira] [Commented] (FLINK-17679) Fix the bug of encoding bytes in cython coder

[ https://issues.apache.org/jira/browse/FLINK-17679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106883#comment-17106883 ] Dian Fu commented on FLINK-17679: - I mean a specific example job > Fix the bug of encoding bytes in

[jira] [Updated] (FLINK-17679) Fix the bug of encoding bytes in cython coder

[ https://issues.apache.org/jira/browse/FLINK-17679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17679: Description: The python bytes b'x\x00\x00\x00' will be transposed to b'\x'. If we use strlen() of c

[jira] [Closed] (FLINK-17724) PyFlink end-to-end test fails with Cannot run program "venv.zip/.conda/bin/python": error=2, No such file or directory

[ https://issues.apache.org/jira/browse/FLINK-17724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17724. --- Resolution: Fixed Merged to master via 01abc3f4b054315c8e8edb1f3efe3610d3a77edb > PyFlink end-to-end test

[jira] [Updated] (FLINK-17724) PyFlink end-to-end test fails with Cannot run program "venv.zip/.conda/bin/python": error=2, No such file or directory

[ https://issues.apache.org/jira/browse/FLINK-17724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17724: Affects Version/s: 1.11.0 > PyFlink end-to-end test fails with Cannot run program >

[jira] [Assigned] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-14500: --- Assignee: Huang Xingbo (was: Dian Fu) > Support Flink Python User-Defined Stateless Function for

[jira] [Closed] (FLINK-16114) Support Scalar Vectorized Python UDF in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16114. --- Resolution: Resolved > Support Scalar Vectorized Python UDF in PyFlink >

[jira] [Assigned] (FLINK-15974) Support to use the Python UDF directly in the Python Table API

[ https://issues.apache.org/jira/browse/FLINK-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-15974: --- Assignee: shuiqiangchen > Support to use the Python UDF directly in the Python Table API >

[jira] [Assigned] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-14500: --- Assignee: Dian Fu > Support Flink Python User-Defined Stateless Function for Table - Phase 2 >

[jira] [Closed] (FLINK-16665) Support Python UDF in SQL Function DDL (FLIP-106)

[ https://issues.apache.org/jira/browse/FLINK-16665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16665. --- Resolution: Resolved > Support Python UDF in SQL Function DDL (FLIP-106) >

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

[ https://issues.apache.org/jira/browse/FLINK-17115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17115. --- Resolution: Resolved Close this ticket as I think all the known subtasks have been resolved. > Support

[jira] [Commented] (FLINK-17285) Translate "Python Table API" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108794#comment-17108794 ] Dian Fu commented on FLINK-17285: - [~billrao] Thanks a for working on this ticket. I can help to review.

[jira] [Comment Edited] (FLINK-16747) Performance improvements for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-16747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108797#comment-17108797 ] Dian Fu edited comment on FLINK-16747 at 5/16/20, 1:20 AM: --- Thanks [~hxbks2ks]

[jira] [Closed] (FLINK-16747) Performance improvements for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-16747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16747. --- Resolution: Resolved Close this ticket as I think all the known tasks have been resolved. > Performance

[jira] [Assigned] (FLINK-17700) The callback client of JavaGatewayServer should run in a daemon thread

[ https://issues.apache.org/jira/browse/FLINK-17700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17700: --- Assignee: shuiqiangchen > The callback client of JavaGatewayServer should run in a daemon thread >

[jira] [Commented] (FLINK-17743) Python e2e failed by Cannot run program "venv.zip/.conda/bin/python"

[ https://issues.apache.org/jira/browse/FLINK-17743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108964#comment-17108964 ] Dian Fu commented on FLINK-17743: - [~lzljs3620320] Thanks for reporting this issue. It is duplicate with

[jira] [Closed] (FLINK-17743) Python e2e failed by Cannot run program "venv.zip/.conda/bin/python"

[ https://issues.apache.org/jira/browse/FLINK-17743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17743. --- Resolution: Duplicate > Python e2e failed by Cannot run program "venv.zip/.conda/bin/python" >

[jira] [Updated] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17710: Labels: pull-request-available test-stability (was: pull-request-available) >

[jira] [Assigned] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17710: --- Assignee: Nicholas Jiang > StreamSqlTests.test_execute_sql test is not stable >

[jira] [Closed] (FLINK-13811) Support converting flink table to pandas dataframe

[ https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-13811. --- Resolution: Resolved Merged to master via d41788999ac8f9f3b9444fb11ebcfdd8a6cb253c > Support converting

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

[ https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13811: Affects Version/s: (was: 1.9.0) > Support converting flink table to pandas dataframe >

[jira] [Closed] (FLINK-17146) Support conversion between PyFlink Table and Pandas DataFrame

[ https://issues.apache.org/jira/browse/FLINK-17146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17146. --- Resolution: Resolved > Support conversion between PyFlink Table and Pandas DataFrame >

[jira] [Comment Edited] (FLINK-12717) Add windows support for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101491#comment-17101491 ] Dian Fu edited comment on FLINK-12717 at 5/15/20, 1:56 AM: --- Merged to master

[jira] [Closed] (FLINK-15138) Add e2e Test for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-15138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-15138. --- Resolution: Resolved Merged to master via b51101bdeb1d7052d0a89ee51c9342aeed5bd153 > Add e2e Test for

[jira] [Assigned] (FLINK-15138) Add e2e Test for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-15138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-15138: --- Assignee: Wei Zhong > Add e2e Test for PyFlink > > > Key:

[jira] [Closed] (FLINK-17596) Unstable PyFlinkBlinkStreamUserDefinedFunctionTests testMethod#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-17596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17596. --- Resolution: Fixed Merged to master via 282da0dd3e2def9e0ea6693f953d2733eb663e70 > Unstable

[jira] [Updated] (FLINK-17596) Unstable PyFlinkBlinkStreamUserDefinedFunctionTests testMethod#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-17596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17596: Labels: pull-request-available test-stability (was: pull-request-available) > Unstable

[jira] [Commented] (FLINK-17722) "Failed to find the file" in "build_wheels" stage

[ https://issues.apache.org/jira/browse/FLINK-17722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108071#comment-17108071 ] Dian Fu commented on FLINK-17722: - [~rmetzger] Thanks a lot for reporting this issue. I will take a look

[jira] [Assigned] (FLINK-17722) "Failed to find the file" in "build_wheels" stage

[ https://issues.apache.org/jira/browse/FLINK-17722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17722: --- Assignee: Huang Xingbo > "Failed to find the file" in "build_wheels" stage >

[jira] [Closed] (FLINK-17722) "Failed to find the file" in "build_wheels" stage

[ https://issues.apache.org/jira/browse/FLINK-17722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17722. --- Resolution: Fixed Merged to master via 38058087a35d2ae94abd89a2c0592f776c6e16b4 > "Failed to find the

[jira] [Updated] (FLINK-17722) "Failed to find the file" in "build_wheels" stage

[ https://issues.apache.org/jira/browse/FLINK-17722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17722: Affects Version/s: 1.11.0 > "Failed to find the file" in "build_wheels" stage >

[jira] [Commented] (FLINK-17724) PyFlink end-to-end test fails with Cannot run program "venv.zip/.conda/bin/python": error=2, No such file or directory

[ https://issues.apache.org/jira/browse/FLINK-17724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108146#comment-17108146 ] Dian Fu commented on FLINK-17724: - cc [~zhongwei] > PyFlink end-to-end test fails with Cannot run

[jira] [Commented] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

[ https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107232#comment-17107232 ] Dian Fu commented on FLINK-17378: - Another instance:

[jira] [Assigned] (FLINK-17555) docstring of pyflink.table.descriptors.FileSystem:1:duplicate object description of pyflink.table.descriptors.FileSystem

[ https://issues.apache.org/jira/browse/FLINK-17555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17555: --- Assignee: shuiqiangchen > docstring of pyflink.table.descriptors.FileSystem:1:duplicate object >

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

[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17092: --- Assignee: shuiqiangchen (was: Wei Zhong) > Pyflink failure for BlinkStreamDependencyTests and

[jira] [Closed] (FLINK-16565) Make Pipeline Json compitable between Java and Python if all Pipelinestage are Java ones

[ https://issues.apache.org/jira/browse/FLINK-16565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16565. --- Resolution: Resolved Merged to master via a7dccf1945d7b2b4abc726c4ca213677df17d8bc > Make Pipeline Json

[jira] [Updated] (FLINK-16650) Support LocalZonedTimestampType for Python UDF in blink planner

[ https://issues.apache.org/jira/browse/FLINK-16650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16650: Summary: Support LocalZonedTimestampType for Python UDF in blink planner (was: Support

[jira] [Created] (FLINK-16650) Support LocalZonedTimestampType for Python UDF of blink planner

Dian Fu created FLINK-16650: --- Summary: Support LocalZonedTimestampType for Python UDF of blink planner Key: FLINK-16650 URL: https://issues.apache.org/jira/browse/FLINK-16650 Project: Flink Issue

[jira] [Updated] (FLINK-16687) PyFlink Cannot determine simple type name "PythonScalarFunction$0"

[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16687: Priority: Major (was: Blocker) > PyFlink Cannot determine simple type name "PythonScalarFunction$0" >

[jira] [Assigned] (FLINK-16691) Adjust Python UDF document to remind users to install PyFlink on the cluster

[ https://issues.apache.org/jira/browse/FLINK-16691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16691: --- Assignee: Huang Xingbo > Adjust Python UDF document to remind users to install PyFlink on the

[jira] [Updated] (FLINK-16691) Adjust Python UDF document to remind users to install PyFlink on the cluster

[ https://issues.apache.org/jira/browse/FLINK-16691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16691: Component/s: API / Python > Adjust Python UDF document to remind users to install PyFlink on the cluster

[jira] [Commented] (FLINK-16691) Improve Python UDF documentation to remind users to install PyFlink on the cluster

[ https://issues.apache.org/jira/browse/FLINK-16691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063330#comment-17063330 ] Dian Fu commented on FLINK-16691: - Merged to master via 8a27bd91474d933dda6a0d99c79f303ec9f4ef58 >

[jira] [Updated] (FLINK-16691) Improve Python UDF documentation to remind users to install PyFlink on the cluster

[ https://issues.apache.org/jira/browse/FLINK-16691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16691: Summary: Improve Python UDF documentation to remind users to install PyFlink on the cluster (was: Adjust

[jira] [Closed] (FLINK-16691) Improve Python UDF documentation to remind users to install PyFlink on the cluster

[ https://issues.apache.org/jira/browse/FLINK-16691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16691. --- Resolution: Resolved > Improve Python UDF documentation to remind users to install PyFlink on the >

[jira] [Updated] (FLINK-16669) Support Python UDF in SQL function DDL

[ https://issues.apache.org/jira/browse/FLINK-16669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16669: Component/s: API / Python > Support Python UDF in SQL function DDL >

[jira] [Assigned] (FLINK-16665) Support Python UDF in SQL Function DDL (FLIP-106)

[ https://issues.apache.org/jira/browse/FLINK-16665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16665: --- Assignee: Wei Zhong > Support Python UDF in SQL Function DDL (FLIP-106) >

[jira] [Assigned] (FLINK-16669) Support Python UDF in SQL function DDL

[ https://issues.apache.org/jira/browse/FLINK-16669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16669: --- Assignee: Wei Zhong > Support Python UDF in SQL function DDL >

[jira] [Assigned] (FLINK-16667) Support new Python dependency configuration options in flink-client

[ https://issues.apache.org/jira/browse/FLINK-16667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16667: --- Assignee: Wei Zhong > Support new Python dependency configuration options in flink-client >

[jira] [Assigned] (FLINK-16666) Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-1: --- Assignee: Wei Zhong > Support new Python dependency configuration options in flink-java, >

[jira] [Assigned] (FLINK-16668) Support new Python dependency configuration options in flink-python

[ https://issues.apache.org/jira/browse/FLINK-16668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16668: --- Assignee: Wei Zhong > Support new Python dependency configuration options in flink-python >

[jira] [Assigned] (FLINK-16687) PyFlink Cannot determine simple type name "PythonScalarFunction$0"

[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16687: --- Assignee: Huang Xingbo > PyFlink Cannot determine simple type name "PythonScalarFunction$0" >

[jira] [Comment Edited] (FLINK-16691) Improve Python UDF documentation to remind users to install PyFlink on the cluster

[ https://issues.apache.org/jira/browse/FLINK-16691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063330#comment-17063330 ] Dian Fu edited comment on FLINK-16691 at 3/20/20, 2:48 PM: --- Merged to master

[jira] [Updated] (FLINK-16538) Restructure Python Table API documentation

[ https://issues.apache.org/jira/browse/FLINK-16538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16538: Fix Version/s: 1.10.1 > Restructure Python Table API documentation >

[jira] [Commented] (FLINK-16538) Restructure Python Table API documentation

[ https://issues.apache.org/jira/browse/FLINK-16538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063422#comment-17063422 ] Dian Fu commented on FLINK-16538: - Merged to release-1.10 via afe7c8e8346e7c8ecc844d8405619eed1ee588ad

[jira] [Comment Edited] (FLINK-16691) Improve Python UDF documentation to remind users to install PyFlink on the cluster

[ https://issues.apache.org/jira/browse/FLINK-16691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063330#comment-17063330 ] Dian Fu edited comment on FLINK-16691 at 3/20/20, 3:02 PM: --- Merged to master

[jira] [Commented] (FLINK-13483) PrestoS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064482#comment-17064482 ] Dian Fu commented on FLINK-13483: - Another instance of release-1.10 cron job: 

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

[ https://issues.apache.org/jira/browse/FLINK-16524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16524: Parent: FLINK-16747 Issue Type: Sub-task (was: Improvement) > Optimize the execution of Python

[jira] [Updated] (FLINK-15970) Optimize the Python UDF execution to only serialize the value

[ https://issues.apache.org/jira/browse/FLINK-15970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15970: Parent: FLINK-16747 Issue Type: Sub-task (was: Improvement) > Optimize the Python UDF execution

[jira] [Updated] (FLINK-16040) Change local import to global import

[ https://issues.apache.org/jira/browse/FLINK-16040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16040: Parent: FLINK-16747 Issue Type: Sub-task (was: Improvement) > Change local import to global

[jira] [Updated] (FLINK-16072) Optimize the performance of the write/read null mask in FlattenRowCoder

[ https://issues.apache.org/jira/browse/FLINK-16072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16072: Parent: FLINK-16747 Issue Type: Sub-task (was: Improvement) > Optimize the performance of the

[jira] [Updated] (FLINK-16071) Introduce FlattenRowCoder to solve the performance issue of __get_item__ in Row

[ https://issues.apache.org/jira/browse/FLINK-16071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16071: Parent: FLINK-16747 Issue Type: Sub-task (was: Improvement) > Introduce FlattenRowCoder to solve

[jira] [Created] (FLINK-16747) Performance improvements for Python UDF

Dian Fu created FLINK-16747: --- Summary: Performance improvements for Python UDF Key: FLINK-16747 URL: https://issues.apache.org/jira/browse/FLINK-16747 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-16252) Optimize the output emit logic to remove unnecessary overhead

[ https://issues.apache.org/jira/browse/FLINK-16252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16252: Parent: FLINK-16747 Issue Type: Sub-task (was: Improvement) > Optimize the output emit logic to

[jira] [Updated] (FLINK-16251) Optimize the cost of function call in ScalarFunctionOpertation

[ https://issues.apache.org/jira/browse/FLINK-16251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16251: Parent: FLINK-16747 Issue Type: Sub-task (was: Improvement) > Optimize the cost of function call

[jira] [Commented] (FLINK-13483) PrestoS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054273#comment-17054273 ] Dian Fu commented on FLINK-13483: - Another instance: 

<    4   5   6   7   8   9   10   11   12   13   >