Rong Rong created FLINK-7357:
Summary: HOP_START() HOP_END() does not work when using HAVING
clause with GROUP BY HOP window
Key: FLINK-7357
URL: https://issues.apache.org/jira/browse/FLINK-7357
Project:
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120483#comment-16120483
]
Rong Rong commented on FLINK-7357:
--
Seems like the logical plan generated from Having inserts another
[
https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7177:
-
Component/s: Table API & SQL
> [table] Using Table API to perform aggregation on another Table API / SQL
[
https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7177:
-
Description:
For example:
[
https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7177:
-
Affects Version/s: 1.3.1
> [table] Using Table API to perform aggregation on another Table API / SQL
>
[
https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7177:
-
Description:
For example:
Rong Rong created FLINK-7177:
Summary: [table] Using Table API to perform aggregation on another
Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan
generation
Key: FLINK-7177
URL:
Rong Rong created FLINK-7137:
Summary: Flink table API defaults top level fields as nullable and
all nested fields within CompositeType as non-nullable
Key: FLINK-7137
URL:
[
https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7177:
-
Description:
For example:
[
https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16084680#comment-16084680
]
Rong Rong commented on FLINK-7003:
--
Probably need to write extensive tests to verify the resulting
Rong Rong created FLINK-7373:
Summary: Using URLClassLoader to load UDF triggers HepPlanner
unexpected ClassNotFoundException
Key: FLINK-7373
URL: https://issues.apache.org/jira/browse/FLINK-7373
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-7357:
Assignee: Rong Rong (was: Haohui Mai)
> HOP_START() HOP_END() does not work when using HAVING
[
https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-7373:
Assignee: Rong Rong
> Using URLClassLoader to load UDF triggers HepPlanner unexpected
>
[
https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7373:
-
Description:
Using URLClassLoader to load, say from Artifactory, and instantiate UDF
instances will
[
https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7373:
-
Description:
Using URLClassLoader to load, say from Artifactory, and instantiate UDF
instances will
Rong Rong created FLINK-7678:
Summary: SQL UserDefineTableFunction does not take CompositeType
input correctly
Key: FLINK-7678
URL: https://issues.apache.org/jira/browse/FLINK-7678
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16206774#comment-16206774
]
Rong Rong commented on FLINK-7373:
--
Hi [~fhueske], no we haven't found a great solution so we decided to
[
https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8151:
Assignee: Rong Rong
> [Table] removing map value equality check
>
Rong Rong created FLINK-8151:
Summary: [Table] removing map value equality check
Key: FLINK-8151
URL: https://issues.apache.org/jira/browse/FLINK-8151
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8151:
-
Summary: [Table] Clean up Map equality check (was: [Table] removing map
value equality check)
> [Table]
[
https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8151:
-
Description:
Following up with FLINK-8038. The equality check currently is broken. Plan to
support
[
https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8151:
-
Summary: [Table] Map equality check to use entrySet equality (was: [Table]
Clean up Map equality check)
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8104:
Assignee: Rong Rong
> Fix Row value constructor
> -
>
>
Rong Rong created FLINK-8104:
Summary: Fix Row value constructor
Key: FLINK-8104
URL: https://issues.apache.org/jira/browse/FLINK-8104
Project: Flink
Issue Type: Sub-task
Components:
Rong Rong created FLINK-8038:
Summary: Support MAP literal
Key: FLINK-8038
URL: https://issues.apache.org/jira/browse/FLINK-8038
Project: Flink
Issue Type: New Feature
Components:
[
https://issues.apache.org/jira/browse/FLINK-8038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8038:
-
Summary: Support MAP value constructor (was: Support MAP literal)
> Support MAP value constructor
>
[
https://issues.apache.org/jira/browse/FLINK-8038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8038:
-
Description:
Similar to https://issues.apache.org/jira/browse/FLINK-4554
We want to support Map value
[
https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8003:
-
Description:
We want to use the row value constructor and CAST to create a named row, or
even nested
[
https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8003:
-
Description:
We want to use the row value constructor and CAST to create a named row, or
even nested
[
https://issues.apache.org/jira/browse/FLINK-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282799#comment-16282799
]
Rong Rong commented on FLINK-8215:
--
Agree. as long as the ValidationException is thrown for TableAPI, we
Rong Rong created FLINK-8215:
Summary: Collections codegen exception when constructing Array or
Map via SQL API
Key: FLINK-8215
URL: https://issues.apache.org/jira/browse/FLINK-8215
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7923:
-
Component/s: Table API & SQL
> SQL parser exception when accessing subfields of a Composite element in an
Rong Rong created FLINK-7922:
Summary: leastRestrictive in FlinkTypeFactory does not resolve
composite type correctly
Key: FLINK-7922
URL: https://issues.apache.org/jira/browse/FLINK-7922
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7922:
-
Description:
FlinkTypeFactory does not override the following function correctly:
{code:java}
def
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7922:
-
Description:
FlinkTypeFactory does not override the following function correctly:
{code:scala}
def
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7922:
-
Component/s: Table API & SQL
> leastRestrictive in FlinkTypeFactory does not resolve composite type
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7922:
-
Description:
FlinkTypeFactory does not override the following function correctly:
{code:java}
def
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-7922:
-
Affects Version/s: 1.4.0
> leastRestrictive in FlinkTypeFactory does not resolve composite type correctly
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-7922:
Assignee: Rong Rong
> leastRestrictive in FlinkTypeFactory does not resolve composite type
Rong Rong created FLINK-7923:
Summary: SQL parser exception when accessing subfields of a
Composite element in an Object Array type column
Key: FLINK-7923
URL: https://issues.apache.org/jira/browse/FLINK-7923
[
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-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-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=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-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-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-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-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-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
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-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9398:
-
Description:
See:
[
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-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-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-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-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
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-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
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-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-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
[
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: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-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-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=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-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-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-9232:
Assignee: Rong Rong
> Add harness test for AggregationCodeGenerator
>
[
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
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-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}}
[
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
*{{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
[
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
*{{MAP}}*,
Rong Rong created FLINK-7934:
Summary: Upgrade Calcite dependency to 1.15
Key: FLINK-7934
URL: https://issues.apache.org/jira/browse/FLINK-7934
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16220895#comment-16220895
]
Rong Rong commented on FLINK-7923:
--
Done, created umbrella task for Calcite 1.15 release.
> SQL parser
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:
-
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 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:
-
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-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 should add distinct aggregate function support to codegen for
`AggregateCall`, where
[
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-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
1 - 100 of 449 matches
Mail list logo
