Wenbing Shen created FLINK-36180:
Summary: Flink pulsar connector when restoring from the state, the
unconsumed messages of the first batch will be lost
Key: FLINK-36180
URL: https://issues.apache.org/jira/browse/
[
https://issues.apache.org/jira/browse/FLINK-35328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen updated FLINK-35328:
-
Description: AutoScale supports setting the maximum floating parallelism by
the number of Pulsar
Wenbing Shen created FLINK-35328:
Summary: AutoScale supports setting the maximum floating
parallelism by the number of Pulsar partitions
Key: FLINK-35328
URL: https://issues.apache.org/jira/browse/FLINK-35328
[
https://issues.apache.org/jira/browse/FLINK-35196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen closed FLINK-35196.
Resolution: Not A Problem
> bouncycastle class not found for flink pulsar connector
>
Wenbing Shen created FLINK-35196:
Summary: bouncycastle class not found for flink pulsar connector
Key: FLINK-35196
URL: https://issues.apache.org/jira/browse/FLINK-35196
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783869#comment-17783869
]
Bo Shen commented on FLINK-33479:
-
I have encountered a similar situation in JdbcSink a
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Shen updated FLINK-30960:
Description:
Here in production I have an environment consisting of a kafka source, to which
third-party
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781713#comment-17781713
]
Bo Shen edited comment on FLINK-30960 at 11/1/23 12:14 PM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781713#comment-17781713
]
Bo Shen commented on FLINK-30960:
-
This issue still exists in the latest master branch o
[
https://issues.apache.org/jira/browse/FLINK-31708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707942#comment-17707942
]
shen commented on FLINK-31708:
--
pull request:https://github.com/apache/flink/pull/22335
>
shen created FLINK-31708:
Summary: RuntimeException/KryoException thrown when deserializing
an empty protobuf record
Key: FLINK-31708
URL: https://issues.apache.org/jira/browse/FLINK-31708
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688044#comment-17688044
]
Bo Shen commented on FLINK-30960:
-
Just to share what I thought on this issue:
The issu
shen created FLINK-30989:
Summary: Configuration table.exec.spill-compression.block-size not
take effect in batch job
Key: FLINK-30989
URL: https://issues.apache.org/jira/browse/FLINK-30989
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685948#comment-17685948
]
Bo Shen edited comment on FLINK-30960 at 2/8/23 3:27 PM:
-
[~mart
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Shen updated FLINK-30960:
Attachment: heap-memory-metrics.png
> OutOfMemory error using jdbc sink
>
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Shen updated FLINK-30960:
Affects Version/s: 1.16.0
(was: 1.13.6)
> OutOfMemory error using jdbc sink
> -
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Shen updated FLINK-30960:
Attachment: taskmanager.log
> OutOfMemory error using jdbc sink
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685948#comment-17685948
]
Bo Shen commented on FLINK-30960:
-
[~martijnvisser] OK, will keep that in mind.
By look
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Shen updated FLINK-30960:
Attachment: (was: image-2023-02-08-16-57-07-850.png)
> OutOfMemory error using jdbc sink
> ---
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Shen updated FLINK-30960:
Attachment: image-2023-02-08-16-58-27-765.png
Description:
Here in production I have an environment c
Bo Shen created FLINK-30960:
---
Summary: OutOfMemory error using jdbc sink
Key: FLINK-30960
URL: https://issues.apache.org/jira/browse/FLINK-30960
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-29347:
-
Description:
I use protobuf generated class in an union list state.
When my flink job restores from checkpoint,
[
https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-29347:
-
Description:
I use protobuf generated class in an union list state.
When my flink job restores from checkpoint,
[
https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-29347:
-
Description:
I use protobuf generated class in an union list state.
When my flink job restores from checkpoint,
[
https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-29347:
-
Description:
I use protobuf generated class in an union list state.
When my flink job restores from checkpoint,
[
https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-29347:
-
Description:
I use protobuf generated class in an union list state.
When my flink job restores from checkpoint,
shen created FLINK-29347:
Summary: Failed to restore from list state with empty protobuf
object
Key: FLINK-29347
URL: https://issues.apache.org/jira/browse/FLINK-29347
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen resolved FLINK-28341.
--
Fix Version/s: 1.17.0
Resolution: Fixed
> Fix comment in BytesKeyNormalizationUtil.java
> -
[
https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605284#comment-17605284
]
shen commented on FLINK-28341:
--
problem solved, close this issue
> Fix comment in BytesKey
Wenbing Shen created FLINK-29207:
Summary: Pulsar message eventTime may be incorrectly set to a
negative number
Key: FLINK-29207
URL: https://issues.apache.org/jira/browse/FLINK-29207
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-28341:
-
Affects Version/s: 1.15.1
> Fix comment in BytesKeyNormalizationUtil.java
>
shen created FLINK-28341:
Summary: Fix comment in BytesKeyNormalizationUtil.java
Key: FLINK-28341
URL: https://issues.apache.org/jira/browse/FLINK-28341
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491782#comment-17491782
]
shen commented on FLINK-26050:
--
[~mayuehappy],
Using _state.backend.rocksdb.timer-service.
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489977#comment-17489977
]
shen commented on FLINK-26050:
--
Created a new [issue|https://github.com/facebook/rocksdb/is
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489976#comment-17489976
]
shen commented on FLINK-26050:
--
[~mayuehappy] , Thx for suggestion. We are actually testing
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-26050:
-
Description:
When using processing time window, in some workload, there will be a lot of
small sst files(server
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-26050:
-
Summary: Too many small sst files in rocksdb state backend when using
processing time window (was: Too Many sma
shen created FLINK-26050:
Summary: Too Many small sst files in rocksdb state backend when
using processing time window
Key: FLINK-26050
URL: https://issues.apache.org/jira/browse/FLINK-26050
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076782#comment-17076782
]
Yijie Shen commented on FLINK-14146:
It would be great if someone could help with re
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 Shen
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: Connect
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
Re
[
https://issues.apache.org/jira/browse/FLINK-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931022#comment-16931022
]
Yang Shen commented on FLINK-14091:
---
Same problem！
> Job can not trigger checkpoint f
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YuFeng Shen updated FLINK-10274:
Description:
When you are preparing to do a Flink framework version upgrading by using the
strate
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YuFeng Shen updated FLINK-10274:
Description:
When you are prepare to do a Flink framework version upgrading by using the
strategy
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598983#comment-16598983
]
YuFeng Shen edited comment on FLINK-10274 at 8/31/18 4:45 PM:
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598983#comment-16598983
]
YuFeng Shen edited comment on FLINK-10274 at 8/31/18 4:44 PM:
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YuFeng Shen updated FLINK-10274:
Description:
**When you are prepare to do a Flink framework version upgrading by using the
strate
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YuFeng Shen updated FLINK-10274:
Description:
**When you are prepare to do a Flink framework version upgrading by using the
strate
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598983#comment-16598983
]
YuFeng Shen commented on FLINK-10274:
-
After doing some checking I found Flink stop
[
https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598983#comment-16598983
]
YuFeng Shen edited comment on FLINK-10274 at 8/31/18 4:38 PM:
YuFeng Shen created FLINK-10274:
---
Summary: The stop-cluster.sh cannot stop cluster properly when
there are multiple clusters running
Key: FLINK-10274
URL: https://issues.apache.org/jira/browse/FLINK-10274
[
https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560571#comment-16560571
]
Jan Shen commented on FLINK-9985:
-
good job
> Incorrect parameter order in document
> --
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523913#comment-16523913
]
YuFeng Shen commented on FLINK-6962:
Any update on this functionality, I would like t
[
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.
Al
[
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.
Al
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
Proj
[
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 un
[
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&focusedCommentId=15289260#comment-15289260
]
Yijie Shen commented on FLINK-3926:
---
I've opened https://github.com/apache/flink/pull/20
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15289230#comment-15289230
]
Yijie Shen commented on FLINK-3926:
---
We have the test case:
{code}
public void testAsWit
[
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 s
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15289215#comment-15289215
]
Yijie Shen commented on FLINK-3926:
---
Yes, I know the convention of `f` followed by index
[
https://issues.apache.org/jira/browse/FLINK-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15289203#comment-15289203
]
Yijie Shen commented on FLINK-3926:
---
Yes, I know the convention of `f` followed by index
[
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* w
[
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* w
[
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 wou
[
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 Ty
[
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&focusedCommentId=15288879#comment-15288879
]
Yijie Shen commented on FLINK-3632:
---
Since #3754 has been resolved, I'll start to work o
[
https://issues.apache.org/jira/browse/FLINK-3891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279438#comment-15279438
]
Yijie Shen commented on FLINK-3891:
---
I think it will be great to implement this, looking
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241439#comment-15241439
]
Yijie Shen edited comment on FLINK-3723 at 4/14/16 4:44 PM:
On
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241439#comment-15241439
]
Yijie Shen edited comment on FLINK-3723 at 4/14/16 4:19 PM:
On
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241439#comment-15241439
]
Yijie Shen commented on FLINK-3723:
---
One more pro as far as I am concerned: Python Pand
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240459#comment-15240459
]
Yijie Shen edited comment on FLINK-3738 at 4/14/16 2:13 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240459#comment-15240459
]
Yijie Shen commented on FLINK-3738:
---
Hi [~fhueske], I've opened
{FLINK-3754|https://iss
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240459#comment-15240459
]
Yijie Shen edited comment on FLINK-3738 at 4/14/16 2:13 AM:
Hi
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
Issue
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238719#comment-15238719
]
Yijie Shen commented on FLINK-3738:
---
Hi [~fhueske], your idea make much sense to me.
Be
[
https://issues.apache.org/jira/browse/FLINK-3736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15236956#comment-15236956
]
Yijie Shen commented on FLINK-3736:
---
Ah I see, thanks :)
> Move toRexNode and toAggCall
[
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 we
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: Impro
[
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 we
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15235530#comment-15235530
]
Yijie Shen commented on FLINK-3723:
---
Ah, I see, thanks. it is implicitly checked by refe
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15235398#comment-15235398
]
Yijie Shen edited comment on FLINK-3723 at 4/11/16 4:24 PM:
bt
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15235398#comment-15235398
]
Yijie Shen commented on FLINK-3723:
---
btw, I was mislead by the javadoc first
{code}
Exam
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15235390#comment-15235390
]
Yijie Shen commented on FLINK-3723:
---
??Or do you assume that these will be implicitly ad
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15235085#comment-15235085
]
Yijie Shen commented on FLINK-3723:
---
Hi [~fhueske], thanks for your reply.
I'm new to fl
[
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 calci
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
95 matches
Mail list logo
