[
https://issues.apache.org/jira/browse/FLINK-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9664:
Assignee: Rong Rong
> FlinkML Quickstart Loading Data section example doesn't work as described
>
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506191#comment-16506191
]
Rong Rong edited comment on FLINK-9430 at 6/8/18 4:07 PM:
--
Hi here, I did some
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506191#comment-16506191
]
Rong Rong commented on FLINK-9430:
--
Hi here, I did some integration test. There are 2 glues that makes
[
https://issues.apache.org/jira/browse/FLINK-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9502:
-
Description:
This ticket is to enable generic Object type as element type by using SQL ANY
in parameter
[
https://issues.apache.org/jira/browse/FLINK-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9502:
-
Description:
This ticket is to enable generic Object type as element type by using SQL ANY
in parameter
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
*{{MAP}}*,
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
*{{MAP}}*,
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9502:
-
Description:
This ticket is to enable generic Object type as element type by using SQL ANY
in parameter
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501829#comment-16501829
]
Rong Rong commented on FLINK-7001:
--
Thanks for the support [~pgrulich], we can definitely collab on
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16500307#comment-16500307
]
Rong Rong commented on FLINK-9294:
--
Yes you are absolutely right, sorry for the typo.
> Improve type
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
*{{MAP}}*,
[
https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9484:
-
Description:
User-defined function has been a great extension for Flink SQL API to support
much complex
[
https://issues.apache.org/jira/browse/FLINK-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9502:
-
Description:
This ticket is to enable generic Object type as element type by using SQL ANY
in parameter
Rong Rong created FLINK-9502:
Summary: Use generic parameter search for user-define functions
when argument contains Object type
Key: FLINK-9502
URL: https://issues.apache.org/jira/browse/FLINK-9502
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Summary: Allow Object or Wildcard type in user-define functions as
parameter types but not result types
Rong Rong created FLINK-9501:
Summary: Allow Object.class type in user-define functions as
parameter types but not result types
Key: FLINK-9501
URL: https://issues.apache.org/jira/browse/FLINK-9501
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-9484
> Improve type inference for UDFs
Rong Rong created FLINK-9484:
Summary: Improve generic type inference for User-Defined Functions
Key: FLINK-9484
URL: https://issues.apache.org/jira/browse/FLINK-9484
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495510#comment-16495510
]
Rong Rong commented on FLINK-9430:
--
Hi [~suez1224], I think [~twalthr] and I had this discussion in a
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492070#comment-16492070
]
Rong Rong commented on FLINK-7001:
--
Hi [~jark], [~StephanEwen],
I was wondering if there's any further
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487968#comment-16487968
]
Rong Rong commented on FLINK-9422:
--
+1 on "can apply windowed aggregates on the result". This would make
[
https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9398:
Assignee: Rong Rong
> Flink CLI list running job returns all jobs except in CREATE state
>
[
https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480670#comment-16480670
]
Rong Rong commented on FLINK-9398:
--
Hi [~yanghua], have you started working on this task?
I was hoping
[
https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9398:
-
Description:
See:
Rong Rong created FLINK-9398:
Summary: Flink CLI list running job returns all jobs except in
CREATE state
Key: FLINK-9398
URL: https://issues.apache.org/jira/browse/FLINK-9398
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16475177#comment-16475177
]
Rong Rong commented on FLINK-8866:
--
+1 on the (1) and (2) point, I found like huge trunk of component
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16474463#comment-16474463
]
Rong Rong commented on FLINK-8866:
--
I think they should be designed to use in both source and sink cases.
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472571#comment-16472571
]
Rong Rong commented on FLINK-8866:
--
Hi [~suez1224]
I was working on FLINK-8880 and I thought it will be
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466014#comment-16466014
]
Rong Rong commented on FLINK-7001:
--
Thanks [~pgrulich], This is definitely a great solution when handling
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464239#comment-16464239
]
Rong Rong commented on FLINK-7001:
--
Hi [~jark],
Is there a FLIP being proposed based on the pain points
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
*{{MAP}}*,
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
*{{MAP}}*,
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
*{{MAP}}*,
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9294:
Assignee: Rong Rong
> Improve type inference for UDFs with composite parameter or result type
>
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
Most of the UDF function signatures that includes composite types such as
{code}MAP{/code}
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9294:
-
Description:
For now most of the UDF function signatures that includes composite types such
as {{MAP}}
Rong Rong created FLINK-9294:
Summary: Improve type inference for UDFs with composite parameter
or result type
Key: FLINK-9294
URL: https://issues.apache.org/jira/browse/FLINK-9294
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16457685#comment-16457685
]
Rong Rong commented on FLINK-7144:
--
FLINK-8689 has been merged and FLINK-8690 is on the way. Will fix
[
https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-7144:
Assignee: Rong Rong
> Optimize multiple LogicalAggregate into one
>
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16457679#comment-16457679
]
Rong Rong commented on FLINK-8690:
--
Thanks for the suggestion [~fhueske]. I think this is much cleaner
[
https://issues.apache.org/jira/browse/FLINK-8986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16455771#comment-16455771
]
Rong Rong commented on FLINK-8986:
--
Hi [~Zentol], I addressed most of your comments and created another
[
https://issues.apache.org/jira/browse/FLINK-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9232:
Assignee: Rong Rong
> Add harness test for AggregationCodeGenerator
>
Rong Rong created FLINK-9232:
Summary: Add harness test for AggregationCodeGenerator
Key: FLINK-9232
URL: https://issues.apache.org/jira/browse/FLINK-9232
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8739:
-
Description:
Possible optimizaitons:
1. Decouple distinct map and actual accumulator so that they can
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8739:
-
Summary: Optimize runtime support for distinct filter (was: Optimize
runtime support for distinct filter
[
https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9172:
Assignee: Rong Rong
> Support external catalog factory that comes default with SQL-Client
>
[
https://issues.apache.org/jira/browse/FLINK-9199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9199:
-
Description:
So far the following has URL exceptions based on FLINK-8986 test results.
[
https://issues.apache.org/jira/browse/FLINK-9199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9199:
-
Summary: Malfunctioning URL target in some messageheaders (was:
[
https://issues.apache.org/jira/browse/FLINK-9199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9199:
Assignee: Rong Rong
> SubtaskExecutionAttemptAccumulatorsHeaders &
>
Rong Rong created FLINK-9199:
Summary: SubtaskExecutionAttemptAccumulatorsHeaders &
SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL
Key: FLINK-9199
URL: https://issues.apache.org/jira/browse/FLINK-9199
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438151#comment-16438151
]
Rong Rong commented on FLINK-9157:
--
Hi [~dmitry_kober], yes, that would be great! I think for now feel
[
https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9172:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-7594
> Support external catalog factory
Rong Rong created FLINK-9172:
Summary: Support external catalog factory that comes default with
SQL-Client
Key: FLINK-9172
URL: https://issues.apache.org/jira/browse/FLINK-9172
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9157:
-
Description: Having SQL-Client to support first external catalog: Apache
HCatalog out of the box. (was:
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9157:
-
Summary: Support for commonly used external catalog (was: Create support
for commonly used external
Rong Rong created FLINK-9157:
Summary: Create support for commonly used external catalog
Key: FLINK-9157
URL: https://issues.apache.org/jira/browse/FLINK-9157
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8880:
Assignee: Rong Rong
> Validate configurations for SQL Client
>
[
https://issues.apache.org/jira/browse/FLINK-9104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419211#comment-16419211
]
Rong Rong edited comment on FLINK-9104 at 3/29/18 3:37 PM:
---
Seems like several
[
https://issues.apache.org/jira/browse/FLINK-9104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419211#comment-16419211
]
Rong Rong commented on FLINK-9104:
--
Seems like several handlers are missing. I will try going down the
[
https://issues.apache.org/jira/browse/FLINK-9104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9104:
Assignee: Rong Rong
> Re-generate REST API documentation for FLIP-6
>
[
https://issues.apache.org/jira/browse/FLINK-8986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419207#comment-16419207
]
Rong Rong commented on FLINK-8986:
--
Thanks [~till.rohrmann] for the info. Yup I can upgrade the doc first
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419202#comment-16419202
]
Rong Rong commented on FLINK-8985:
--
Thanks [~till.rohrmann] for the confirmation. Yes, I saw you already
[
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417893#comment-16417893
]
Rong Rong commented on FLINK-8880:
--
Hi [~xccui]. I think I can help with this task. There are still some
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8985:
Assignee: Rong Rong
> End-to-end test: CLI
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-8986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411958#comment-16411958
]
Rong Rong commented on FLINK-8986:
--
Hi [~till.rohrmann], I can help with this e2e test.
Is this
[
https://issues.apache.org/jira/browse/FLINK-8986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8986:
Assignee: Rong Rong
> End-to-end test: REST
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411952#comment-16411952
]
Rong Rong commented on FLINK-8985:
--
Hi [~till.rohrmann]. I can help contributing to the REST & CLI e2e
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394806#comment-16394806
]
Rong Rong commented on FLINK-8690:
--
Sweet. Thank you [~hequn8128]!
I am still a bit skeptical putting a
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394379#comment-16394379
]
Rong Rong commented on FLINK-8690:
--
Thanks [~hequn8128] for the valuable feedback :-)
I did some research
[
https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394377#comment-16394377
]
Rong Rong commented on FLINK-7144:
--
Hi [~jark], I am working on FLINK-8688 and I think I can use the fix
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394068#comment-16394068
]
Rong Rong commented on FLINK-8690:
--
You are right. Haven't thought about that. I will verify the plan
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394046#comment-16394046
]
Rong Rong edited comment on FLINK-8690 at 3/10/18 5:54 AM:
---
That should resolve
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394046#comment-16394046
]
Rong Rong edited comment on FLINK-8690 at 3/10/18 5:52 AM:
---
That should resolve
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394046#comment-16394046
]
Rong Rong commented on FLINK-8690:
--
That should resolve our problem partially. The real reason why I
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394042#comment-16394042
]
Rong Rong commented on FLINK-8863:
--
Sounds good. We can deal with that in future. Thanks for the quick
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16393966#comment-16393966
]
Rong Rong commented on FLINK-8863:
--
Thanks [~xccui] for the quick reply. I am assuming users would have
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16393942#comment-16393942
]
Rong Rong commented on FLINK-8863:
--
Hi [~twalthr], in the task description, there's no specification
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390467#comment-16390467
]
Rong Rong commented on FLINK-8690:
--
I created one of the initial (not at all perfect) support trying to
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16376938#comment-16376938
]
Rong Rong commented on FLINK-8690:
--
Yes, changed the description
> Update logical rule set to generate
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8690:
-
Description:
Currently, *FlinkLogicalAggregate / FlinkLogicalWindowAggregate* does not allow
distinct
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8690:
-
Description:
Currently*, FlinkLogicalAggregate / FlinkLogicalWindowAggregate* does not allow
distinct
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8690:
-
Description:
**Currently, *FlinkLogicalAggregate* does not allow distinct aggregate.
We are proposing to
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8689:
-
Summary: Add runtime support of distinct filter using MapView (was: Add
runtime support of distinct
Rong Rong created FLINK-8739:
Summary: Optimize runtime support for distinct filter to reuse
same distinct accumulator for filtering
Key: FLINK-8739
URL: https://issues.apache.org/jira/browse/FLINK-8739
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8690:
-
Description:
**Currently, *FlinkLogicalAggregate* does not allow distinct aggregate.
We are propose to
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8690:
-
Description:
**Currently, *FlinkLogicalAggregate* does not allow distinct aggregate.
We are proposing to
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8689:
-
Description:
This ticket should cover distinct aggregate function support to codegen for
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8690:
-
Summary: Update logical rule set to generate FlinkLogicalAggregate
explicitly allow distinct agg on
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8689:
-
Description:
This should add distinct aggregate function support to codegen for
`AggregateCall`, where
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8689:
-
Description:
This ticket should cover distinct aggregate function support to codegen for
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8689:
-
Description:
This should add distinct aggregate function support to codegen for
`AggregateCall`, where
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8689:
Assignee: Rong Rong
> Add runtime support of distinct filter using MapView for GenerateAggregation
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8690:
Assignee: Rong Rong
> Update logical rule set to generate FlinkLogicalAggregate explicitly allow
301 - 400 of 449 matches
Mail list logo
