[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165815#comment-16165815
]
Dian Fu commented on FLINK-7606:
Hi [~matteoferrario29],
{quote}
What we've seen is that
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167242#comment-16167242
]
Dian Fu commented on FLINK-7606:
I think this is by design otherwise users could not get t
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167242#comment-16167242
]
Dian Fu edited comment on FLINK-7606 at 9/15/17 2:18 AM:
-
I think
[
https://issues.apache.org/jira/browse/FLINK-10577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654571#comment-16654571
]
Dian Fu commented on FLINK-10577:
-
Hi [~simahoa], this is currently by design. For patte
[
https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16656534#comment-16656534
]
Dian Fu commented on FLINK-8159:
Hi [~dawidwys],
For the concern #1 you described:
my in
[
https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662091#comment-16662091
]
Dian Fu commented on FLINK-8159:
Thanks [~dawidwys] for your feedback.
1. I prefer addin
[
https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692723#comment-16692723
]
Dian Fu commented on FLINK-7599:
Sure, go ahead.
> Support aggregation functions in the
Dian Fu created FLINK-10958:
---
Summary: Add overload support for user defined function
Key: FLINK-10958
URL: https://issues.apache.org/jira/browse/FLINK-10958
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10973:
---
Assignee: Dian Fu
> Add Map operator to Table API
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Affects Version/s: (was: 1.7.1)
1.8.0
> Enhancements to Flink Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Fix Version/s: 1.8.0
> Enhancements to Flink Table API
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10973:
Fix Version/s: 1.8.0
> Add Map operator to Table API
> -
>
> K
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Affects Version/s: (was: 1.8.0)
> Enhancements to Flink Table API
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10973:
Affects Version/s: (was: 1.8.0)
> Add Map operator to Table API
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10974:
---
Assignee: Dian Fu
> Add FlatMap to TableAPI
> ---
>
> Key: FLIN
[
https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10976:
---
Assignee: Dian Fu (was: Hequn Cheng)
> Add Aggregate operator to Table API
> -
Dian Fu created FLINK-11009:
---
Summary: Add support for FILTER clause for non-windowed
aggregation in Table API and SQL
Key: FLINK-11009
URL: https://issues.apache.org/jira/browse/FLINK-11009
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11009:
Fix Version/s: 1.8.0
> Add support for FILTER clause for non-windowed aggregation in Table API and
> SQL
[
https://issues.apache.org/jira/browse/FLINK-11009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11009:
Description:
Currently the following clause is not supported in Flink, the *FILTER* clause
is ignored in
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-6938:
--
Assignee: Dian Fu (was: Jark Wu)
> IterativeCondition should support RichFunction interface
> ---
Dian Fu created FLINK-11013:
---
Summary: Fix distinct aggregates for group window in Table API
Key: FLINK-11013
URL: https://issues.apache.org/jira/browse/FLINK-11013
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704356#comment-16704356
]
Dian Fu commented on FLINK-8739:
Hi [~walterddr], are you still working on this ticket? I
[
https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-7208:
--
Assignee: Dian Fu
> Refactor build-in agg(MaxWithRetractAccumulator and
> MinWithRetractAccumulator)
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706595#comment-16706595
]
Dian Fu commented on FLINK-8739:
[~walterddr] Thanks a lot. I'll provide a PR ASAP and lo
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-8739:
--
Assignee: Dian Fu
> Optimize runtime support for distinct filter
> ---
[
https://issues.apache.org/jira/browse/FLINK-11052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11052:
---
Assignee: Dian Fu
> Add Bounded(Group Window) FlatAggregate operator to batch Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-7209:
--
Assignee: Dian Fu
> Support DataView in Java and Scala Tuples and case classes or as the
> accumulato
Dian Fu created FLINK-11074:
---
Summary: Improve the harness test to make it possible test with
state backend
Key: FLINK-11074
URL: https://issues.apache.org/jira/browse/FLINK-11074
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718401#comment-16718401
]
Dian Fu commented on FLINK-11067:
-
Hi [~twalthr], Thanks a lot for the solution. Agree w
Dian Fu created FLINK-11136:
---
Summary: Fix the logical of merge for DISTINCT aggregates
Key: FLINK-11136
URL: https://issues.apache.org/jira/browse/FLINK-11136
Project: Flink
Issue Type: Test
Dian Fu created FLINK-6876:
--
Summary: The comment of DataStream#assignTimestampsAndWatermarks
is incorrect
Key: FLINK-6876
URL: https://issues.apache.org/jira/browse/FLINK-6876
Project: Flink
Issue
Dian Fu created FLINK-6904:
--
Summary: Support for quantifier range to CEP's pattern API
Key: FLINK-6904
URL: https://issues.apache.org/jira/browse/FLINK-6904
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-6905:
--
Summary: Support for zeroOrMore to CEP's pattern API
Key: FLINK-6905
URL: https://issues.apache.org/jira/browse/FLINK-6905
Project: Flink
Issue Type: Bug
Compo
[
https://issues.apache.org/jira/browse/FLINK-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-6905.
Resolution: Not A Problem
Just found that this can be implemented with oneOrMore().optional().
> Support fo
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-6904:
--
Assignee: Dian Fu
> Support for quantifier range to CEP's pattern API
> ---
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049178#comment-16049178
]
Dian Fu commented on FLINK-4641:
Hi [~chermenin], are you still working on this JIRA? It s
Dian Fu created FLINK-6927:
--
Summary: Support pattern group in CEP
Key: FLINK-6927
URL: https://issues.apache.org/jira/browse/FLINK-6927
Project: Flink
Issue Type: Bug
Components: CEP
Dian Fu created FLINK-6933:
--
Summary: Refactor NFACompiler to reduce code duplication
Key: FLINK-6933
URL: https://issues.apache.org/jira/browse/FLINK-6933
Project: Flink
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-6935:
--
Assignee: Dian Fu
> Integration of SQL and CEP
> --
>
> Key: FL
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-6904:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Support for quantifier range to CEP's pattern AP
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-6927:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Support pattern group in CEP
> -
[
https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-6933:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Refactor NFACompiler to reduce code duplication
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-4641:
--
Assignee: Dian Fu (was: Alexander Chermenin)
> Support branching CEP patterns
> -
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-4641:
---
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6935
> Support branching CEP patterns
> --
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-6904.
Resolution: Fixed
> Support for quantifier range to CEP's pattern API
>
[
https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-6933.
Resolution: Duplicate
Close as this issue has been resolved in FLINK-6904
> Refactor NFACompiler to reduce
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16105963#comment-16105963
]
Dian Fu commented on FLINK-7293:
{quote}
Could you explain a bit why this is needed?
{quo
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16105963#comment-16105963
]
Dian Fu edited comment on FLINK-7293 at 7/29/17 1:30 AM:
-
{quote}
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16105963#comment-16105963
]
Dian Fu edited comment on FLINK-7293 at 7/29/17 1:59 AM:
-
{quote}
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106877#comment-16106877
]
Dian Fu commented on FLINK-7293:
As the {{event-time}}/{{process-time}} has higher priorit
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106877#comment-16106877
]
Dian Fu edited comment on FLINK-7293 at 7/31/17 6:59 AM:
-
As the {
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106877#comment-16106877
]
Dian Fu edited comment on FLINK-7293 at 7/31/17 6:59 AM:
-
As the {
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106877#comment-16106877
]
Dian Fu edited comment on FLINK-7293 at 7/31/17 7:00 AM:
-
As the {
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106909#comment-16106909
]
Dian Fu commented on FLINK-7293:
Agree that we can sort both by the time and the custom or
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106909#comment-16106909
]
Dian Fu edited comment on FLINK-7293 at 7/31/17 7:35 AM:
-
Agree th
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-7293.
Resolution: Fixed
> Support custom order by in PatternStream
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reopened FLINK-7123:
Reopen this JIRA as I think it's useful. Although we can achieve this via
{{times(n-1)}} followed by {{oneOrMor
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131782#comment-16131782
]
Dian Fu commented on FLINK-7129:
Hi [~dawidwys],
Thanks a lot for your work here. I'm very
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131782#comment-16131782
]
Dian Fu edited comment on FLINK-7129 at 8/18/17 6:22 AM:
-
Hi [~daw
Dian Fu created FLINK-7479:
--
Summary: Support to retrieve the past event by an offset
Key: FLINK-7479
URL: https://issues.apache.org/jira/browse/FLINK-7479
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16133007#comment-16133007
]
Dian Fu commented on FLINK-7479:
This is to support the {{PREV}} clause in {{MATCH_RECOGNI
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-7479:
---
Summary: Support to retrieve the past event by physical offset (was:
Support to retrieve the past event by a
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16133888#comment-16133888
]
Dian Fu commented on FLINK-7479:
Hi [~kkl0u],
{quote}
Before opening a PR for a feature,
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16133888#comment-16133888
]
Dian Fu edited comment on FLINK-7479 at 8/19/17 2:27 AM:
-
Hi [~kkl
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137864#comment-16137864
]
Dian Fu commented on FLINK-7129:
Hi [~dawidwys],
I thought about the issue you mentioned f
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16139494#comment-16139494
]
Dian Fu commented on FLINK-7129:
I think we can firstly create a keyed stream of events {{
Dian Fu created FLINK-7496:
--
Summary: Support greedy quantifier followed by an optional pattern
Key: FLINK-7496
URL: https://issues.apache.org/jira/browse/FLINK-7496
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-7147.
Resolution: Fixed
> Support greedy quantifier in CEP
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-7169.
Resolution: Fixed
> Support AFTER MATCH SKIP function in CEP library API
> -
Dian Fu created FLINK-7591:
--
Summary: Support partition by and order by of MATCH_RECOGNIZE
Key: FLINK-7591
URL: https://issues.apache.org/jira/browse/FLINK-7591
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-7599:
--
Summary: Support aggregation functions in the define and measures
clause of MatchRecognize
Key: FLINK-7599
URL: https://issues.apache.org/jira/browse/FLINK-7599
Project: Flink
Dian Fu created FLINK-7601:
--
Summary: Support classifier in MatchRecognize
Key: FLINK-7601
URL: https://issues.apache.org/jira/browse/FLINK-7601
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-7601:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Support classifier in MatchRecognize
> -
Dian Fu created FLINK-7603:
--
Summary: Support within clause in MatchRecognize
Key: FLINK-7603
URL: https://issues.apache.org/jira/browse/FLINK-7603
Project: Flink
Issue Type: Sub-task
Re
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917548#comment-16917548
]
Dian Fu commented on FLINK-6935:
Hi [~libenchao] Most of the features mentioned there is
Dian Fu created FLINK-13999:
---
Summary: Correct the documentation of MATCH_RECOGNIZE
Key: FLINK-13999
URL: https://issues.apache.org/jira/browse/FLINK-13999
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-13999:
Description:
Regarding to the following [example|#aggregations]] in the doc:
{code:java}
SELECT *
FROM Tic
[
https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16924731#comment-16924731
]
Dian Fu commented on FLINK-13999:
-
This issue is reported in the user list:
[http://apa
Dian Fu created FLINK-14013:
---
Summary: Support Flink Python User-Defined Stateless Function for
Table
Key: FLINK-14013
URL: https://issues.apache.org/jira/browse/FLINK-14013
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-14013:
Description:
The Python Table API has been supported in release 1.9.0. See the
[FLIP-38|https://cwiki.apa
[
https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-14013:
Description:
The Python Table API has been supported in release 1.9.0. See the
[FLIP-38|https://cwiki.apa
Dian Fu created FLINK-14014:
---
Summary: Introduce PythonScalarFunctionRunner to handle the
communication with Python worker for Python ScalarFunction execution
Key: FLINK-14014
URL: https://issues.apache.org/jira/browse/
Dian Fu created FLINK-14015:
---
Summary: Introduce PythonScalarFunctionOperator as a standalone
StreamOperator for Python ScalarFunction execution
Key: FLINK-14015
URL: https://issues.apache.org/jira/browse/FLINK-14015
Dian Fu created FLINK-14016:
---
Summary: Introduce RelNodes FlinkLogicalPythonScalarFunctionExec
and DataStreamPythonScalarFunctionExec which are containers for Python
PythonScalarFunctions
Key: FLINK-14016
URL: https://
Dian Fu created FLINK-14017:
---
Summary: Support to start up Python worker in process mode
Key: FLINK-14017
URL: https://issues.apache.org/jira/browse/FLINK-14017
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14018:
---
Summary: Add Python building blocks to make sure the basic
functionality of Python ScalarFunction could work
Key: FLINK-14018
URL: https://issues.apache.org/jira/browse/FLINK-14018
Dian Fu created FLINK-14019:
---
Summary: Python environment and dependency management
Key: FLINK-14019
URL: https://issues.apache.org/jira/browse/FLINK-14019
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14020:
---
Summary: User Apache Arrow as the serializer for data transmission
between Java operator and Python harness
Key: FLINK-14020
URL: https://issues.apache.org/jira/browse/FLINK-14020
Dian Fu created FLINK-14021:
---
Summary: Add rules to push down the Python ScalarFunctions
contained in the join condition of Correlate node
Key: FLINK-14021
URL: https://issues.apache.org/jira/browse/FLINK-14021
Dian Fu created FLINK-14022:
---
Summary: Add validation check for places where Python
ScalarFunction cannot be used
Key: FLINK-14022
URL: https://issues.apache.org/jira/browse/FLINK-14022
Project: Flink
Dian Fu created FLINK-14023:
---
Summary: Support accessing job parameters in Python user-defined
functions
Key: FLINK-14023
URL: https://issues.apache.org/jira/browse/FLINK-14023
Project: Flink
Issu
Dian Fu created FLINK-14024:
---
Summary: Support use-defined metrics in Python user-defined
functions
Key: FLINK-14024
URL: https://issues.apache.org/jira/browse/FLINK-14024
Project: Flink
Issue Typ
Dian Fu created FLINK-14025:
---
Summary: Support to run the Python worker in docker mode
Key: FLINK-14025
URL: https://issues.apache.org/jira/browse/FLINK-14025
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14026:
---
Summary: Manage the resource of Python worker properly
Key: FLINK-14026
URL: https://issues.apache.org/jira/browse/FLINK-14026
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14027:
---
Summary: Add documentation for Python user-defined functions
Key: FLINK-14027
URL: https://issues.apache.org/jira/browse/FLINK-14027
Project: Flink
Issue Type: Sub-tas
Dian Fu created FLINK-14028:
---
Summary: Support logging aggregation in Python user-defined
functions
Key: FLINK-14028
URL: https://issues.apache.org/jira/browse/FLINK-14028
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-14020:
Description:
Apache Arrow is "a cross-language development platform for in-memory data. It
specifies a st
[
https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928369#comment-16928369
]
Dian Fu commented on FLINK-14066:
-
Hi [~coldmoon777], currently PyFlink is still not
[
https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928507#comment-16928507
]
Dian Fu commented on FLINK-14066:
-
I mean that for windows support, we need to consider
[
https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933348#comment-16933348
]
Dian Fu commented on FLINK-14019:
-
Looking forward to the design doc. This is a very imp
1 - 100 of 4090 matches
Mail list logo
