[
https://issues.apache.org/jira/browse/FLINK-16296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046366#comment-17046366
]
Kurt Young commented on FLINK-16296:
The reason behind this was an non-obvious design choice:
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046357#comment-17046357
]
Kurt Young commented on FLINK-14807:
[~becket_qin] Your first point is actually the root of
[
https://issues.apache.org/jira/browse/FLINK-16286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045203#comment-17045203
]
Kurt Young commented on FLINK-16286:
Isn't this already supported?
> Support select from nothing
>
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045155#comment-17045155
]
Kurt Young commented on FLINK-14807:
A side comment: if we want this API fully deal with fault
[
https://issues.apache.org/jira/browse/FLINK-15990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15990:
---
Component/s: API / Python
> Remove register source and sink in ConnectTableDescriptor
>
[
https://issues.apache.org/jira/browse/FLINK-15990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-15990.
--
Resolution: Fixed
master: 0398c30650fe7baa586b6534366bd37e1a1c1286
> Remove register source and sink
[
https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15950:
---
Description:
This ticket would track the removal of direct TableSource/TableSink
registration to
[
https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15950:
---
Labels: breaking-api (was: )
> Remove registration of TableSource/TableSink in Table Env and
>
Kurt Young created FLINK-15950:
--
Summary: Remove registration of TableSource/TableSink in Table Env
and ConnectTableDescriptor
Key: FLINK-15950
URL: https://issues.apache.org/jira/browse/FLINK-15950
[
https://issues.apache.org/jira/browse/FLINK-15613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15613:
---
Fix Version/s: (was: 1.10.0)
1.11.0
> execute sql appear
[
https://issues.apache.org/jira/browse/FLINK-15928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15928:
--
Assignee: Jingsong Lee
> Batch mode in blink planner caused IndexOutOfBoundsException error
[
https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-15858.
--
Assignee: Rui Li
Resolution: Fixed
1.10.0: ba5b5b77cdfeafa4b84028d48af66f130a2cc071
master:
[
https://issues.apache.org/jira/browse/FLINK-15881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-15881.
--
Resolution: Duplicate
> Stop overriding TableSource::getReturnType in jdbc connector
>
[
https://issues.apache.org/jira/browse/FLINK-15881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030385#comment-17030385
]
Kurt Young commented on FLINK-15881:
Thanks for the notice.
> Stop overriding
[
https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030368#comment-17030368
]
Kurt Young commented on FLINK-15858:
Consider we don't have much time, fix this issue and improve
[
https://issues.apache.org/jira/browse/FLINK-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15896:
--
Assignee: Danny Chen
> Stop using TableSource::getTableSchema
>
[
https://issues.apache.org/jira/browse/FLINK-15894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15894:
--
Assignee: Danny Chen
> Stop overriding TableSource::getTableSchema in flink walkthrough
>
[
https://issues.apache.org/jira/browse/FLINK-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15878:
--
Assignee: Danny Chen
> Stop overriding TableSource::getReturnType in tests
>
[
https://issues.apache.org/jira/browse/FLINK-15885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15885:
--
Assignee: Danny Chen
> Stop overriding TableSource::getTableSchema in tests
>
[
https://issues.apache.org/jira/browse/FLINK-15895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15895:
--
Assignee: Danny Chen
> Stop using TableSource::getReturnType except for compatibility
[
https://issues.apache.org/jira/browse/FLINK-15877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15877:
---
Priority: Critical (was: Major)
> Stop using deprecated methods from TableSource interface
>
Kurt Young created FLINK-15896:
--
Summary: Stop using TableSource::getTableSchema
Key: FLINK-15896
URL: https://issues.apache.org/jira/browse/FLINK-15896
Project: Flink
Issue Type: Sub-task
Kurt Young created FLINK-15895:
--
Summary: Stop using TableSource::getReturnType except for
compatibility purpose
Key: FLINK-15895
URL: https://issues.apache.org/jira/browse/FLINK-15895
Project: Flink
Kurt Young created FLINK-15894:
--
Summary: Stop overriding TableSource::getTableSchema in flink
walkthrough
Key: FLINK-15894
URL: https://issues.apache.org/jira/browse/FLINK-15894
Project: Flink
Kurt Young created FLINK-15893:
--
Summary: Stop overriding TableSource::getTableSchema in python
table source
Key: FLINK-15893
URL: https://issues.apache.org/jira/browse/FLINK-15893
Project: Flink
Kurt Young created FLINK-15892:
--
Summary: Stop overriding TableSource::getTableSchema in csv table
source
Key: FLINK-15892
URL: https://issues.apache.org/jira/browse/FLINK-15892
Project: Flink
Kurt Young created FLINK-15890:
--
Summary: Stop overriding TableSource::getTableSchema in orc table
source
Key: FLINK-15890
URL: https://issues.apache.org/jira/browse/FLINK-15890
Project: Flink
Kurt Young created FLINK-15891:
--
Summary: Stop overriding TableSource::getTableSchema in parquet
table source
Key: FLINK-15891
URL: https://issues.apache.org/jira/browse/FLINK-15891
Project: Flink
Kurt Young created FLINK-15889:
--
Summary: Stop overriding TableSource::getTableSchema in jdbc
connector
Key: FLINK-15889
URL: https://issues.apache.org/jira/browse/FLINK-15889
Project: Flink
Kurt Young created FLINK-15888:
--
Summary: Stop overriding TableSource::getTableSchema in hbase
Key: FLINK-15888
URL: https://issues.apache.org/jira/browse/FLINK-15888
Project: Flink
Issue Type:
Kurt Young created FLINK-15887:
--
Summary: Stop overriding TableSource::getTableSchema in kafka
Key: FLINK-15887
URL: https://issues.apache.org/jira/browse/FLINK-15887
Project: Flink
Issue Type:
Kurt Young created FLINK-15886:
--
Summary: Stop overriding TableSource::getTableSchema in hive table
source
Key: FLINK-15886
URL: https://issues.apache.org/jira/browse/FLINK-15886
Project: Flink
Kurt Young created FLINK-15885:
--
Summary: Stop overriding TableSource::getTableSchema in tests
Key: FLINK-15885
URL: https://issues.apache.org/jira/browse/FLINK-15885
Project: Flink
Issue Type:
Kurt Young created FLINK-15884:
--
Summary: Stop overriding TableSource::getReturnType in python
table source
Key: FLINK-15884
URL: https://issues.apache.org/jira/browse/FLINK-15884
Project: Flink
Kurt Young created FLINK-15883:
--
Summary: Stop overriding TableSource::getReturnType in parquet
table source
Key: FLINK-15883
URL: https://issues.apache.org/jira/browse/FLINK-15883
Project: Flink
Kurt Young created FLINK-15882:
--
Summary: Stop overriding TableSource::getReturnType in orc table
source
Key: FLINK-15882
URL: https://issues.apache.org/jira/browse/FLINK-15882
Project: Flink
Kurt Young created FLINK-15881:
--
Summary: Stop overriding TableSource::getReturnType in jdbc
connector
Key: FLINK-15881
URL: https://issues.apache.org/jira/browse/FLINK-15881
Project: Flink
Kurt Young created FLINK-15879:
--
Summary: Stop overriding TableSource::getReturnType in kafka
connector
Key: FLINK-15879
URL: https://issues.apache.org/jira/browse/FLINK-15879
Project: Flink
Kurt Young created FLINK-15880:
--
Summary: Stop overriding TableSource::getReturnType in hbase
connector
Key: FLINK-15880
URL: https://issues.apache.org/jira/browse/FLINK-15880
Project: Flink
Kurt Young created FLINK-15878:
--
Summary: Stop overriding TableSource::getReturnType in tests
Key: FLINK-15878
URL: https://issues.apache.org/jira/browse/FLINK-15878
Project: Flink
Issue Type:
Kurt Young created FLINK-15877:
--
Summary: Stop using deprecated methods from TableSource interface
Key: FLINK-15877
URL: https://issues.apache.org/jira/browse/FLINK-15877
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-15577.
--
Fix Version/s: 1.10.0
1.9.2
Resolution: Fixed
1.9.2:
[
https://issues.apache.org/jira/browse/FLINK-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018753#comment-17018753
]
Kurt Young commented on FLINK-15625:
Since 1.10.0 is about to release, we can't include such
[
https://issues.apache.org/jira/browse/FLINK-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15625:
---
Fix Version/s: (was: 1.10.0)
1.11.0
> flink sql multiple statements syntatic
[
https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15579:
--
Assignee: Shu Li Zheng
> Can not use jdbc connector on Blink batch mode
>
[
https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014930#comment-17014930
]
Kurt Young commented on FLINK-15579:
Sounds good to me, assigning to you [~eric.zheng].
> Can not
[
https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15577:
--
Assignee: Benoit Hanotte
> WindowAggregate RelNodes missing Window specs in digest
>
[
https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014876#comment-17014876
]
Kurt Young commented on FLINK-15577:
[~b.hanotte] Thanks for the fix, looks like blink planner also
[
https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014875#comment-17014875
]
Kurt Young commented on FLINK-15579:
So you want to use JDBC as a batch sink?
> Can not use jdbc
[
https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15579:
---
Issue Type: Improvement (was: Bug)
> Can not use jdbc connector on Blink batch mode
>
[
https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15579:
---
Component/s: Table SQL / Planner
> Can not use jdbc connector on Blink batch mode
>
[
https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014779#comment-17014779
]
Kurt Young commented on FLINK-15577:
[~b.hanotte] Thanks for the nice investigation, would you also
[
https://issues.apache.org/jira/browse/FLINK-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014325#comment-17014325
]
Kurt Young commented on FLINK-15563:
[~sujun1020] Before we fixing this bug, you could also try out
[
https://issues.apache.org/jira/browse/FLINK-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15563:
---
Component/s: (was: Connectors / FileSystem)
Table SQL / Legacy Planner
> When
[
https://issues.apache.org/jira/browse/FLINK-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014324#comment-17014324
]
Kurt Young commented on FLINK-15563:
Thanks [~godfreyhe]
> When using ParquetTableSource, The
[
https://issues.apache.org/jira/browse/FLINK-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15563:
--
Assignee: godfrey he
> When using ParquetTableSource, The program hangs until OOM
>
[
https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014190#comment-17014190
]
Kurt Young commented on FLINK-15570:
This is duplicated with FLINK-15066?
> Support inserting into
[
https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15565:
--
Assignee: Jingsong Lee
> Incompatible types of expression and result type thrown in codegen
[
https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014186#comment-17014186
]
Kurt Young commented on FLINK-15565:
[~lzljs3620320] I've assigned to you.
> Incompatible types of
[
https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014056#comment-17014056
]
Kurt Young commented on FLINK-15565:
cc [~lzljs3620320]
> sql planner Incompatible
>
[
https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15565:
---
Summary: Incompatible types of expression and result type thrown in codegen
(was: sql planner
[
https://issues.apache.org/jira/browse/FLINK-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013990#comment-17013990
]
Kurt Young commented on FLINK-15563:
cc [~godfreyhe]
> When using ParquetTableSource, The program
[
https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013989#comment-17013989
]
Kurt Young commented on FLINK-15527:
IIRC yarn session mode is just a standalone cluster but
[
https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013963#comment-17013963
]
Kurt Young commented on FLINK-15527:
[~chenchencc] can you use yarn session mode to achieve what you
[
https://issues.apache.org/jira/browse/FLINK-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011766#comment-17011766
]
Kurt Young commented on FLINK-15538:
Why it's more efficient? Won't it cause lots of virtual
[
https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-15466.
--
Resolution: Fixed
master: 6f2e9abffb0b1ef68e4f2cf058a24524b61e88a1
1.10.0:
[
https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15466:
---
Affects Version/s: (was: 1.9.0)
> `FlinkAggregateExpandDistinctAggregatesRule` generates wrong
[
https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011474#comment-17011474
]
Kurt Young commented on FLINK-15527:
According to your log:
2020-01-09 14:05:03,775 INFO
[
https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15527:
---
Attachment: image-2020-01-09-14-30-46-973.png
> can not control the number of container on yarn
[
https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011453#comment-17011453
]
Kurt Young commented on FLINK-15527:
Hi, have you start the job successfully? Could you check what's
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011442#comment-17011442
]
Kurt Young commented on FLINK-15509:
If source and sink have different properties, I think verifying
[
https://issues.apache.org/jira/browse/FLINK-15511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011404#comment-17011404
]
Kurt Young commented on FLINK-15511:
Why the first and second job went through different code paths?
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011403#comment-17011403
]
Kurt Young commented on FLINK-15509:
But you don't know where this table would be used, whether it
[
https://issues.apache.org/jira/browse/FLINK-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011337#comment-17011337
]
Kurt Young commented on FLINK-14875:
How much effort needed for fixing this? Can we make it in time
[
https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15466:
--
Assignee: Shuo Cheng
> `FlinkAggregateExpandDistinctAggregatesRule` generates wrong plan for
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15509:
---
Fix Version/s: 1.11.0
> Use sql cilents create view occur Unexpected exception
>
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15509:
---
Issue Type: Improvement (was: Bug)
> Use sql cilents create view occur Unexpected exception
>
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15509:
---
Affects Version/s: 1.10.0
> Use sql cilents create view occur Unexpected exception
>
[
https://issues.apache.org/jira/browse/FLINK-15511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010441#comment-17010441
]
Kurt Young commented on FLINK-15511:
cc [~lirui]
> export org.apache.flink.table.api.TableException
[
https://issues.apache.org/jira/browse/FLINK-15511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010436#comment-17010436
]
Kurt Young commented on FLINK-15511:
Hi, please use English to record this issue.
> flink 1.10
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010430#comment-17010430
]
Kurt Young commented on FLINK-15509:
A single "create table" statement shouldn't verify any source &
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010356#comment-17010356
]
Kurt Young commented on FLINK-15509:
[~lzljs3620320] It lacked the basic information that both
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010341#comment-17010341
]
Kurt Young commented on FLINK-15509:
[~docete] Maybe we should fail the "create table" statement
[
https://issues.apache.org/jira/browse/FLINK-15485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-15485:
--
Assignee: Leonard Xu
> Reopen tests when blocking issue has been resolved
>
[
https://issues.apache.org/jira/browse/FLINK-15485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009707#comment-17009707
]
Kurt Young commented on FLINK-15485:
Nice cleanup!
> Reopen tests when blocking issue has been
[
https://issues.apache.org/jira/browse/FLINK-15498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009589#comment-17009589
]
Kurt Young edited comment on FLINK-15498 at 1/7/20 10:19 AM:
-
Reusing an e2e
[
https://issues.apache.org/jira/browse/FLINK-15498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009589#comment-17009589
]
Kurt Young commented on FLINK-15498:
Reusing a e2e test sounds really fragile to me. We might modify
[
https://issues.apache.org/jira/browse/FLINK-15498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009587#comment-17009587
]
Kurt Young commented on FLINK-15498:
We could also open source a flink-sql-benchmark project?
>
[
https://issues.apache.org/jira/browse/FLINK-15498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009490#comment-17009490
]
Kurt Young commented on FLINK-15498:
I'm not 100% sure about this, how can our end-to-end test cases
[
https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15497:
---
Component/s: Table SQL / Runtime
> Streaming TopN operator doesn't reduce outputs when rank number
[
https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15497:
---
Fix Version/s: 1.10.0
1.9.2
> Streaming TopN operator doesn't reduce outputs
[
https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009400#comment-17009400
]
Kurt Young commented on FLINK-15497:
cc [~jark] [~jinyu.zj]
> Streaming TopN operator doesn't
[
https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15497:
---
Affects Version/s: 1.9.1
> Streaming TopN operator doesn't reduce outputs when rank number is not
[
https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15497:
---
Description:
As we described in the doc:
[
https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15497:
---
Summary: Streaming TopN operator doesn't reduce outputs when rank number is
not required (was:
Kurt Young created FLINK-15497:
--
Summary: Topn
Key: FLINK-15497
URL: https://issues.apache.org/jira/browse/FLINK-15497
Project: Flink
Issue Type: Bug
Reporter: Kurt Young
--
[
https://issues.apache.org/jira/browse/FLINK-15494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15494:
---
Fix Version/s: 1.10.0
1.9.2
> time field index wrong in
[
https://issues.apache.org/jira/browse/FLINK-11964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-11964:
--
Assignee: Jingsong Lee
> Avoid hash collision of partition and bucket in HybridHashTable in
[
https://issues.apache.org/jira/browse/FLINK-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15379:
---
Fix Version/s: (was: 1.10.0)
> JDBC connector return wrong value if defined dataType contains
[
https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-15231:
---
Component/s: (was: Table SQL / Planner)
Table SQL / Runtime
> Wrong HeapVector
701 - 800 of 1931 matches
Mail list logo
