[
https://issues.apache.org/jira/browse/FLINK-36307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-36307.
---
Resolution: Fixed
Merged to master via fc3ace9bd652a8035c3a3d5a1b2cd580f4566a57
> Remove deprecated PyFlink
[
https://issues.apache.org/jira/browse/FLINK-36311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-36311.
---
> Remove deprecated flink-formats config options
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-36308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-36308.
---
> Remove deprecated CEP config options
>
>
> Key: FLINK-363
[
https://issues.apache.org/jira/browse/FLINK-36311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-36311.
-
Resolution: Fixed
Merged to master viade40ebe53797a4abe023a437e63d9ba5aa095d40 to
483a94a15aed6661a3332
[
https://issues.apache.org/jira/browse/FLINK-36308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-36308.
-
Resolution: Fixed
Merged to master via 42d918dec1658c4dc1f0586148704c46bc1dd8d0
> Remove deprecated CEP
[
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 unknown
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845526#comment-17845526
]
Dian Fu edited comment on FLINK-35112 at 5/11/24 2:56 AM:
--
Fix
[
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
> --
[
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
>
[
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
> -
[
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
> ---
[
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 0f01a0e9a6856781d5a0e33b26172bb913ec1928
[
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
(StreamExecutionEnvironment#cachedFile
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
Is
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837965#comment-17837965
]
Dian Fu commented on FLINK-35112:
-
Great (y). Thanks [~wzorgdrager]
> Membership for R
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837512#comment-17837512
]
Dian Fu commented on FLINK-35112:
-
Sounds reasonable for me. [~wzorgdrager] Do you want
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
[
https://issues.apache.org/jira/browse/FLINK-33220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829346#comment-17829346
]
Dian Fu commented on FLINK-33220:
-
[~liu.chong] I missed this ticket. Feel free to subm
[
https://issues.apache.org/jira/browse/FLINK-33220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829346#comment-17829346
]
Dian Fu edited comment on FLINK-33220 at 3/21/24 1:24 AM:
--
[~li
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818326#comment-17818326
]
Dian Fu commented on FLINK-34202:
-
[~lincoln.86xy] It will randomly select one Python ve
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818242#comment-17818242
]
Dian Fu commented on FLINK-34202:
-
[~hxbks2ks] Could you help to take a look at this iss
[
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 in:
[
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
> --
[
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 b1bfd70ad8a9
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786595#comment-17786595
]
Dian Fu commented on FLINK-33528:
-
Thanks very much for the efforts (y)
> Externalize P
[
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"
> --
[
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
> PyFlink
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785727#comment-17785727
]
Dian Fu commented on FLINK-33529:
-
Fixed in:
* master via 34d9594ab1e5412371b77912f120b
[
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"
> -
[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785708#comment-17785708
]
Dian Fu commented on FLINK-33528:
-
Yes, I think so.
> Externalize Python connector code
[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785456#comment-17785456
]
Dian Fu commented on FLINK-33528:
-
I think it's fair enough to externalize Python connec
[
https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762927#comment-17762927
]
Dian Fu commented on FLINK-32962:
-
+1 to backport to Flink 1.17 and 1.18, especially Fli
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760240#comment-17760240
]
Dian Fu commented on FLINK-32758:
-
Merged to:
- release-1.18 via 1f7796ee50cfbea4fb63369
[
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 restric
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760238#comment-17760238
]
Dian Fu commented on FLINK-32758:
-
Fixed in master via 5b5a0af15d57ed4424cf8dd744808433e
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759969#comment-17759969
]
Dian Fu commented on FLINK-32758:
-
Have verified that upgrade *{*}cibuildwheel{*}* doesn
[
https://issues.apache.org/jira/browse/FLINK-32981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759855#comment-17759855
]
Dian Fu commented on FLINK-32981:
-
[~gaborgsomogyi] [~mbalassi] It seems that this PR br
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
Components
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759777#comment-17759777
]
Dian Fu commented on FLINK-32758:
-
[~deepyaman] Actually the tests have passed on the CI
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759774#comment-17759774
]
Dian Fu commented on FLINK-32758:
-
[~Sergey Nuyanzin] [~deepyaman] I have submitted a h
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758790#comment-17758790
]
Dian Fu commented on FLINK-32758:
-
Will backport to release-1.17 and release-1.8 branch
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758788#comment-17758788
]
Dian Fu commented on FLINK-32758:
-
Merged to master via 0dd6f9745b8df005e3aef286ae730926
[
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
> --
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: Improvement
[
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
> --
[
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
>
[
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 Arr
[
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
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-32327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738519#comment-17738519
]
Dian Fu commented on FLINK-32327:
-
Thanks (y). I will find some time to investigate this
[
https://issues.apache.org/jira/browse/FLINK-32327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733729#comment-17733729
]
Dian Fu commented on FLINK-32327:
-
PS: I can help to dig into this problem if we know wh
[
https://issues.apache.org/jira/browse/FLINK-32327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733728#comment-17733728
]
Dian Fu commented on FLINK-32327:
-
[~chesnay] It seems that you have disabled the entire
[
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
R
[
https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733327#comment-17733327
]
Dian Fu commented on FLINK-32136:
-
[~wash] I have submitted a PR. Could you help to revi
[
https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733327#comment-17733327
]
Dian Fu edited comment on FLINK-32136 at 6/16/23 5:25 AM:
--
[~wa
[
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
[
https://issues.apache.org/jira/browse/FLINK-32136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733017#comment-17733017
]
Dian Fu commented on FLINK-32136:
-
[~wash] Good catch! This seems like a critical proble
[
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 Function(
[
https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732524#comment-17732524
]
Dian Fu commented on FLINK-32040:
-
Good catch! I think you are right that this is a bug.
[
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 an
[
https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732518#comment-17732518
]
Dian Fu commented on FLINK-32034:
-
[~coltenp] Thanks for reporting this issue and the fi
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732515#comment-17732515
]
Dian Fu commented on FLINK-32207:
-
This seems duplicate with FLINK-32206. Closing this t
[
https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732513#comment-17732513
]
Dian Fu commented on FLINK-32206:
-
'Kafka' has already been removed from 'pyflink.table
[
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 respe
[
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 fbf7b91424ec
[
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 hadoop
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 Type
[
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 th
[
https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722623#comment-17722623
]
Dian Fu commented on FLINK-20794:
-
Thanks for the analysis. Since string based interface
[
https://issues.apache.org/jira/browse/FLINK-31968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719599#comment-17719599
]
Dian Fu edited comment on FLINK-31968 at 5/5/23 2:27 AM:
-
[~grad
[
https://issues.apache.org/jira/browse/FLINK-31968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719599#comment-17719599
]
Dian Fu commented on FLINK-31968:
-
[~gradysnik] Thanks for the confirmation. I'm closing
[
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
>
[
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 sou
[
https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719245#comment-17719245
]
Dian Fu commented on FLINK-20794:
-
[~supercmmetry] Thanks for taking this ticket. Have a
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17716967#comment-17716967
]
Dian Fu edited comment on FLINK-28786 at 4/27/23 10:04 AM:
---
Fi
[
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 1.1
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17716967#comment-17716967
]
Dian Fu commented on FLINK-28786:
-
Fixed in:
- master via a3368635e3d06f764d144f8c8e2e06
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: Fl
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17716757#comment-17716757
]
Dian Fu edited comment on FLINK-28786 at 4/26/23 2:41 PM:
--
Reop
[
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
(https://apache-flink.slack.com/archives/C03G7LJT
[
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 pyflin
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
Proj
[
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 type
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
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709597#comment-17709597
]
Dian Fu commented on FLINK-28528:
-
The exception happens when converting TableSchema to
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709595#comment-17709595
]
Dian Fu commented on FLINK-28528:
-
The root cause is that currently table.get_schema() o
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709591#comment-17709591
]
Dian Fu commented on FLINK-28528:
-
A similar issue reported in slack channel:
https://a
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-31707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708188#comment-17708188
]
Dian Fu edited comment on FLINK-31707 at 4/4/23 5:26 AM:
-
Fixed
[
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 7c6d8b0134cb
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
Issue
[
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 in:
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
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
[
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 in:
1 - 100 of 2549 matches
Mail list logo
