Rong Rong created FLINK-8691:
Summary: Update table API to support distinct operator on data
stream
Key: FLINK-8691
URL: https://issues.apache.org/jira/browse/FLINK-8691
Project: Flink
Issue
Rong Rong created FLINK-8690:
Summary: Update logical rule set to generate FlinkLogicalAggregate
explicitly allow distinct operator
Key: FLINK-8690
URL: https://issues.apache.org/jira/browse/FLINK-8690
Rong Rong created FLINK-8689:
Summary: Add runtime support of distinct filter using MapView for
GenerateAggregation
Key: FLINK-8689
URL: https://issues.apache.org/jira/browse/FLINK-8689
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368585#comment-16368585
]
Rong Rong commented on FLINK-8688:
--
Related distinct aggregate feature request JIRA
> Enable distinct
[
https://issues.apache.org/jira/browse/FLINK-8688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8688:
-
Description:
Distinct aggregation is not currently supported on data stream with Table/SQL
API. This is
[
https://issues.apache.org/jira/browse/FLINK-8688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8688:
-
Description:
Distinct aggregation is not currently supported on data stream with Table/SQL
API. This is
Rong Rong created FLINK-8688:
Summary: Enable distinct aggregation for data stream on Table/SQL
API
Key: FLINK-8688
URL: https://issues.apache.org/jira/browse/FLINK-8688
Project: Flink
Issue
[
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-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-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] 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 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-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:
[
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-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-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
>
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-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-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: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-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-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:
-
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 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 reassigned FLINK-7922:
Assignee: Rong Rong
> leastRestrictive in FlinkTypeFactory does not resolve composite type
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-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
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-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-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-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-7373:
Summary: Using URLClassLoader to load UDF triggers HepPlanner
unexpected ClassNotFoundException
Key: FLINK-7373
URL: https://issues.apache.org/jira/browse/FLINK-7373
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-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:
-
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:
[
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-7137:
Summary: Flink table API defaults top level fields as nullable and
all nested fields within CompositeType as non-nullable
Key: FLINK-7137
URL:
401 - 449 of 449 matches
Mail list logo
