[jira] [Updated] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody

[ https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-35302: Fix Version/s: 1.20.0 (was: 1.19.1) > Flink REST server throws exception on

[jira] [Comment Edited] (FLINK-35112) Membership for Row class does not include field names

[ https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845526#comment-17845526 ] Dian Fu edited comment on FLINK-35112 at 5/11/24 2:56 AM: -- Fix in - master via

[jira] [Updated] (FLINK-35112) Membership for Row class does not include field names

[ https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-35112: Fix Version/s: 1.19.1 > Membership for Row class does not include field names >

[jira] [Closed] (FLINK-35112) Membership for Row class does not include field names

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

[jira] [Assigned] (FLINK-35112) Membership for Row class does not include field names

[ https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-35112: --- Assignee: Wouter Zorgdrager > Membership for Row class does not include field names >

[jira] [Assigned] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody

[ https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-35302: --- Assignee: Juntao Hu > Flink REST server throws exception on unknown fields in RequestBody >

[jira] [Closed] (FLINK-35208) Respect pipeline.cached-files during processing Python dependencies

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

[jira] [Updated] (FLINK-35208) Respect pipeline.cached-files during processing Python dependencies

[ https://issues.apache.org/jira/browse/FLINK-35208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-35208: Description: Currently, PyFlink will make use of distributed cache

[jira] [Created] (FLINK-35208) Respect pipeline.cached-files during processing Python dependencies

Dian Fu created FLINK-35208: --- Summary: Respect pipeline.cached-files during processing Python dependencies Key: FLINK-35208 URL: https://issues.apache.org/jira/browse/FLINK-35208 Project: Flink

[jira] [Commented] (FLINK-35112) Membership for Row class does not include field names

[ https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837965#comment-17837965 ] Dian Fu commented on FLINK-35112: - Great (y). Thanks [~wzorgdrager]  > Membership for Row class does

[jira] [Commented] (FLINK-35112) Membership for Row class does not include field names

[ https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837512#comment-17837512 ] Dian Fu commented on FLINK-35112: - Sounds reasonable for me. [~wzorgdrager] Do you want to submit a PR

[jira] [Created] (FLINK-34985) It doesn't support to access fields by name for map function in thread mode

Dian Fu created FLINK-34985: --- Summary: It doesn't support to access fields by name for map function in thread mode Key: FLINK-34985 URL: https://issues.apache.org/jira/browse/FLINK-34985 Project: Flink

[jira] [Commented] (FLINK-33220) PyFlink support for Datagen connector

[ https://issues.apache.org/jira/browse/FLINK-33220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829346#comment-17829346 ] Dian Fu commented on FLINK-33220: - [~liu.chong]  I missed this ticket. Feel free to submit the PR and

[jira] [Comment Edited] (FLINK-33220) PyFlink support for Datagen connector

[ https://issues.apache.org/jira/browse/FLINK-33220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829346#comment-17829346 ] Dian Fu edited comment on FLINK-33220 at 3/21/24 1:24 AM: -- [~liu.chong]  Sorry,

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818326#comment-17818326 ] Dian Fu commented on FLINK-34202: - [~lincoln.86xy] It will randomly select one Python version to test

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818242#comment-17818242 ] Dian Fu commented on FLINK-34202: - [~hxbks2ks] Could you help to take a look at this issue? > python

[jira] [Closed] (FLINK-33613) Python UDF Runner process leak in Process Mode

[ https://issues.apache.org/jira/browse/FLINK-33613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-33613. --- Fix Version/s: 1.19.0 1.18.1 1.17.3 Resolution: Fixed Fixed

[jira] [Assigned] (FLINK-33613) Python UDF Runner process leak in Process Mode

[ https://issues.apache.org/jira/browse/FLINK-33613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-33613: --- Assignee: Dian Fu > Python UDF Runner process leak in Process Mode >

[jira] [Closed] (FLINK-33225) Python API incorrectly passes `JVM_ARGS` as single argument

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

[jira] [Assigned] (FLINK-33225) Python API incorrectly passes `JVM_ARGS` as single argument

[ https://issues.apache.org/jira/browse/FLINK-33225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-33225: --- Assignee: Deepyaman Datta > Python API incorrectly passes `JVM_ARGS` as single argument >

[jira] [Commented] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786595#comment-17786595 ] Dian Fu commented on FLINK-33528: - Thanks very much for the efforts (y) > Externalize Python connector

[jira] [Updated] (FLINK-33529) PyFlink fails with "No module named 'cloudpickle"

[ https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-33529: Affects Version/s: 1.17.2 > PyFlink fails with "No module named 'cloudpickle" >

[jira] [Closed] (FLINK-33529) PyFlink fails with "No module named 'cloudpickle"

[ https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-33529. --- Fix Version/s: 1.19.0 1.18.1 1.17.3 Resolution: Fixed >

[jira] [Commented] (FLINK-33529) PyFlink fails with "No module named 'cloudpickle"

[ https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785727#comment-17785727 ] Dian Fu commented on FLINK-33529: - Fixed in: * master via 34d9594ab1e5412371b77912f120b7949c92dcdd *

[jira] [Assigned] (FLINK-33529) PyFlink fails with "No module named 'cloudpickle"

[ https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-33529: --- Assignee: Prabhu Joseph > PyFlink fails with "No module named 'cloudpickle" >

[jira] [Commented] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785708#comment-17785708 ] Dian Fu commented on FLINK-33528: - Yes, I think so. > Externalize Python connector code >

[jira] [Commented] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785456#comment-17785456 ] Dian Fu commented on FLINK-33528: - I think it's fair enough to externalize Python connectors. 

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762927#comment-17762927 ] Dian Fu commented on FLINK-32962: - +1 to backport to Flink 1.17 and 1.18, especially Flink 1.18. >

[jira] [Assigned] (FLINK-32962) Failure to install python dependencies from requirements file

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-32962: --- Assignee: Aleksandr Pilipenko > Failure to install python dependencies from requirements file >

[jira] [Commented] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

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

[jira] [Closed] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32758. --- Fix Version/s: 1.18.0 1.17.2 Resolution: Fixed > PyFlink bounds are overly

[jira] [Commented] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760238#comment-17760238 ] Dian Fu commented on FLINK-32758: - Fixed in master via 5b5a0af15d57ed4424cf8dd744808433e397ebc4 >

[jira] [Commented] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759969#comment-17759969 ] Dian Fu commented on FLINK-32758: - Have verified that upgrade *{*}cibuildwheel{*}* doesn't work and

[jira] [Commented] (FLINK-32981) Add python dynamic Flink home detection

[ https://issues.apache.org/jira/browse/FLINK-32981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759855#comment-17759855 ] Dian Fu commented on FLINK-32981: - [~gaborgsomogyi] [~mbalassi] It seems that this PR breaks the PyFlink

[jira] [Created] (FLINK-32989) PyFlink wheel package build failed

Dian Fu created FLINK-32989: --- Summary: PyFlink wheel package build failed Key: FLINK-32989 URL: https://issues.apache.org/jira/browse/FLINK-32989 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759777#comment-17759777 ] Dian Fu commented on FLINK-32758: - [~deepyaman] Actually the tests have passed on the CI:

[jira] [Updated] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-32758: Attachment: image-2023-08-29-10-19-37-977.png > PyFlink bounds are overly restrictive and outdated >

[jira] [Commented] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759774#comment-17759774 ] Dian Fu commented on FLINK-32758: - [~Sergey Nuyanzin] [~deepyaman]  I have submitted a hotfix to

[jira] [Commented] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758790#comment-17758790 ] Dian Fu commented on FLINK-32758: - Will backport to release-1.17 and release-1.8 branch after one

[jira] [Commented] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

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

[jira] [Assigned] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-32758: --- Assignee: Deepyaman Datta > PyFlink bounds are overly restrictive and outdated >

[jira] [Created] (FLINK-32724) Mark CEP API classes as Public / PublicEvolving

Dian Fu created FLINK-32724: --- Summary: Mark CEP API classes as Public / PublicEvolving Key: FLINK-32724 URL: https://issues.apache.org/jira/browse/FLINK-32724 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-32544) PythonFunctionFactoryTest fails on Java 17

[ https://issues.apache.org/jira/browse/FLINK-32544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-32544: --- Assignee: Dian Fu > PythonFunctionFactoryTest fails on Java 17 >

[jira] [Updated] (FLINK-32536) Python tests fail with Arrow DirectBuffer exception

[ https://issues.apache.org/jira/browse/FLINK-32536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-32536: Fix Version/s: 1.18.0 > Python tests fail with Arrow DirectBuffer exception >

[jira] [Closed] (FLINK-32536) Python tests fail with Arrow DirectBuffer exception

[ https://issues.apache.org/jira/browse/FLINK-32536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32536. --- Resolution: Fixed Fixed in master via 7f34df40c0de8e7bffd149196851f89012faf842 > Python tests fail with

[jira] [Closed] (FLINK-32327) Python Kafka connector runs into strange NullPointerException

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

[jira] [Assigned] (FLINK-32327) Python Kafka connector runs into strange NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-32327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-32327: --- Assignee: Dian Fu > Python Kafka connector runs into strange NullPointerException >

[jira] [Commented] (FLINK-32327) Python Kafka connector runs into strange NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-32327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738519#comment-17738519 ] Dian Fu commented on FLINK-32327: - Thanks (y). I will find some time to investigate this issue next

[jira] [Commented] (FLINK-32327) Python Kafka connector runs into strange NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-32327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733729#comment-17733729 ] Dian Fu commented on FLINK-32327: - PS: I can help to dig into this problem if we know which ones are

[jira] [Commented] (FLINK-32327) Python Kafka connector runs into strange NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-32327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733728#comment-17733728 ] Dian Fu commented on FLINK-32327: - [~chesnay] It seems that you have disabled the entire Python tests

[jira] [Closed] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32136. --- Fix Version/s: 1.18.0 1.16.3 1.17.2 Assignee: Dian Fu

[jira] [Commented] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733327#comment-17733327 ] Dian Fu commented on FLINK-32136: - [~wash] I have submitted a PR. Could you help to review? It would be

[jira] [Comment Edited] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733327#comment-17733327 ] Dian Fu edited comment on FLINK-32136 at 6/16/23 5:25 AM: -- [~wash] I have

[jira] [Closed] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32034. --- Fix Version/s: 1.18.0 1.17.2 Assignee: Colten Pilgreen Resolution: Fixed

[jira] [Commented] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

[ https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733017#comment-17733017 ] Dian Fu commented on FLINK-32136: - [~wash] Good catch! This seems like a critical problem. Would you

[jira] [Updated] (FLINK-32040) The WatermarkStrategy defined with the Function(with_idleness) report an error

[ https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-32040: Affects Version/s: 1.17.0 1.16.0 > The WatermarkStrategy defined with the

[jira] [Commented] (FLINK-32040) The WatermarkStrategy defined with the Function(with_idleness) report an error

[ https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732524#comment-17732524 ] Dian Fu commented on FLINK-32040: - Good catch! I think you are right that this is a bug. cc [~Juntao Hu] 

[jira] [Updated] (FLINK-32040) The WatermarkStrategy defined with the Function(with_idleness) report an error

[ https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-32040: Priority: Major (was: Blocker) > The WatermarkStrategy defined with the Function(with_idleness) report

[jira] [Commented] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732518#comment-17732518 ] Dian Fu commented on FLINK-32034: - [~coltenp] Thanks for reporting this issue and the finding. Would you

[jira] [Closed] (FLINK-32207) Error import Pyflink.table.descriptors due to python3.10 version mismatch

[ https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32207. --- Resolution: Duplicate > Error import Pyflink.table.descriptors due to python3.10 version mismatch >

[jira] [Commented] (FLINK-32207) Error import Pyflink.table.descriptors due to python3.10 version mismatch

[ https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732515#comment-17732515 ] Dian Fu commented on FLINK-32207: - This seems duplicate with FLINK-32206. Closing this ticket~. Feel

[jira] [Commented] (FLINK-32206) ModuleNotFoundError for Pyflink.table.descriptors wheel version mismatch

[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732513#comment-17732513 ] Dian Fu commented on FLINK-32206: -  'Kafka' has already been removed from 'pyflink.table.descriptors'. I

[jira] [Resolved] (FLINK-31916) Python API only respects deprecated env.java.opts key

[ https://issues.apache.org/jira/browse/FLINK-31916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu resolved FLINK-31916. - Resolution: Fixed Merged to master via 626d70d86d3bee944edf548606b38042f31e09b6 > Python API only

[jira] [Closed] (FLINK-32056) Update the used Pulsar connector in flink-python to 4.0.0

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

[jira] [Closed] (FLINK-32131) Support specifying hadoop config dir for Python HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-32131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32131. --- Resolution: Fixed Merged to master via 5a89d22c146f451f12fd0c6de64804d315e1f4b6 > Support specifying

[jira] [Created] (FLINK-32131) Support specifying hadoop config dir for Python HiveCatalog

Dian Fu created FLINK-32131: --- Summary: Support specifying hadoop config dir for Python HiveCatalog Key: FLINK-32131 URL: https://issues.apache.org/jira/browse/FLINK-32131 Project: Flink Issue

[jira] [Closed] (FLINK-20794) Support to select distinct columns in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20794. --- Fix Version/s: (was: 1.18.0) Resolution: Not A Problem > Support to select distinct columns in

[jira] [Commented] (FLINK-20794) Support to select distinct columns in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722623#comment-17722623 ] Dian Fu commented on FLINK-20794: - Thanks for the analysis. Since string based interfaces have been

[jira] [Comment Edited] (FLINK-31968) [PyFlink] 1.17.0 version on M1 processor

[ https://issues.apache.org/jira/browse/FLINK-31968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719599#comment-17719599 ] Dian Fu edited comment on FLINK-31968 at 5/5/23 2:27 AM: - [~gradysnik] Thanks

[jira] [Commented] (FLINK-31968) [PyFlink] 1.17.0 version on M1 processor

[ https://issues.apache.org/jira/browse/FLINK-31968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719599#comment-17719599 ] Dian Fu commented on FLINK-31968: - [~gradysnik] Thanks for the confirmation. I'm closing this ticket

[jira] [Closed] (FLINK-31968) [PyFlink] 1.17.0 version on M1 processor

[ https://issues.apache.org/jira/browse/FLINK-31968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-31968. --- Resolution: Duplicate > [PyFlink] 1.17.0 version on M1 processor >

[jira] [Updated] (FLINK-31988) Implement Python wrapper for new KDS source

[ https://issues.apache.org/jira/browse/FLINK-31988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-31988: Component/s: API / Python Connectors / Kinesis > Implement Python wrapper for new KDS

[jira] [Commented] (FLINK-20794) Support to select distinct columns in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719245#comment-17719245 ] Dian Fu commented on FLINK-20794: - [~supercmmetry] Thanks for taking this ticket. Have assigned it to

[jira] [Assigned] (FLINK-20794) Support to select distinct columns in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20794: --- Assignee: Vishaal Selvaraj > Support to select distinct columns in the Table API >

[jira] [Comment Edited] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716967#comment-17716967 ] Dian Fu edited comment on FLINK-28786 at 4/27/23 10:04 AM: --- Fixed in: -

[jira] [Closed] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28786. --- Fix Version/s: 1.17.1 (was: 1.17.0) Resolution: Fixed > Cannot run PyFlink

[jira] [Commented] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716967#comment-17716967 ] Dian Fu commented on FLINK-28786: - Fixed in: - master via a3368635e3d06f764d144f8c8e2e06e499e79665 -

[jira] [Created] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged

Dian Fu created FLINK-31949: --- Summary: The state of CountTumblingWindowAssigner of Python DataStream API were never purged Key: FLINK-31949 URL: https://issues.apache.org/jira/browse/FLINK-31949 Project:

[jira] [Comment Edited] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716757#comment-17716757 ] Dian Fu edited comment on FLINK-28786 at 4/26/23 2:41 PM: -- Reopen it as one

[jira] [Reopened] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reopened FLINK-28786: - Reopen it as one user reported an issue related to Mac M1

[jira] [Updated] (FLINK-31905) Exception thrown when accessing nested field of the result of Python UDF with complex result type

[ https://issues.apache.org/jira/browse/FLINK-31905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-31905: Description: For the following job: {code} import logging, sys from pyflink.common import Row from

[jira] [Created] (FLINK-31905) Exception thrown when accessing nested field of the result of Python UDF with complex type

Dian Fu created FLINK-31905: --- Summary: Exception thrown when accessing nested field of the result of Python UDF with complex type Key: FLINK-31905 URL: https://issues.apache.org/jira/browse/FLINK-31905

[jira] [Updated] (FLINK-31905) Exception thrown when accessing nested field of the result of Python UDF with complex result type

[ https://issues.apache.org/jira/browse/FLINK-31905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-31905: Summary: Exception thrown when accessing nested field of the result of Python UDF with complex result

[jira] [Created] (FLINK-31861) Introduce ByteArraySchema which serialize/deserialize data of type byte array

Dian Fu created FLINK-31861: --- Summary: Introduce ByteArraySchema which serialize/deserialize data of type byte array Key: FLINK-31861 URL: https://issues.apache.org/jira/browse/FLINK-31861 Project: Flink

[jira] [Commented] (FLINK-28528) Table.getSchema fails on table with watermark

[ https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709597#comment-17709597 ] Dian Fu commented on FLINK-28528: - The exception happens when converting TableSchema to ResolvedSchema

[jira] [Commented] (FLINK-28528) Table.getSchema fails on table with watermark

[ https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709595#comment-17709595 ] Dian Fu commented on FLINK-28528: - The root cause is that currently table.get_schema() only supports

[jira] [Commented] (FLINK-28528) Table.getSchema fails on table with watermark

[ https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709591#comment-17709591 ] Dian Fu commented on FLINK-28528: - A similar issue reported in slack channel:

[jira] [Updated] (FLINK-31707) Constant string cannot be used as input arguments of Pandas UDAF

[ https://issues.apache.org/jira/browse/FLINK-31707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-31707: Fix Version/s: 1.16.2 > Constant string cannot be used as input arguments of Pandas UDAF >

[jira] [Comment Edited] (FLINK-31707) Constant string cannot be used as input arguments of Pandas UDAF

[ https://issues.apache.org/jira/browse/FLINK-31707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708188#comment-17708188 ] Dian Fu edited comment on FLINK-31707 at 4/4/23 5:26 AM: - Fixed in: - master via

[jira] [Closed] (FLINK-31707) Constant string cannot be used as input arguments of Pandas UDAF

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

[jira] [Created] (FLINK-31707) Constant string cannot be used as input arguments of Pandas UDAF

Dian Fu created FLINK-31707: --- Summary: Constant string cannot be used as input arguments of Pandas UDAF Key: FLINK-31707 URL: https://issues.apache.org/jira/browse/FLINK-31707 Project: Flink

[jira] [Closed] (FLINK-31690) The current key is not set for KeyedCoProcessOperator

[ https://issues.apache.org/jira/browse/FLINK-31690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-31690. --- Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Fixed Fixed

[jira] [Created] (FLINK-31690) The current key is not set for KeyedCoProcessOperator

Dian Fu created FLINK-31690: --- Summary: The current key is not set for KeyedCoProcessOperator Key: FLINK-31690 URL: https://issues.apache.org/jira/browse/FLINK-31690 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31532) Support StreamExecutionEnvironment.socketTextStream in Python DataStream API

Dian Fu created FLINK-31532: --- Summary: Support StreamExecutionEnvironment.socketTextStream in Python DataStream API Key: FLINK-31532 URL: https://issues.apache.org/jira/browse/FLINK-31532 Project: Flink

[jira] [Closed] (FLINK-31503) "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a subtype" is thrown when executing Python

[ https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-31503. --- Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Fixed Fixed

[jira] [Updated] (FLINK-31503) "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a subtype" is thrown when executing Pytho

[ https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-31503: Affects Version/s: 1.15.0 > "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider >

[jira] [Commented] (FLINK-31503) "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a subtype" is thrown when executing Pyt

[ https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701861#comment-17701861 ] Dian Fu commented on FLINK-31503: - If your Flink version doesn't contain this fix, you could simply work

[jira] [Closed] (FLINK-31478) TypeError: a bytes-like object is required, not 'JavaList' is thrown when ds.execute_and_collect() is called on a KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-31478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-31478. --- Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Fixed Fixed

[jira] [Created] (FLINK-31503) "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a subtype" is thrown when executing Pytho

Dian Fu created FLINK-31503: --- Summary: "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a subtype" is thrown when executing Python UDFs in SQL Client Key:

[jira] [Updated] (FLINK-31478) TypeError: a bytes-like object is required, not 'JavaList' is thrown when ds.execute_and_collect() is called on a KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-31478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-31478: Description: {code} #

  1   2   3   4   5   6   7   8   9   10   >