[
https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29903:
Affects Version/s: (was: 1.16.0)
> Support “string1.notSimilar(string2)” built-in function in Table AP
[
https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629479#comment-17629479
]
Dian Fu commented on FLINK-29903:
-
[~cun8cun8] Have assigned it to you~
> Support “stri
[
https://issues.apache.org/jira/browse/FLINK-29904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29904:
Issue Type: Improvement (was: New Feature)
> Support “string1.notLike(string2)” built-in function in Tabl
[
https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29903:
Issue Type: Improvement (was: New Feature)
> Support “string1.notSimilar(string2)” built-in function in T
[
https://issues.apache.org/jira/browse/FLINK-29904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29904:
Affects Version/s: (was: 1.16.0)
> Support “string1.notLike(string2)” built-in function in Table API
>
[
https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29903:
---
Assignee: zhangjingcun
> Support “string1.notSimilar(string2)” built-in function in Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-29902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29902:
---
Assignee: zhangjingcun
> Support “value1.notIn(TABLE)” built-in function in Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-29902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629478#comment-17629478
]
Dian Fu commented on FLINK-29902:
-
[~cun8cun8] Have assigned it to you~
> Support “valu
[
https://issues.apache.org/jira/browse/FLINK-29901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629477#comment-17629477
]
Dian Fu commented on FLINK-29901:
-
[~cun8cun8] Have assigned it to you~
> Support “NOT
[
https://issues.apache.org/jira/browse/FLINK-29901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29901:
Issue Type: Improvement (was: New Feature)
> Support “NOT IN” built-in function in Table API
> --
[
https://issues.apache.org/jira/browse/FLINK-29901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29901:
---
Assignee: zhangjingcun
> Support “NOT IN” built-in function in Table API
>
[
https://issues.apache.org/jira/browse/FLINK-29796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628677#comment-17628677
]
Dian Fu commented on FLINK-29796:
-
cc [~hxb]
> pyflink protobuf requirement out of date
[
https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29479:
Summary: Support whether using system PythonPath for PyFlink jobs (was:
support whether using system env
[
https://issues.apache.org/jira/browse/FLINK-25497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-25497.
---
Resolution: Duplicate
Seems duplicate with FLINK-27715. Just close it~
> Add more ML Python examples
>
[
https://issues.apache.org/jira/browse/FLINK-26084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-26084.
---
Resolution: Cannot Reproduce
> Python tests exit with code 137
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-26264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-26264.
---
Resolution: Cannot Reproduce
> Python Test failed on its docs building phase
> -
[
https://issues.apache.org/jira/browse/FLINK-26385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-26385.
---
Resolution: Duplicate
> Use new Kafka source and sink in Python API
> --
[
https://issues.apache.org/jira/browse/FLINK-28667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28667.
---
Fix Version/s: (was: 1.17.0)
Resolution: Duplicate
> "evictor" operations of "window_all" are sup
[
https://issues.apache.org/jira/browse/FLINK-29094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29094:
Component/s: Connectors / Kafka
(was: API / Python)
> Cannot stop Python job with sav
[
https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29479:
Affects Version/s: (was: 1.17.0)
> support whether using system env for pythonpath
> -
[
https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-27715:
---
Assignee: Yunfeng Zhou (was: Huang Xingbo)
> Add more Python ML examples
> ---
[
https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-27715:
---
Assignee: Huang Xingbo
> Add more Python ML examples
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618034#comment-17618034
]
Dian Fu edited comment on FLINK-29608 at 10/15/22 7:37 AM:
---
>F
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618034#comment-17618034
]
Dian Fu edited comment on FLINK-29608 at 10/15/22 7:35 AM:
---
>F
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618034#comment-17618034
]
Dian Fu commented on FLINK-29608:
-
>From the exception stack:
```
I don't
> 使用 pyflin
[
https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29483:
---
Assignee: jackylau
> flink python udf arrow in thread model bug
> -
[
https://issues.apache.org/jira/browse/FLINK-29353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29353.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master via bca164f97d824fac7c4d42555be806e8db393242
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29552:
Summary: Fix documentation usage examples for DAYOFYEAR, DAYOFMONTH, and
DAYOFWEEK functions (was: Fix do
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29552.
---
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
Merged to
- master via c0df986333ab
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29552:
---
Assignee: zhangjingcun
> Fix documentation usage examples for DAYOFYEAR, DAYOFMONTH, and DAYOFFEEK
[
https://issues.apache.org/jira/browse/FLINK-29517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29517.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master via d1cb177c91b41a5387814ad60d1799c08caf3ad9
[
https://issues.apache.org/jira/browse/FLINK-29517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29517:
Summary: Update documentation about DATE_FORMAT to state that it's
supported in Table API (was: Support D
[
https://issues.apache.org/jira/browse/FLINK-29352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29352.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master via 8d5e27740c34dac4685ba8539c2bec7303314ae6
[
https://issues.apache.org/jira/browse/FLINK-29354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29354:
Component/s: Table SQL / API
> Support TO_DATE and TO_TIMESTAMP built-in function in the Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-29354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29354.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master via 946949eda11184c02f56272a2fb24200b6badb29
[
https://issues.apache.org/jira/browse/FLINK-29523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29523:
---
Assignee: zhangjingcun
> Support STR_TO_MAP、SUBSTR built-in function in Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-29522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29522:
---
Assignee: zhangjingcun
> Support SPLIT_INDEX built-in function in Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-29525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29525:
---
Assignee: zhangjingcun
> Support INSTR、LEFT、RIGHT built-in function in Table API
>
[
https://issues.apache.org/jira/browse/FLINK-29524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29524:
---
Assignee: zhangjingcun
> Support DECODE、ENCODE built-in function in Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-29518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29518:
---
Assignee: zhangjingcun
> Support YEAR、QUARTER、MONTH、WEEK、HOUR、MINUTE、SECOND built-in function in Ta
[
https://issues.apache.org/jira/browse/FLINK-29519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29519:
---
Assignee: zhangjingcun
> Support DAYOFYEAR、DAYOFMONTH built-in function in Table API
>
[
https://issues.apache.org/jira/browse/FLINK-29521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29521:
---
Assignee: zhangjingcun
> Support REVERSE built-in function in Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-29520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29520:
---
Assignee: zhangjingcun
> Support PARSE_URL built-in function in Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-29517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29517:
---
Assignee: zhangjingcun
> Support DATE_FORMAT built-in function in Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-29516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29516:
---
Assignee: zhangjingcun
> Support TIMESTAMPADD built-in function in Table API
>
[
https://issues.apache.org/jira/browse/FLINK-29156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29156.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master via 397141ed7c00586e5b5449177840243babe2a776
[
https://issues.apache.org/jira/browse/FLINK-29354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612032#comment-17612032
]
Dian Fu commented on FLINK-29354:
-
[~cun8cun8] Have assign it to you~
> Support TO_DATE
[
https://issues.apache.org/jira/browse/FLINK-29353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29353:
---
Assignee: zhangjingcun
> Support UNIX_TIMESTAMP built-in function in Table API
> --
[
https://issues.apache.org/jira/browse/FLINK-29354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29354:
---
Assignee: zhangjingcun
> Support TO_DATE and TO_TIMESTAMP built-in function in the Table API
>
[
https://issues.apache.org/jira/browse/FLINK-29353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612031#comment-17612031
]
Dian Fu commented on FLINK-29353:
-
[~cun8cun8] Have assign it to you~
> Support UNIX_TI
[
https://issues.apache.org/jira/browse/FLINK-29352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29352:
---
Assignee: zhangjingcun
> Support CONVERT_TZ built-in function in Table API
> --
[
https://issues.apache.org/jira/browse/FLINK-29352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612030#comment-17612030
]
Dian Fu commented on FLINK-29352:
-
Have assign it to you~
> Support CONVERT_TZ built-in
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608622#comment-17608622
]
Dian Fu commented on FLINK-28786:
-
[~lemonjing] Hi, could you provide more information?
[
https://issues.apache.org/jira/browse/FLINK-29192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600646#comment-17600646
]
Dian Fu commented on FLINK-29192:
-
[~pemide] Thanks. Have assigned it to you~
> Add com
[
https://issues.apache.org/jira/browse/FLINK-29192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29192:
---
Assignee: pengmd
> Add completeness test for built-in functions between Java and Python Table API
>
[
https://issues.apache.org/jira/browse/FLINK-29192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29192:
Description: I have found many times that users are adding built-in
functions in the Java Table API, howev
[
https://issues.apache.org/jira/browse/FLINK-29192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29192:
Description: I have found many times that users are adding a built-in
function in the Java Table API, howe
Dian Fu created FLINK-29192:
---
Summary: Add completeness test for built-in functions between Java
and Python Table API
Key: FLINK-29192
URL: https://issues.apache.org/jira/browse/FLINK-29192
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29156:
---
Assignee: zhangjingcun
> Support LISTAGG in the Table API
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28253.
---
Resolution: Duplicate
> It reports "LocalDateTime is not supported in PyFlink currently" when
> converting
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28253.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in FLINK-28827 via 1c40dc15fbc29e8e5e514565109a3fb05b47
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reopened FLINK-28253:
-
> It reports "LocalDateTime is not supported in PyFlink currently" when
> converting between Table and Data
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28253:
Fix Version/s: (was: 1.16.0)
> It reports "LocalDateTime is not supported in PyFlink currently" when
[
https://issues.apache.org/jira/browse/FLINK-29028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29028:
Component/s: (was: Documentation)
> Add the missing cache api in Python DataStream API
> -
[
https://issues.apache.org/jira/browse/FLINK-29028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29028.
---
Resolution: Fixed
Merged to master via 97519d1683f3f5f086ce613d59aa5ba46cf38a30
> Add the missing cache api
[
https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582680#comment-17582680
]
Dian Fu commented on FLINK-28972:
-
Merged to master via 77ea6638f150d1e261e6bd703a06282e
[
https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28972.
---
Fix Version/s: (was: 1.14.6)
(was: 1.15.3)
Assignee: Luning Wang
R
[
https://issues.apache.org/jira/browse/FLINK-28908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28908.
---
Assignee: Juntao Hu
Resolution: Fixed
Fixed in:
- master via de8ff096a5344d85eb9be497902b99dd4b24e2a9
[
https://issues.apache.org/jira/browse/FLINK-28944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28944.
---
Resolution: Fixed
Merged to master via a62c5a35aa29014780bb5598facd0fbdf2db4426
> Optimize the Python Execu
[
https://issues.apache.org/jira/browse/FLINK-27584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27584.
---
Resolution: Done
> Support broadcast state in PyFlink DataStream API
> -
[
https://issues.apache.org/jira/browse/FLINK-27588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27588.
---
Assignee: Juntao Hu (was: Luning Wang)
Resolution: Fixed
Merged to master via 4739a5c88ccc27dca3a19ad
[
https://issues.apache.org/jira/browse/FLINK-28904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28904:
Component/s: Documentation
> Add missing connector/format doc for PyFlink
> --
[
https://issues.apache.org/jira/browse/FLINK-28904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28904:
Affects Version/s: (was: 1.15.1)
> Add missing connector/format doc for PyFlink
>
[
https://issues.apache.org/jira/browse/FLINK-28904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28904.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via 465db25502e6e2c59e466b05dfd3bdb28919a765
>
[
https://issues.apache.org/jira/browse/FLINK-28895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28895.
---
Resolution: Fixed
Merged to master via 6844be2128dd4c6ec62fe6e0b5230d885393e1ce
> Eliminate RowRowConverter
[
https://issues.apache.org/jira/browse/FLINK-28895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28895:
Affects Version/s: (was: 1.15.1)
> Eliminate RowRowConverter between RowData source and sink
> ---
[
https://issues.apache.org/jira/browse/FLINK-28895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-28895:
---
Assignee: Juntao Hu
> Eliminate RowRowConverter between RowData source and sink
> -
[
https://issues.apache.org/jira/browse/FLINK-28876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28876:
Affects Version/s: (was: 1.15.1)
> Support writing RowData to Orc files in PyFlink
> -
[
https://issues.apache.org/jira/browse/FLINK-28876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28876.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via cf3beff586a088c20833d8a8fc72bbc37d87a2b1
>
[
https://issues.apache.org/jira/browse/FLINK-28886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28886.
---
Resolution: Fixed
Merged to master via fda2bdd05c75587b81205e72ca010d0022a44616
> Support HybridSource in P
[
https://issues.apache.org/jira/browse/FLINK-28862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28862.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via de8ff096a5344d85eb9be497902b99dd4b24e2a9
>
[
https://issues.apache.org/jira/browse/FLINK-28862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28862:
Summary: Support writing Parquet files in PyFlink (was: Support writing
RowData to Parquet files in PyFli
Dian Fu created FLINK-28886:
---
Summary: Support HybridSource in Python DataStream API
Key: FLINK-28886
URL: https://issues.apache.org/jira/browse/FLINK-28886
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-28183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28183.
---
Resolution: Fixed
Merged to master via 5506930cc79eb131c66c5df0320045ad53437dce
> flink-python is lacking s
[
https://issues.apache.org/jira/browse/FLINK-28827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28827:
Affects Version/s: (was: 1.15.1)
> Complete DataType support in DataStream API for PyFlink
> -
[
https://issues.apache.org/jira/browse/FLINK-28827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28827.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via 1c40dc15fbc29e8e5e514565109a3fb05b47a83f
>
[
https://issues.apache.org/jira/browse/FLINK-27966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-27966:
Affects Version/s: (was: 1.15.0)
> All the classes move to the connector specific files
>
[
https://issues.apache.org/jira/browse/FLINK-27966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576614#comment-17576614
]
Dian Fu commented on FLINK-27966:
-
[~ana4] Since it's closing to the code freeze of 1.16
[
https://issues.apache.org/jira/browse/FLINK-27966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27966.
---
Assignee: Dian Fu
Resolution: Fixed
Merged to master via 9dd2b19995beb766f0cd0986b079f2d210c1e836
> A
[
https://issues.apache.org/jira/browse/FLINK-28822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28822:
Component/s: API / Python
(was: Table SQL / Runtime)
> Avoid create VectorizedColumnB
[
https://issues.apache.org/jira/browse/FLINK-28822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28822.
---
Assignee: Aitozi
Resolution: Fixed
Merged to master via e47cb6eeb4ceac13db4b8b357a0885b77651826c
> Av
[
https://issues.apache.org/jira/browse/FLINK-28782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28782.
---
Resolution: Fixed
Merged to master via b6cc5b24c0e23f08d4191e2c6bae5d8af8729c22
> Support FileSink compacti
[
https://issues.apache.org/jira/browse/FLINK-28782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28782:
Affects Version/s: (was: 1.15.1)
> Support FileSink compaction in PyFlink
> --
[
https://issues.apache.org/jira/browse/FLINK-28782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-28782:
---
Assignee: Juntao Hu
> Support FileSink compaction in PyFlink
>
[
https://issues.apache.org/jira/browse/FLINK-28740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28740:
Affects Version/s: (was: 1.15.1)
> Support CsvBulkWriter in PyFlink
>
[
https://issues.apache.org/jira/browse/FLINK-28740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28740.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via 17e1920bcd2780e12f5ad318faa0db68c4f7fec0
>
[
https://issues.apache.org/jira/browse/FLINK-28664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28664.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via f8f2ebb34f18540f4bfdf2b5db591539199b65e7
>
[
https://issues.apache.org/jira/browse/FLINK-28140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28140.
---
Fix Version/s: 1.16.0
1.15.2
Resolution: Fixed
> Improve the documentation by addi
[
https://issues.apache.org/jira/browse/FLINK-28140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573221#comment-17573221
]
Dian Fu commented on FLINK-28140:
-
Updated the remaining documentation pages:
* master v
[
https://issues.apache.org/jira/browse/FLINK-28667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-28667:
---
Assignee: zhangjingcun
> "evictor" operations of "window_all" are supported in Python datastream AP
201 - 300 of 3834 matches
Mail list logo
