[jira] [Created] (FLINK-16606) Throw exceptions for the data types which are not currently supported

Dian Fu created FLINK-16606: --- Summary: Throw exceptions for the data types which are not currently supported Key: FLINK-16606 URL: https://issues.apache.org/jira/browse/FLINK-16606 Project: Flink

[jira] [Created] (FLINK-16608) Support primitive data types for vectorized Python UDF

Dian Fu created FLINK-16608: --- Summary: Support primitive data types for vectorized Python UDF Key: FLINK-16608 URL: https://issues.apache.org/jira/browse/FLINK-16608 Project: Flink Issue Type:

[jira] [Created] (FLINK-16607) Update flink-fn-execution.proto adding more schema information

Dian Fu created FLINK-16607: --- Summary: Update flink-fn-execution.proto adding more schema information Key: FLINK-16607 URL: https://issues.apache.org/jira/browse/FLINK-16607 Project: Flink Issue

[jira] [Updated] (FLINK-16607) Update flink-fn-execution.proto adding more schema information

[ https://issues.apache.org/jira/browse/FLINK-16607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16607: Description: Currently the following information is missing in flink-fn-execution.proto: - the length

[jira] [Closed] (FLINK-16980) PyFlink UDF execution module is not compatible with protobuf 3.6.1

[ https://issues.apache.org/jira/browse/FLINK-16980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16980. --- Fix Version/s: 1.11.0 1.10.1 Resolution: Fixed Merged in - master via

[jira] [Updated] (FLINK-16980) PyFlink UDF execution module is not compatible with protobuf 3.6.1

[ https://issues.apache.org/jira/browse/FLINK-16980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16980: Affects Version/s: (was: 1.11.0) > PyFlink UDF execution module is not compatible with protobuf 3.6.1

[jira] [Updated] (FLINK-16980) Python UDF doesn't work with protobuf 3.6.1

[ https://issues.apache.org/jira/browse/FLINK-16980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16980: Summary: Python UDF doesn't work with protobuf 3.6.1 (was: PyFlink UDF execution module is not

[jira] [Created] (FLINK-16983) Support RowType in vectorized Python UDF

Dian Fu created FLINK-16983: --- Summary: Support RowType in vectorized Python UDF Key: FLINK-16983 URL: https://issues.apache.org/jira/browse/FLINK-16983 Project: Flink Issue Type: Task

[jira] [Assigned] (FLINK-16980) PyFlink UDF execution module is not compatible with protobuf 3.6.1

[ https://issues.apache.org/jira/browse/FLINK-16980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16980: --- Assignee: Huang Xingbo > PyFlink UDF execution module is not compatible with protobuf 3.6.1 >

[jira] [Assigned] (FLINK-16786) Fix pyarrow version incompatible problem

[ https://issues.apache.org/jira/browse/FLINK-16786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16786: --- Assignee: Rong Rong > Fix pyarrow version incompatible problem >

[jira] [Updated] (FLINK-16827) Kafka stream data sorted by time field throws null pointer exception under multiple concurrency

[ https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16827: Description: flink reads kafka data and sorts by time field. In the case of multiple concurrency, it

[jira] [Updated] (FLINK-16827) Kafka stream data sorted by time field throws null pointer exception under multiple concurrency

[ https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16827: Summary: Kafka stream data sorted by time field throws null pointer exception under multiple concurrency

[jira] [Updated] (FLINK-16827) FLINK 1.9.1 KAFKA stream data sorted by time field throws null pointer exception under multiple concurrency

[ https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16827: Summary: FLINK 1.9.1 KAFKA stream data sorted by time field throws null pointer exception under multiple

[jira] [Closed] (FLINK-16674) Add documentation about how to use user-defined metrics for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-16674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16674. --- Resolution: Resolved Merged to master via 41724c72f3f7e6aa4b7b9e64d7626eca7d367c1a > Add documentation

[jira] [Created] (FLINK-16914) Support ArrayType in vectorized Python UDF

Dian Fu created FLINK-16914: --- Summary: Support ArrayType in vectorized Python UDF Key: FLINK-16914 URL: https://issues.apache.org/jira/browse/FLINK-16914 Project: Flink Issue Type: Task

[jira] [Commented] (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:comment-tabpanel=17074469#comment-17074469 ] Dian Fu commented on FLINK-1: - Thanks [~aljoscha] and [~sunjincheng121] for your suggestions, make

[jira] [Created] (FLINK-16847) Support timestamp types in vectorized Python UDF

Dian Fu created FLINK-16847: --- Summary: Support timestamp types in vectorized Python UDF Key: FLINK-16847 URL: https://issues.apache.org/jira/browse/FLINK-16847 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-16608) Support primitive data types for vectorized Python UDF

[ https://issues.apache.org/jira/browse/FLINK-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16608: Issue Type: Task (was: Improvement) > Support primitive data types for vectorized Python UDF >

[jira] [Closed] (FLINK-16673) Support Counter, Gauge, Meter, Distribution metric type for Python UDTF

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

[jira] [Closed] (FLINK-16672) Support Counter, Gauge, Meter, Distribution metric type for Python UDF

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

[jira] [Created] (FLINK-16932) Remove unnecessary entries in the distribution jar NOTICE

Dian Fu created FLINK-16932: --- Summary: Remove unnecessary entries in the distribution jar NOTICE Key: FLINK-16932 URL: https://issues.apache.org/jira/browse/FLINK-16932 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-16932) Remove unnecessary entries in the distribution jar NOTICE

[ https://issues.apache.org/jira/browse/FLINK-16932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16932: --- Assignee: Dian Fu > Remove unnecessary entries in the distribution jar NOTICE >

[jira] [Commented] (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:comment-tabpanel=17073593#comment-17073593 ] Dian Fu commented on FLINK-1: - Hi [~aljoscha], as explained by [~zhongwei], the requirement is that

[jira] [Updated] (FLINK-15616) Move boot error messages from python-udf-boot.log to taskmanager's log file

[ https://issues.apache.org/jira/browse/FLINK-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15616: Fix Version/s: 1.10.1 > Move boot error messages from python-udf-boot.log to taskmanager's log file >

[jira] [Commented] (FLINK-16759) HiveModuleTest failed to compile on release-1.10

[ https://issues.apache.org/jira/browse/FLINK-16759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17066321#comment-17066321 ] Dian Fu commented on FLINK-16759: - cc [~lirui] [~lzljs3620320] > HiveModuleTest failed to compile on

[jira] [Created] (FLINK-16759) HiveModuleTest failed to compile on release-1.10

Dian Fu created FLINK-16759: --- Summary: HiveModuleTest failed to compile on release-1.10 Key: FLINK-16759 URL: https://issues.apache.org/jira/browse/FLINK-16759 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-16671) Support define scopes and variables on Python metric group

[ https://issues.apache.org/jira/browse/FLINK-16671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16671: Description: In this ticket, we are going to support define scopes and variables on Python metric group,

[jira] [Closed] (FLINK-16671) Support define scopes and variables on Python metric group

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

[jira] [Closed] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17394. --- Fix Version/s: (was: 1.11.0) Resolution: Invalid Thanks [~aljoscha][~kkl0u] for the clarify. I

[jira] [Closed] (FLINK-16971) Support Python UDF in SQL Client (FLIP-114)

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

[jira] [Updated] (FLINK-16971) Support Python UDF in SQL Client (FLIP-114)

[ https://issues.apache.org/jira/browse/FLINK-16971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16971: Fix Version/s: 1.11.0 > Support Python UDF in SQL Client (FLIP-114) >

[jira] [Updated] (FLINK-16971) Support Python UDF in SQL Client (FLIP-114)

[ https://issues.apache.org/jira/browse/FLINK-16971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16971: Issue Type: New Feature (was: Task) > Support Python UDF in SQL Client (FLIP-114) >

[jira] [Updated] (FLINK-16971) Support Python UDF in SQL Client (FLIP-114)

[ https://issues.apache.org/jira/browse/FLINK-16971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16971: Issue Type: Task (was: Improvement) > Support Python UDF in SQL Client (FLIP-114) >

[jira] [Updated] (FLINK-17395) Add the sign and sha logic for PyFlink wheel packages

[ https://issues.apache.org/jira/browse/FLINK-17395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17395: Component/s: Release System API / Python > Add the sign and sha logic for PyFlink wheel

[jira] [Updated] (FLINK-17395) Add the sign and shasum logic for PyFlink wheel packages

[ https://issues.apache.org/jira/browse/FLINK-17395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17395: Summary: Add the sign and shasum logic for PyFlink wheel packages (was: Add the sign and sha logic for

[jira] [Updated] (FLINK-17395) Add the sign and sha logic for PyFlink wheel packages

[ https://issues.apache.org/jira/browse/FLINK-17395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17395: Component/s: (was: API / Python) > Add the sign and sha logic for PyFlink wheel packages >

[jira] [Closed] (FLINK-17395) Add the sign and sha logic for PyFlink wheel packages

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

[jira] [Closed] (FLINK-17418) Windows system is not supported currently

[ https://issues.apache.org/jira/browse/FLINK-17418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17418. --- Resolution: Duplicate [~taosiyuan...@163.com] There is an existing JIRA(FLINK-12717) dedicated for the

[jira] [Commented] (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:comment-tabpanel=17095112#comment-17095112 ] Dian Fu commented on FLINK-17454: - cc [~zhongwei] > test_configuration.py

[jira] [Updated] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control

[ https://issues.apache.org/jira/browse/FLINK-17436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17436: Fix Version/s: 1.11.0 > When submitting Python job via "flink run" a IllegalAccessError will be > raised

[jira] [Assigned] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control

[ https://issues.apache.org/jira/browse/FLINK-17436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17436: --- Assignee: Wei Zhong > When submitting Python job via "flink run" a IllegalAccessError will be >

[jira] [Updated] (FLINK-16667) Support the Python dependency configuration options in CliFrontend

[ https://issues.apache.org/jira/browse/FLINK-16667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16667: Summary: Support the Python dependency configuration options in CliFrontend (was: Support new Python

[jira] [Closed] (FLINK-16667) Support the Python dependency configuration options in CliFrontend

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

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

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

[jira] [Closed] (FLINK-17215) Clean the build document for Pyflink

[ https://issues.apache.org/jira/browse/FLINK-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17215. --- Resolution: Resolved Merged to release-1.9 via 8c8fa36f118ac841990fbaced14e71aeb946edf1 > Clean the build

[jira] [Updated] (FLINK-17215) Clean the build document for Pyflink

[ https://issues.apache.org/jira/browse/FLINK-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17215: Component/s: Documentation > Clean the build document for Pyflink >

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

[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091081#comment-17091081 ] Dian Fu commented on FLINK-17188: - Thanks [~rmetzger], I have merged the PR. Let's see if this issue

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

[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17188. --- Resolution: Fixed Merged to master via 681371b8328cfbec3904395acddf6453609aeb73 > Failed to download conda

[jira] [Closed] (FLINK-17345) Support register and get Python UDF in Catalog

[ https://issues.apache.org/jira/browse/FLINK-17345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17345. --- Fix Version/s: 1.11.0 Resolution: Fixed Merged to master via

[jira] [Assigned] (FLINK-17345) Support register and get Python UDF in Catalog

[ https://issues.apache.org/jira/browse/FLINK-17345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17345: --- Assignee: Wei Zhong > Support register and get Python UDF in Catalog >

[jira] [Updated] (FLINK-17345) Support register and get Python UDF in Catalog

[ https://issues.apache.org/jira/browse/FLINK-17345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17345: Issue Type: Task (was: Improvement) > Support register and get Python UDF in Catalog >

[jira] [Closed] (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 closed FLINK-16669. --- Resolution: Resolved Merged to master via d1f53ae0b46c1f4f73f5fa920e0c34934d16177c and

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

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

[jira] [Assigned] (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 reassigned FLINK-13811: --- Assignee: Dian Fu > Support converting flink table to pandas dataframe >

[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: Fix Version/s: 1.11.0 > Support converting flink table to pandas dataframe >

[jira] [Closed] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17471. --- Resolution: Fixed > Move LICENSE and NOTICE files to root directory of python distribution >

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096484#comment-17096484 ] Dian Fu commented on FLINK-17471: - Thanks [~zhongwei] for addressing this and thanks [~rmetzger] for the

[jira] [Closed] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control

[ https://issues.apache.org/jira/browse/FLINK-17436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17436. --- Resolution: Fixed Merged to master via bdf4f7127353a436d03ce18d145be0e0cdb9fdd4 > When submitting Python

[jira] [Assigned] (FLINK-17311) Add executable permissions to the script in the wheel package

[ https://issues.apache.org/jira/browse/FLINK-17311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17311: --- Assignee: Huang Xingbo > Add executable permissions to the script in the wheel package >

[jira] [Updated] (FLINK-17311) Add executable permissions to the script in the wheel package

[ https://issues.apache.org/jira/browse/FLINK-17311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17311: Component/s: Build System / Azure Pipelines > Add executable permissions to the script in the wheel

[jira] [Updated] (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 updated FLINK-17146: Fix Version/s: 1.11.0 > Support conversion between PyFlink Table and Pandas DataFrame >

[jira] [Updated] (FLINK-17414) Update the documentation about PyFlink building about Cython support

[ https://issues.apache.org/jira/browse/FLINK-17414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17414: Summary: Update the documentation about PyFlink building about Cython support (was: Change the steps of

[jira] [Closed] (FLINK-17414) Change the steps of building PyFlink in doc

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

[jira] [Closed] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17254. --- Fix Version/s: 1.9.4 1.10.1 Resolution: Resolved Merged to - master via

[jira] [Assigned] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17254: --- Assignee: shuiqiangchen > Improve the PyFlink documentation and examples to use SQL DDL for

[jira] [Updated] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17254: Component/s: Documentation > Improve the PyFlink documentation and examples to use SQL DDL for

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096133#comment-17096133 ] Dian Fu commented on FLINK-17471: - [~liyu] Thanks for filing this ticket. I will take a look ASAP. >

[jira] [Closed] (FLINK-17628) Remove the unnecessary py4j log information

[ https://issues.apache.org/jira/browse/FLINK-17628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17628. --- Fix Version/s: 1.11.0 Resolution: Resolved Merged to master via

[jira] [Assigned] (FLINK-17628) Remove the unnecessary py4j log information

[ https://issues.apache.org/jira/browse/FLINK-17628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17628: --- Assignee: shuiqiangchen > Remove the unnecessary py4j log information >

[jira] [Closed] (FLINK-17612) The Python command line options are ignored by the CliOptionsParser in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17612. --- Fix Version/s: 1.11.0 Resolution: Fixed Merged to master via

[jira] [Assigned] (FLINK-17612) The Python command line options are ignored by the CliOptionsParser in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17612: --- Assignee: Wei Zhong > The Python command line options are ignored by the CliOptionsParser in SQL

[jira] [Updated] (FLINK-17612) Support Python command line options in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17612: Parent: FLINK-16971 Issue Type: Sub-task (was: Bug) > Support Python command line options in SQL

[jira] [Updated] (FLINK-17612) Support Python command line options in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17612: Summary: Support Python command line options in SQL Client (was: The Python command line options are

[jira] [Assigned] (FLINK-17609) Execute the script directly when user specified the entry script with "-py" rather than run as module.

[ https://issues.apache.org/jira/browse/FLINK-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17609: --- Assignee: shuiqiangchen > Execute the script directly when user specified the entry script with

[jira] [Closed] (FLINK-17609) Execute the script directly when user specified the entry script with "-py" rather than run as module.

[ https://issues.apache.org/jira/browse/FLINK-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17609. --- Resolution: Fixed Merged to master via 89d46fac30cdf8b86ae9709bf86f4d9d42802014 > Execute the script

[jira] [Updated] (FLINK-16225) Metaspace Out Of Memory should be handled as Fatal Error in TaskManager

[ https://issues.apache.org/jira/browse/FLINK-16225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16225: Fix Version/s: (was: 1.10.1) 1.10.2 > Metaspace Out Of Memory should be handled as

[jira] [Assigned] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

[ https://issues.apache.org/jira/browse/FLINK-17772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17772: --- Assignee: Dian Fu > test_pandas_udf.py: NoClassDefFoundError >

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

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

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

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

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109281#comment-17109281 ] Dian Fu commented on FLINK-17768: - cc [~AHeise] >

[jira] [Commented] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

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

[jira] [Assigned] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17764: --- Assignee: xushiwei > Update tips about the default planner when the planner parameter value is not

[jira] [Commented] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109277#comment-17109277 ] Dian Fu commented on FLINK-17764: - [~xushiwei] Thanks for the contribution. Have assigned the issue to

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

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

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

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

[jira] [Created] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

Dian Fu created FLINK-17768: --- Summary: UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable Key: FLINK-17768 URL: https://issues.apache.org/jira/browse/FLINK-17768

[jira] [Comment Edited] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109491#comment-17109491 ] Dian Fu edited comment on FLINK-17771 at 5/17/20, 2:10 PM: --- When I tried to

[jira] [Commented] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109491#comment-17109491 ] Dian Fu commented on FLINK-17771: - When I tried to reproduce this problem locally with JDK 11, it will

[jira] [Updated] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17764: Affects Version/s: 1.11.0 > Update tips about the default planner when the planner parameter value is not

[jira] [Closed] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17764. --- Resolution: Fixed master: f631b4926bc4d51e89b619fc695675c66f3ccee3 > Update tips about the default planner

[jira] [Closed] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

[ https://issues.apache.org/jira/browse/FLINK-17772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17772. --- Resolution: Fixed master: 6a58ce0a0c14f64e3415480c7427eb50509d44c8 > test_pandas_udf.py:

[jira] [Commented] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

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

[jira] [Updated] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17764: Fix Version/s: 1.11.0 > Update tips about the default planner when the planner parameter value is not >

[jira] [Closed] (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 closed FLINK-17700. --- Resolution: Fixed Merged to - release-1.10 via 2bc4628876715698c9bae542e36014344a93c42b - release-1.9 via

[jira] [Updated] (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 updated FLINK-17700: Fix Version/s: (was: 1.10.0) (was: 1.9.0) 1.9.4

[jira] [Updated] (FLINK-17125) Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

[ https://issues.apache.org/jira/browse/FLINK-17125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17125: Fix Version/s: 1.11.0 1.10.1 > Add a Usage Notes Page to Answer Common Questions

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

[ https://issues.apache.org/jira/browse/FLINK-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-12717. --- Resolution: Resolved Merged to master via 7a28dbe754397cd455f0b3d139abe0ab646b2627 > Add windows support

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

[ https://issues.apache.org/jira/browse/FLINK-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12717: Fix Version/s: 1.11.0 > Add windows support for PyFlink > --- > >

[jira] [Updated] (FLINK-16225) Metaspace Out Of Memory should be handled as Fatal Error in TaskManager

[ https://issues.apache.org/jira/browse/FLINK-16225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16225: Fix Version/s: (was: 1.10.2) 1.10.1 > Metaspace Out Of Memory should be handled as

[jira] [Updated] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16014: Fix Version/s: 1.10.1 > S3 plugin ClassNotFoundException SAXParser >

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