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&focusedCommentId=16206774#comment-16206774
]
Rong Rong commented on FLINK-7373:
--
Hi [~fhueske], no we haven't found a great solution s
[
https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10556:
--
Description:
This is an umbrella JIRA tracking all enhancement and issues related to
integrating Flin
Rong Rong created FLINK-11006:
-
Summary: Update Calcite dependency to 1.18
Key: FLINK-11006
URL: https://issues.apache.org/jira/browse/FLINK-11006
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704949#comment-16704949
]
Rong Rong commented on FLINK-8739:
--
No I haven't started. please feel free to assign to
[
https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706398#comment-16706398
]
Rong Rong commented on FLINK-11010:
---
Based on the discussion in the mailing list:
htt
Rong Rong created FLINK-11088:
-
Summary: Improve Kerberos Authentication using Keytab in YARN
proxy user mode
Key: FLINK-11088
URL: https://issues.apache.org/jira/browse/FLINK-11088
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11088:
--
Component/s: Security
> Improve Kerberos Authentication using Keytab in YARN proxy user mode
> ---
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-11088:
-
Assignee: Rong Rong
> Improve Kerberos Authentication using Keytab in YARN proxy user mode
> --
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16714128#comment-16714128
]
Rong Rong commented on FLINK-11088:
---
Initial investigation needs to find a way to dist
[
https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16716173#comment-16716173
]
Rong Rong commented on FLINK-11081:
---
+1 to this feature. Very helpful actually for lot
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11088:
--
Description:
Currently flink-yarn assumes keytab is shipped as application master
environment local r
[
https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16634867#comment-16634867
]
Rong Rong commented on FLINK-10474:
---
Voting for the first approach.
I was actually wo
[
https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635666#comment-16635666
]
Rong Rong commented on FLINK-10474:
---
Yes. I think having cascaded predicates are defin
[
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638159#comment-16638159
]
Rong Rong commented on FLINK-8880:
--
[~twalthr] yes aboslutely. please go ahead.
> Vali
[
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8880:
Assignee: (was: Rong Rong)
> Validate configurations for SQL Client
>
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:
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
Project:
[
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 cause
[
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 cause
[
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
> ClassNotFo
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120483#comment-16120483
]
Rong Rong commented on FLINK-7357:
--
Seems like the logical plan generated from Having ins
[
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 clau
[
https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921546#comment-16921546
]
Rong Rong commented on FLINK-12399:
---
Hi [~fhueske]. would you please kindly take a loo
[
https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833107#comment-16833107
]
Rong Rong edited comment on FLINK-12399 at 9/4/19 4:28 PM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932569#comment-16932569
]
Rong Rong commented on FLINK-11936:
---
[~danny0405] yes. I think that would be great.
>
[
https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841511#comment-16841511
]
Rong Rong commented on FLINK-10232:
---
Thanks Danny for bringing this up.
I think we c
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852147#comment-16852147
]
Rong Rong commented on FLINK-11921:
---
Hi [~twalthr], [~danny0405] and I discussed brief
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11921:
--
Summary: Upgrade Calcite dependency to 1.20 (was: Upgrade Calcite
dependency to 1.19)
> Upgrade Calc
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11921:
--
Description:
Umbrella issue for all tasks related to the next Calcite upgrade to 1.20.x
release
We w
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858835#comment-16858835
]
Rong Rong commented on FLINK-11921:
---
changed title as discussed: we will skip 1.19, di
[
https://issues.apache.org/jira/browse/FLINK-12872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866178#comment-16866178
]
Rong Rong commented on FLINK-12872:
---
This might be a [related
reading|https://stackov
[
https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072854#comment-17072854
]
Rong Rong commented on FLINK-16522:
---
Is this Jira referring to TypeChecking as well?
[
https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-16522:
--
Description: [Type Hints|https://www.python.org/dev/peps/pep-0484/] was
introduced in Python 3.5 and i
[
https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-16522:
--
Description: [Type Hints|https://www.python.org/dev/peps/pep-0484/] was
introduced in Python 3.5 and i
[
https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076873#comment-17076873
]
Rong Rong commented on FLINK-16522:
---
Thanks for the clarification. huge +1. looking fo
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9630:
-
Comment: was deleted
(was: Hi All,
Is this a duplicate of FLINK-8497 ?)
> Kafka09PartitionDiscoverer ca
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997755#comment-16997755
]
Rong Rong commented on FLINK-9630:
--
Hi All,
Is this a duplicate of FLINK-8497 ?
> Kafk
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997757#comment-16997757
]
Rong Rong commented on FLINK-9630:
--
Hi All,
is this connected somehow with FLINK-8497?
[
https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-15451:
-
Assignee: Rong Rong
> TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailur
[
https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-15451:
-
Assignee: (was: Rong Rong)
> TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerPr
[
https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007605#comment-17007605
]
Rong Rong commented on FLINK-11120:
---
Hi [~x1q1j1] yes it will be in 1.10 release and i
Rong Rong created FLINK-15475:
-
Summary: Add isOutputTypeUsed() API to Transformation
Key: FLINK-15475
URL: https://issues.apache.org/jira/browse/FLINK-15475
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-15475:
--
Description:
Currently there's no way to "peek" into a `Transformation` object and see if
`typeUsed`
[
https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-15475:
--
Description:
Currently there's no way to "peek" into a `Transformation` object and see if
`typeUsed`
[
https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-15475:
--
Description:
Currently there's no way to "peek" into a `Transformation` object and see if
`typeUsed`
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong closed FLINK-17386.
-
Fix Version/s: 1.11.0
Resolution: Fixed
> Exception in HadoopSecurityContextFactory.createContext
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109703#comment-17109703
]
Rong Rong commented on FLINK-17386:
---
closed via: 1892bedeea9fa118b6e3bcb572f63c2e7f6d8
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-17386:
--
Component/s: Deployment / YARN
> Exception in HadoopSecurityContextFactory.createContext while no
> s
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-17386:
--
Affects Version/s: 1.11.0
> Exception in HadoopSecurityContextFactory.createContext while no
> shaded
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:
-
Component/s: Table API & SQL
> leastRestrictive in FlinkTypeFactory does not resolve composite type correc
[
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 leastRes
[
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 correctl
[
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 leastRe
[
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 leastRes
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-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-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
Reporter
[
https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220895#comment-16220895
]
Rong Rong commented on FLINK-7923:
--
Done, created umbrella task for Calcite 1.15 release.
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: Table
[
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 cons
[
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 name
[
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 name
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: Ta
[
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
> -
>
> Key
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
Com
[
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
> -
[
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 elemen
[
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-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539256#comment-16539256
]
Rong Rong commented on FLINK-8985:
--
Thanks [~florianschmidt] for the exhausted listing f
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541084#comment-16541084
]
Rong Rong commented on FLINK-9294:
--
hmm. nvm. I think I messed up with scala/java implic
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16547269#comment-16547269
]
Rong Rong commented on FLINK-8985:
--
Yeah I agree, I would put more thought on this in a
[
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}}*, *{{ARR
[
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}}*, *{{ARR
[
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}}*, *{{ARR
[
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}}*, *{{ARR
[
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}}*, *{{ARR
[
https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16551884#comment-16551884
]
Rong Rong commented on FLINK-9134:
--
Calcite 1.17 has been
[released|https://mail-archiv
[
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}}*, *{{ARR
[
https://issues.apache.org/jira/browse/FLINK-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-8691:
-
Issue Type: Improvement (was: Sub-task)
Parent: (was: FLINK-8688)
> Update table API to supp
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-5315:
Assignee: Rong Rong
> Support distinct aggregations in table api
> ---
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5315:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-8688
> Support distinct aggregations in ta
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554326#comment-16554326
]
Rong Rong commented on FLINK-5315:
--
Since FLINK-8689 and FLINK-8690 has been checked in,
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554866#comment-16554866
]
Rong Rong commented on FLINK-9294:
--
Had an initial diff for discussion on what needs to
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555898#comment-16555898
]
Rong Rong edited comment on FLINK-5315 at 7/25/18 4:16 PM:
---
Oop
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555898#comment-16555898
]
Rong Rong commented on FLINK-5315:
--
Oops. sorry that was what I meant [~twalthr] to use
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559889#comment-16559889
]
Rong Rong commented on FLINK-5315:
--
Yes [~hequn8128]. Currently I am transferring the di
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559889#comment-16559889
]
Rong Rong edited comment on FLINK-5315 at 7/27/18 5:05 PM:
---
Yes
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560803#comment-16560803
]
Rong Rong commented on FLINK-5315:
--
Hmm. Yes that's true we cannot have {{a.distinct}} b
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560803#comment-16560803
]
Rong Rong edited comment on FLINK-5315 at 7/28/18 9:38 PM:
---
Hmm
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563766#comment-16563766
]
Rong Rong commented on FLINK-5315:
--
Actually I agree with [~hequn8128] that these are tw
Rong Rong created FLINK-10010:
-
Summary: Deprecate unused BaseAlignedWindowAssigner related
components
Key: FLINK-10010
URL: https://issues.apache.org/jira/browse/FLINK-10010
Project: Flink
Issu
Rong Rong created FLINK-10019:
-
Summary: Fix Composite getResultType of UDF cannot be chained with
other operators
Key: FLINK-10019
URL: https://issues.apache.org/jira/browse/FLINK-10019
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10019:
--
Description:
If explicitly return a CompositeType in {{udf.getResultType}}, will result in
some failu
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5315:
-
Description:
Support distinct aggregations in Table API in the following format:
For Expressions:
{code:
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5315:
-
Description:
Support distinct aggregations in Table API in the following format:
For Expressions:
{code:
1 - 100 of 449 matches
Mail list logo