[
https://issues.apache.org/jira/browse/FLINK-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076782#comment-17076782
]
Yijie Shen commented on FLINK-14146:
It would be great if someone could help with reviewing these
Yijie Shen created FLINK-15624:
--
Summary: Pulsar Sink
Key: FLINK-15624
URL: https://issues.apache.org/jira/browse/FLINK-15624
Project: Flink
Issue Type: Sub-task
Reporter: Yijie
Yijie Shen created FLINK-15089:
--
Summary: Pulsar Catalog
Key: FLINK-15089
URL: https://issues.apache.org/jira/browse/FLINK-15089
Project: Flink
Issue Type: Sub-task
Components:
Yijie Shen created FLINK-14146:
--
Summary: Introduce Pulsar connector
Key: FLINK-14146
URL: https://issues.apache.org/jira/browse/FLINK-14146
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3988:
--
Description:
I would like to add a connector to DistributedLog, which recently published by
twitter.
[
https://issues.apache.org/jira/browse/FLINK-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3987:
--
Description:
I would like to add a connector to DistributedLog, which recently published by
twitter.
Yijie Shen created FLINK-3976:
-
Summary: Alias fields of physical plan node to avoid name
collision with Calcite protected fields
Key: FLINK-3976
URL: https://issues.apache.org/jira/browse/FLINK-3976
[
https://issues.apache.org/jira/browse/FLINK-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3976:
--
Description:
The field name collisions in physical plan node make IDE hard to get a field's
type and
[
https://issues.apache.org/jira/browse/FLINK-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen reassigned FLINK-3941:
-
Assignee: Yijie Shen
> Add support for UNION (with duplicate elimination)
>
[
https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3940:
--
Flagged: Impediment
> Add support for ORDER BY OFFSET FETCH
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3940:
--
Flagged: (was: Impediment)
> Add support for ORDER BY OFFSET FETCH
>
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15289260#comment-15289260
]
Yijie Shen commented on FLINK-3926:
---
I've opened https://github.com/apache/flink/pull/2004 to fix this.
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15289230#comment-15289230
]
Yijie Shen commented on FLINK-3926:
---
We have the test case:
{code}
public void
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3926:
--
Comment: was deleted
(was: Yes, I know the convention of `f` followed by index, but it's a public
API
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15289215#comment-15289215
]
Yijie Shen commented on FLINK-3926:
---
Yes, I know the convention of `f` followed by index, but it's a
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15289203#comment-15289203
]
Yijie Shen commented on FLINK-3926:
---
Yes, I know the convention of `f` followed by index, but it's a
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3926:
--
Component/s: Core
> Incorrect implementation of getFieldIndex in TupleTypeInfo
>
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3926:
--
Affects Version/s: 1.0.2
> Incorrect implementation of getFieldIndex in TupleTypeInfo
>
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3926:
--
Description:
The origin code assumes filed name as f`i` which is not always true.
Finding a field *x*
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3926:
--
Description:
The origin code assumes filed name as *f2* which is not always true.
Finding a field *x*
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3926:
--
Description:
The origin code assumes filed name as f`i` which is not always true.
Finding a field a
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3926:
--
Priority: Minor (was: Major)
> Incorrect implementation of getFieldIndex in TupleTypeInfo
>
Yijie Shen created FLINK-3926:
-
Summary: Incorrect implementation of getFieldIndex in
TupleTypeInfo
Key: FLINK-3926
URL: https://issues.apache.org/jira/browse/FLINK-3926
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen reassigned FLINK-3632:
-
Assignee: Yijie Shen
> Clean up Table API exceptions
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15288879#comment-15288879
]
Yijie Shen commented on FLINK-3632:
---
Since #3754 has been resolved, I'll start to work on this one. :)
[
https://issues.apache.org/jira/browse/FLINK-3891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279438#comment-15279438
]
Yijie Shen commented on FLINK-3891:
---
I think it will be great to implement this, looking forward the PR
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15241439#comment-15241439
]
Yijie Shen edited comment on FLINK-3723 at 4/14/16 4:44 PM:
One more pro as
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15241439#comment-15241439
]
Yijie Shen edited comment on FLINK-3723 at 4/14/16 4:19 PM:
One more pro as
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15241439#comment-15241439
]
Yijie Shen commented on FLINK-3723:
---
One more pro as far as I am concerned: Python Panda Library, as
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15240459#comment-15240459
]
Yijie Shen edited comment on FLINK-3738 at 4/14/16 2:13 AM:
Hi [~fhueske],
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15240459#comment-15240459
]
Yijie Shen commented on FLINK-3738:
---
Hi [~fhueske], I've opened
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15240459#comment-15240459
]
Yijie Shen edited comment on FLINK-3738 at 4/14/16 2:13 AM:
Hi [~fhueske],
Yijie Shen created FLINK-3754:
-
Summary: Add a validation phase before construct RelNode using
TableAPI
Key: FLINK-3754
URL: https://issues.apache.org/jira/browse/FLINK-3754
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15238719#comment-15238719
]
Yijie Shen commented on FLINK-3738:
---
Hi [~fhueske], your idea make much sense to me.
Besides you have
[
https://issues.apache.org/jira/browse/FLINK-3736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15236956#comment-15236956
]
Yijie Shen commented on FLINK-3736:
---
Ah I see, thanks :)
> Move toRexNode and toAggCall logic into
[
https://issues.apache.org/jira/browse/FLINK-3736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3736:
--
Description: Since we have a one-to-one mapping from Flink {{Expression}}
to Calcite {{RexNode}}, and
Yijie Shen created FLINK-3736:
-
Summary: Move toRexNode and toAggCall logic into Expressions
Key: FLINK-3736
URL: https://issues.apache.org/jira/browse/FLINK-3736
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3736:
--
Description: Since we have a one-to-one mapping from Flink {{Expression}}
to Calcite {{RexNode}}, and
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235530#comment-15235530
]
Yijie Shen commented on FLINK-3723:
---
Ah, I see, thanks. it is implicitly checked by referring to the
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235398#comment-15235398
]
Yijie Shen edited comment on FLINK-3723 at 4/11/16 4:24 PM:
btw, I was misled
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235398#comment-15235398
]
Yijie Shen commented on FLINK-3723:
---
btw, I was mislead by the javadoc first
{code}
Example:
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235390#comment-15235390
]
Yijie Shen commented on FLINK-3723:
---
??Or do you assume that these will be implicitly added because they
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235085#comment-15235085
]
Yijie Shen commented on FLINK-3723:
---
Hi [~fhueske], thanks for your reply.
I'm new to flink and reading
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3723:
--
Description:
When we type {code}select deptno, name, max(age) from dept group by
deptno;{code} in
Yijie Shen created FLINK-3723:
-
Summary: Aggregate Functions and scalar expressions shouldn't be
mixed in select
Key: FLINK-3723
URL: https://issues.apache.org/jira/browse/FLINK-3723
Project: Flink
45 matches
Mail list logo
