[
https://issues.apache.org/jira/browse/FLINK-19926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327570#comment-17327570
]
Flink Jira Bot commented on FLINK-19926:
----------------------------------------
This major issue is unassigned and itself and all of its Sub-Tasks have not
been updated for 30 days. So, it has been labeled "stale-major". If this ticket
is indeed "major", please either assign yourself or give an update. Afterwards,
please remove the label. In 7 days the issue will be deprioritized.
> Wrong results for join post tumble grouping
> -------------------------------------------
>
> Key: FLINK-19926
> URL: https://issues.apache.org/jira/browse/FLINK-19926
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.11.1
> Environment: Flink version: 1.11.1
> Reporter: Satyam Shekhar
> Priority: Major
> Labels: stale-major
>
> I have a table T0 with the following schema -
> {code:java}
> root
> |-- amount: BIGINT
> |-- timestamp: TIMESTAMP(3)
> {code}
>
> The table T0 has two rows -
> |amount|timestamp|
> |0|0|
> |1|86400000|
>
> The following query with tumble grouping returns the wrong result -
> {code:java}
> WITH CTE AS
> (SELECT SUM(amount) AS _output,
> TUMBLE_END(`timestamp`, INTERVAL '1' SECOND) AS _dim0
> FROM T0 GROUP BY TUMBLE(`timestamp`, INTERVAL '1' SECOND))
> SELECT V0._output as V0_output, V1._output AS V1_output,
> V0._dim0 as V0_time, V1._dim0 as V1_time
> FROM CTE as V0 INNER JOIN CTE V1 ON V0._dim0 = V1._dim0
> {code}
>
> The returned result is -
> |V0_output|V1_output|V0_time|V1_time|
> |1|1|86401000|86401000|
>
> The expected result is -
> |V0_output|V1_output|V0_time|V1_time|
> |0|0|1000|1000|
> |1|1|86401000|86401000|
>
> Running subquery for `CTE` returns the correct result -
> {code:java}
> SELECT SUM(amount) AS _output,
> TUMBLE_END(`timestamp`, INTERVAL '1' SECOND) AS _dim0
> FROM T0 GROUP BY TUMBLE(`timestamp`, INTERVAL '1' SECOND)
> {code}
>
> Result (this is correct) -
> |_output|_dim0|
> |0|1000|
> |1|86401000|
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
