[
https://issues.apache.org/jira/browse/FLINK-31742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710824#comment-17710824
]
Shuo Cheng commented on FLINK-31742:
[~lemonjing] LGTM
> Replace deprecated TableSc
[
https://issues.apache.org/jira/browse/FLINK-31742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709203#comment-17709203
]
Shuo Cheng commented on FLINK-31742:
Hi, [~lemonjing] , changes of public API genera
[
https://issues.apache.org/jira/browse/FLINK-29990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-29990:
---
Description:
Consider the following DDL sql (LIKE without any options):
{code:java}
create table sou
[
https://issues.apache.org/jira/browse/FLINK-29990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-29990:
---
Description:
Consider the following DDL sql:
{code:java}
create table source_table(
a int,
b big
Shuo Cheng created FLINK-29990:
--
Summary: Unparsed SQL for SqlTableLike cannot be parsed correctly
Key: FLINK-29990
URL: https://issues.apache.org/jira/browse/FLINK-29990
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474325#comment-17474325
]
Shuo Cheng commented on FLINK-25095:
Similar issue: FLINK-20765
> Case when would b
[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447766#comment-17447766
]
Shuo Cheng commented on FLINK-24997:
[~zouyunhe] you can follow the similar Jira FLI
[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447758#comment-17447758
]
Shuo Cheng commented on FLINK-24997:
Flink use Calcite to parse SQL, and Calcite has
[
https://issues.apache.org/jira/browse/FLINK-24809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440170#comment-17440170
]
Shuo Cheng commented on FLINK-24809:
`SumWithRetractAggFunction` as well.
> Check &
Shuo Cheng created FLINK-24762:
--
Summary: Remove agg function: INCR_SUM
Key: FLINK-24762
URL: https://issues.apache.org/jira/browse/FLINK-24762
Project: Flink
Issue Type: Improvement
C
Shuo Cheng created FLINK-24598:
--
Summary: Current IT case do not cover fallback path for hash
aggregate
Key: FLINK-24598
URL: https://issues.apache.org/jira/browse/FLINK-24598
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-23086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng closed FLINK-23086.
--
Fix Version/s: (was: 1.15.0)
1.14.0
Resolution: Duplicate
> Add getRunti
[
https://issues.apache.org/jira/browse/FLINK-23136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng closed FLINK-23136.
--
Fix Version/s: 1.14.0
Resolution: Duplicate
> Make `addSource` method with specific boundedness
[
https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414800#comment-17414800
]
Shuo Cheng commented on FLINK-24001:
For session window, when merging two windows, I
[
https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-24048:
---
Description:
Currently, when there are multiple sinks in a sql job, the DAG is split into
multiple
[
https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-24048:
---
Description:
Currently, when there are multiple sinks in a sql job, the DAG is split into
multiple
Shuo Cheng created FLINK-24048:
--
Summary: Move changeLog inference out of optimizing phase
Key: FLINK-24048
URL: https://issues.apache.org/jira/browse/FLINK-24048
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
---
Description:
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode
[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
---
Description:
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode
[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
---
Description:
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode
[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
---
Description:
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode
[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
---
Description:
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode
[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
---
Description:
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode
[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
---
Description:
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode
Shuo Cheng created FLINK-23962:
--
Summary: UpdateKind trait is not propagated properly in changeLog
inference for DAG optimizing
Key: FLINK-23962
URL: https://issues.apache.org/jira/browse/FLINK-23962
Pro
Shuo Cheng created FLINK-23827:
--
Summary: Fix ModifiedMonotonicity inference for some node
Key: FLINK-23827
URL: https://issues.apache.org/jira/browse/FLINK-23827
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-23310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377223#comment-17377223
]
Shuo Cheng commented on FLINK-23310:
cc [~qingru zhang]
> Correct the `ModifyKindSe
[
https://issues.apache.org/jira/browse/FLINK-23310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23310:
---
Component/s: (was: Table SQL / API)
Table SQL / Planner
> Correct the `ModifyKi
Shuo Cheng created FLINK-23310:
--
Summary: Correct the `ModifyKindSetTrait` for
`GroupWindowAggregate` when the input is an update stream
Key: FLINK-23310
URL: https://issues.apache.org/jira/browse/FLINK-23310
[
https://issues.apache.org/jira/browse/FLINK-23107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377003#comment-17377003
]
Shuo Cheng commented on FLINK-23107:
cc [~lzljs3620320], I'll take this Jira.
> Sep
[
https://issues.apache.org/jira/browse/FLINK-21573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376399#comment-17376399
]
Shuo Cheng commented on FLINK-21573:
This is related to this Calcite JRIA
[CALCITE-
[
https://issues.apache.org/jira/browse/FLINK-23136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368675#comment-17368675
]
Shuo Cheng commented on FLINK-23136:
cc [~dwysakowicz]
> Make `addSource` method wi
Shuo Cheng created FLINK-23136:
--
Summary: Make `addSource` method with specific boundedness in
`StreamExecutionEnvironment` public
Key: FLINK-23136
URL: https://issues.apache.org/jira/browse/FLINK-23136
Shuo Cheng created FLINK-23086:
--
Summary: Add getRuntimeExecutionMode to StreamExecutionEnvironment
Key: FLINK-23086
URL: https://issues.apache.org/jira/browse/FLINK-23086
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353126#comment-17353126
]
Shuo Cheng commented on FLINK-22781:
[~qingru zhang], I think what you mentioned abo
[
https://issues.apache.org/jira/browse/FLINK-19926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350250#comment-17350250
]
Shuo Cheng edited comment on FLINK-19926 at 5/24/21, 5:56 AM:
[
https://issues.apache.org/jira/browse/FLINK-19926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350250#comment-17350250
]
Shuo Cheng commented on FLINK-19926:
Hi, [~satyamshekhar], I've test the case you pr
[
https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343658#comment-17343658
]
Shuo Cheng commented on FLINK-19796:
This jira seems silent for long time. I'll take
[
https://issues.apache.org/jira/browse/FLINK-22586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-22586:
---
Description:
Currently the precision and scale derivation is not properly for decimal data
arithmet
[
https://issues.apache.org/jira/browse/FLINK-22586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-22586:
---
Description:
Currently the precision and scale derivation is not properly for decimal data
arithmet
Shuo Cheng created FLINK-22586:
--
Summary: Improve precision derivation for decimal arithmetics
Key: FLINK-22586
URL: https://issues.apache.org/jira/browse/FLINK-22586
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-22182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340112#comment-17340112
]
Shuo Cheng commented on FLINK-22182:
Actually, the precision of the result may be la
[
https://issues.apache.org/jira/browse/FLINK-22182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331446#comment-17331446
]
Shuo Cheng edited comment on FLINK-22182 at 4/25/21, 8:12 AM:
[
https://issues.apache.org/jira/browse/FLINK-22182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331446#comment-17331446
]
Shuo Cheng commented on FLINK-22182:
Hi [~maver1ck], I think the result is not wrong
[
https://issues.apache.org/jira/browse/FLINK-22304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-22304:
---
Summary: Refactor some interfaces for TVF based window to improve the
extendability (was: Refactor
[
https://issues.apache.org/jira/browse/FLINK-22304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-22304:
---
Fix Version/s: (was: 1.13.1)
1.13.0
> Refactor some interfaces for TVF based
Shuo Cheng created FLINK-22304:
--
Summary: Refactor some interfaces for TVF based window to improve
the scalability
Key: FLINK-22304
URL: https://issues.apache.org/jira/browse/FLINK-22304
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319188#comment-17319188
]
Shuo Cheng commented on FLINK-21247:
Hi [~txdong-sz], it seems you are offline for s
[
https://issues.apache.org/jira/browse/FLINK-21613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17317627#comment-17317627
]
Shuo Cheng commented on FLINK-21613:
Thks [~yr] for the efforts, I think we can leav
[
https://issues.apache.org/jira/browse/FLINK-22063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316903#comment-17316903
]
Shuo Cheng commented on FLINK-22063:
[~Leonard Xu] Not start yet, but will soon..
>
[
https://issues.apache.org/jira/browse/FLINK-22148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316902#comment-17316902
]
Shuo Cheng commented on FLINK-22148:
[~godfreyhe], I'll solve this problem.
> Plann
Shuo Cheng created FLINK-22148:
--
Summary: Planner rules should use RexCall#equsls to check whether
two rexCalls are equivalent
Key: FLINK-22148
URL: https://issues.apache.org/jira/browse/FLINK-22148
Proj
Shuo Cheng created FLINK-22063:
--
Summary: Lookup Join outputs wrong results for some scenario
Key: FLINK-22063
URL: https://issues.apache.org/jira/browse/FLINK-22063
Project: Flink
Issue Type: N
Shuo Cheng created FLINK-21613:
--
Summary: Parse Compute Column with `IN` expression throws NPE
Key: FLINK-21613
URL: https://issues.apache.org/jira/browse/FLINK-21613
Project: Flink
Issue Type:
Shuo Cheng created FLINK-20826:
--
Summary: Fix bug in streaming SQL examples
Key: FLINK-20826
URL: https://issues.apache.org/jira/browse/FLINK-20826
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-20670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-20670:
---
Description:
Now Flink has supported dynamic table options based on the Hint framework of
Calcite.
[
https://issues.apache.org/jira/browse/FLINK-20670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-20670:
---
Description:
Now Flink has supported dynamic table options based on the Hint framework of
Calcite.
Shuo Cheng created FLINK-20670:
--
Summary: Support query hints for Flink SQL
Key: FLINK-20670
URL: https://issues.apache.org/jira/browse/FLINK-20670
Project: Flink
Issue Type: New Feature
Shuo Cheng created FLINK-17651:
--
Summary: DecomposeGroupingSetsRule generates wrong plan when there
exist distinct agg and simple agg with same filter
Key: FLINK-17651
URL: https://issues.apache.org/jira/browse/FLINK
Shuo Cheng created FLINK-17649:
--
Summary: Generated hash aggregate code may produce NPE when there
exists an aggregate call with Filter.
Key: FLINK-17649
URL: https://issues.apache.org/jira/browse/FLINK-17649
[
https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058401#comment-17058401
]
Shuo Cheng edited comment on FLINK-16578 at 3/13/20, 3:35 AM:
[
https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058401#comment-17058401
]
Shuo Cheng edited comment on FLINK-16578 at 3/13/20, 3:34 AM:
[
https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058401#comment-17058401
]
Shuo Cheng commented on FLINK-16578:
One hack way is copy `RelDecorrelator` from Cal
[
https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-16578:
---
Description:
Reproducing:
{code:java}
// CorrelateITCase.scala
@Test
def testJoinTableFunction():
[
https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058390#comment-17058390
]
Shuo Cheng commented on FLINK-16578:
cc [~jark], [~danny0405]
> join lateral table
Shuo Cheng created FLINK-16578:
--
Summary: join lateral table function with condition fails with
exception
Key: FLINK-16578
URL: https://issues.apache.org/jira/browse/FLINK-16578
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058370#comment-17058370
]
Shuo Cheng edited comment on FLINK-16577 at 3/13/20, 2:45 AM:
[
https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058370#comment-17058370
]
Shuo Cheng commented on FLINK-16577:
I think one possible solution is when we get va
[
https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058365#comment-17058365
]
Shuo Cheng commented on FLINK-16577:
cc [~godfreyhe], [~jark]
> Exception will be t
Shuo Cheng created FLINK-16577:
--
Summary: Exception will be thrown when computing columnInterval
relmetadata in some case
Key: FLINK-16577
URL: https://issues.apache.org/jira/browse/FLINK-16577
Project:
Shuo Cheng created FLINK-15537:
--
Summary: Type of keys should be `BinaryRow` when manipulating map
state with `BaseRow` as key type.
Key: FLINK-15537
URL: https://issues.apache.org/jira/browse/FLINK-15537
[
https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007255#comment-17007255
]
Shuo Cheng commented on FLINK-15466:
@[~godfreyhe], [~jark], [~lincoln.86xy]
> `Fli
[
https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-15466:
---
Attachment: (was: image-2020-01-03-14-20-54-887.png)
> `FlinkAggregateExpandDistinctAggregatesRu
[
https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-15466:
---
Attachment: image-2020-01-03-14-24-35-943.png
> `FlinkAggregateExpandDistinctAggregatesRule` generat
[
https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-15466:
---
Description:
For the sql in batch mode,
{code:java}
SELECT
a, COUNT(a), SUM(DISTINCT b) FILTE
Shuo Cheng created FLINK-15466:
--
Summary: `FlinkAggregateExpandDistinctAggregatesRule` generates
wrong plan for cases that have distinct aggs with filter.
Key: FLINK-15466
URL: https://issues.apache.org/jira/browse/F
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694096#comment-16694096
]
Shuo Cheng edited comment on FLINK-5601 at 11/21/18 3:16 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694096#comment-16694096
]
Shuo Cheng commented on FLINK-5601:
---
Hi, JiaYi, You say that the watermark restored is
78 matches
Mail list logo
