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

[ 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: 1.9.2 > KafkaITCase#prepare failed in travis > > >

[jira] [Created] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

Dian Fu created FLINK-15493: --- Summary: FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis Key: FLINK-15493 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15493: Affects Version/s: (was: 1.10.0) > FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartiti

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009287#comment-17009287 ] Dian Fu commented on FLINK-15493: - cc [~becket_qin] > FlinkKafkaInternalProducerITCase.

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15493: Description: FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinato

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15493: Description: FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinato

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

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

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009422#comment-17009422 ] Dian Fu commented on FLINK-15493: - I checked the code and there are no changes for the K

[jira] [Assigned] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17586: --- Assignee: Wei Zhong > Due to the new behavior of the flink-table module the Python dependency > ma

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17586: Fix Version/s: 1.11.0 > Due to the new behavior of the flink-table module the Python dependency > managem

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17586: Affects Version/s: 1.11.0 > Due to the new behavior of the flink-table module the Python dependency > man

[jira] [Updated] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17585: Fix Version/s: 1.11.0 > "PythonProgramOptions" changes the entry point class when user submit a Java > sq

[jira] [Assigned] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17585: --- Assignee: Wei Zhong > "PythonProgramOptions" changes the entry point class when user submit a Java

[jira] [Updated] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17585: Affects Version/s: 1.11.0 > "PythonProgramOptions" changes the entry point class when user submit a Java

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17103244#comment-17103244 ] Dian Fu commented on FLINK-17596: - cc [~zhongwei] > Unstable PyFlinkBlinkStreamUserDefi

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

Dian Fu created FLINK-17597: --- Summary: JavaSqlTests#test_java_sql_ddl is instable Key: FLINK-17597 URL: https://issues.apache.org/jira/browse/FLINK-17597 Project: Flink Issue Type: Bug Co

[jira] [Updated] (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 updated FLINK-17597: Labels: test-stability (was: ) > JavaSqlTests#test_java_sql_ddl is instable > ---

[jira] [Closed] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17585. --- Resolution: Fixed Merged to master via eb33d98eadeb99ef9bbc668cc3e96fba3de5edfa > "PythonProgramOptions" ch

[jira] [Closed] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17586. --- Resolution: Fixed Merged to master via 1a734c2b95fab7b2a0b62e5aded899b1efd91508 > Due to the new behavior o

[jira] [Comment Edited] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17103262#comment-17103262 ] Dian Fu edited comment on FLINK-17586 at 5/9/20, 11:35 AM: --- Me

[jira] [Assigned] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17585: --- Assignee: shuiqiangchen (was: Wei Zhong) > "PythonProgramOptions" changes the entry point class wh

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

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

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

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

[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] [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&focusedCommentId=17103763#comment-17103763 ] Dian Fu commented on FLINK-16944: - Add fix version of "1.10.1" as I noticed that it has

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

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

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

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

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

[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-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&focusedCommentId=17103779#comment-17103779 ] Dian Fu commented on FLINK-15998: - Have removed the fix version of "1.10.1" as actually

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

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

[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] [Commented] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

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

[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) > Kafka010ProducerITCase>KafkaProduc

[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&focusedCommentId=17103784#comment-17103784 ] Dian Fu commented on FLINK-14223: - Removed the fix version to avoid it appears in the re

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

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

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

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

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

[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] [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] [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 722f8445b7f8f2df90af9e8c4b3cfa231d71129d

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

[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-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 > testMethod#test_udf_in_join

[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 > testMethod#test_udf_in

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

[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&focusedCommentId=17106835#comment-17106835 ] Dian Fu commented on FLINK-17679: - [~hxbks2ks] could you give an example in which case i

[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&focusedCommentId=17106883#comment-17106883 ] Dian Fu commented on FLINK-17679: - I mean a specific example job > Fix the bug of encod

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

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

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

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

[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&focusedCommentId=17107232#comment-17107232 ] Dian Fu commented on FLINK-17378: - Another instance: https://dev.azure.com/apache-flink

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

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

[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&focusedCommentId=17101491#comment-17101491 ] Dian Fu edited comment on FLINK-12717 at 5/15/20, 1:56 AM: --- Me

[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] [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) > StreamSqlTests.test_execute

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

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

[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&focusedCommentId=17108071#comment-17108071 ] Dian Fu commented on FLINK-17722: - [~rmetzger] Thanks a lot for reporting this issue. I

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

[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&focusedCommentId=17108146#comment-17108146 ] Dian Fu commented on FLINK-17724: - cc [~zhongwei] > PyFlink end-to-end test fails with

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

[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 > "venv.zip/.conda/bin/

[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-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&focusedCommentId=17108794#comment-17108794 ] Dian Fu commented on FLINK-17285: - [~billrao] Thanks a for working on this ticket. I can

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

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

[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&focusedCommentId=17108797#comment-17108797 ] Dian Fu edited comment on FLINK-16747 at 5/16/20, 1:20 AM: --- Th

[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] [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] [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] [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: Huang Xingbo (was: Dian Fu) > Support Flink Python User-Defined Stateless Function for T

[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&focusedCommentId=17108964#comment-17108964 ] Dian Fu commented on FLINK-17743: - [~lzljs3620320] Thanks for reporting this issue. It i

[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] [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&focusedCommentId=17109277#comment-17109277 ] Dian Fu commented on FLINK-17764: - [~xushiwei] Thanks for the contribution. Have assigne

[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

<    6   7   8   9   10   11   12   13   14   15   >