[jira] [Closed] (FLINK-14446) Design a Java end to end test framework for supporting more external system

2019-10-18 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14446. -- Resolution: Duplicate > Design a Java end to end test framework for supporting more external system >

[jira] [Closed] (FLINK-12399) FilterableTableSource does not use filters on job run

2019-10-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12399. -- Fix Version/s: 1.10.0 Resolution: Fixed merged to 1.10: 

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

2019-10-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953685#comment-16953685 ] Kurt Young commented on FLINK-11491: You can also further merge 1 and 2 into 2. > Support all

[jira] [Assigned] (FLINK-13867) Write file only once when doing blocking broadcast shuffle

2019-10-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13867: -- Assignee: Yun Gao > Write file only once when doing blocking broadcast shuffle >

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

2019-10-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953478#comment-16953478 ] Kurt Young commented on FLINK-11491: I think sub-task-4 is unnecessary. For sub-task-3, it's better

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

2019-10-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945356#comment-16945356 ] Kurt Young commented on FLINK-11935: I'm removing this issue from the sub-tasks of upgrading calcite

[jira] [Updated] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

2019-10-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11935: --- Parent: (was: FLINK-13656) Issue Type: Improvement (was: Sub-task) > Remove

[jira] [Comment Edited] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

2019-10-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945353#comment-16945353 ] Kurt Young edited comment on FLINK-11936 at 10/6/19 1:34 PM: - I'm removing

[jira] [Updated] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

2019-10-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11936: --- Parent: (was: FLINK-13656) Issue Type: Improvement (was: Sub-task) > Remove

[jira] [Commented] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

2019-10-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945353#comment-16945353 ] Kurt Young commented on FLINK-11936: I'm removing this issue from the sub-tasks of upgrading calcite

[jira] [Closed] (FLINK-13657) Remove FlinkJoinToMultiJoinRule pull-in from Calcite

2019-10-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13657. -- Fix Version/s: 1.10.0 Resolution: Fixed merged in 1.10: 

[jira] [Assigned] (FLINK-13657) Remove FlinkJoinToMultiJoinRule pull-in from Calcite

2019-10-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13657: -- Assignee: Danny Chen > Remove FlinkJoinToMultiJoinRule pull-in from Calcite >

[jira] [Commented] (FLINK-13656) Upgrade Calcite dependency to 1.21

2019-10-04 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944978#comment-16944978 ] Kurt Young commented on FLINK-13656: [~twalthr] Sorry, didn't notice this. I will double check the

[jira] [Commented] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-09-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940624#comment-16940624 ] Kurt Young commented on FLINK-14243: The cache you mentioned is a normal class fields, and AFAIK

[jira] [Commented] (FLINK-14243) flink hiveudf need some check whether it is using cache

2019-09-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940614#comment-16940614 ] Kurt Young commented on FLINK-14243: What do you mean by using cache? > flink hiveudf need some

[jira] [Commented] (FLINK-14274) RuntimeContext can be get from FunctionContext

2019-09-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940589#comment-16940589 ] Kurt Young commented on FLINK-14274: [~hailong wang] Once RuntimeContext exposed to user, the

[jira] [Closed] (FLINK-14274) RuntimeContext can be get from FunctionContext

2019-09-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14274. -- Resolution: Won't Fix > RuntimeContext can be get from FunctionContext >

[jira] [Commented] (FLINK-14274) RuntimeContext can be get from FunctionContext

2019-09-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940312#comment-16940312 ] Kurt Young commented on FLINK-14274: I think this is by-design, we didn't allow UDF to use state. >

[jira] [Assigned] (FLINK-13656) Upgrade Calcite dependency to 1.21

2019-09-28 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13656: -- Assignee: Danny Chen > Upgrade Calcite dependency to 1.21 >

[jira] [Closed] (FLINK-13656) Upgrade Calcite dependency to 1.21

2019-09-28 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13656. -- Fix Version/s: 1.10.0 Resolution: Fixed > Upgrade Calcite dependency to 1.21 >

[jira] [Assigned] (FLINK-11491) Support all TPC-DS queries

2019-09-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-11491: -- Assignee: Leonard Xu (was: Kurt Young) > Support all TPC-DS queries >

[jira] [Updated] (FLINK-11491) Support all TPC-DS queries

2019-09-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11491: --- Component/s: Table SQL / Planner > Support all TPC-DS queries > -- > >

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

2019-09-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939092#comment-16939092 ] Kurt Young commented on FLINK-11491: Sure and thanks [~Leonard Xu] > Support all TPC-DS queries >

[jira] [Updated] (FLINK-11493) Finalize the Blink SQL merging efforts

2019-09-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11493: --- Fix Version/s: 1.10.0 > Finalize the Blink SQL merging efforts >

[jira] [Updated] (FLINK-11492) Support the full Blink SQL runtime

2019-09-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11492: --- Fix Version/s: 1.10.0 > Support the full Blink SQL runtime > -- > >

[jira] [Updated] (FLINK-11491) Support all TPC-DS queries

2019-09-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11491: --- Fix Version/s: 1.10.0 > Support all TPC-DS queries > -- > >

[jira] [Updated] (FLINK-11490) Add an initial Blink SQL batch runtime

2019-09-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11490: --- Fix Version/s: 1.9.0 > Add an initial Blink SQL batch runtime >

[jira] [Updated] (FLINK-14031) flink-examples-table should add the blink planner dependency

2019-09-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14031: --- Priority: Minor (was: Major) > flink-examples-table should add the blink planner dependency >

[jira] [Updated] (FLINK-14031) flink-examples-table should add the blink planner dependency

2019-09-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14031: --- Issue Type: Improvement (was: Bug) > flink-examples-table should add the blink planner dependency

[jira] [Closed] (FLINK-14031) flink-examples-table should add the blink planner dependency

2019-09-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14031. -- Fix Version/s: 1.10.0 Resolution: Fixed merged in 1.10: 

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-09-18 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932262#comment-16932262 ] Kurt Young commented on FLINK-14118: If this is true, I would suggest we should cherry pick this to

[jira] [Commented] (FLINK-13656) Upgrade Calcite dependency to 1.21

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932076#comment-16932076 ] Kurt Young commented on FLINK-13656: [~danny0405] Would you like to take this issue? > Upgrade

[jira] [Commented] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932074#comment-16932074 ] Kurt Young commented on FLINK-14092: I think we should stick to FLINK-13656, I will close this one.

[jira] [Closed] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14092. -- Resolution: Duplicate > Upgrade Calcite version to 1.21 for Flink SQL >

[jira] [Assigned] (FLINK-14100) Introduce OracleDialect

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14100: -- Assignee: Canbin Zheng > Introduce OracleDialect > --- > >

[jira] [Assigned] (FLINK-14102) Introduce DB2Dialect

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14102: -- Assignee: Canbin Zheng > Introduce DB2Dialect > > >

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931993#comment-16931993 ] Kurt Young commented on FLINK-14078: Thanks [~felixzheng], I will assign these jiras to you. >

[jira] [Assigned] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14078: -- Assignee: Canbin Zheng > Introduce more JDBCDialect implementations >

[jira] [Assigned] (FLINK-14101) Introduce SqlServerDialect

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14101: -- Assignee: Canbin Zheng > Introduce SqlServerDialect > -- > >

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931960#comment-16931960 ] Kurt Young commented on FLINK-14078: I think split into some subtasks is a good idea. Even if there

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

2019-09-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931944#comment-16931944 ] Kurt Young commented on FLINK-14078: Just want to clarify, does this only take effect to JDBC

[jira] [Assigned] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

2019-09-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14092: -- Assignee: (was: Daniel Schwager) > Upgrade Calcite version to 1.21 for Flink SQL >

[jira] [Assigned] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

2019-09-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14092: -- Assignee: Daniel Schwager > Upgrade Calcite version to 1.21 for Flink SQL >

[jira] [Assigned] (FLINK-14031) flink-examples-table should add the blink planner dependency

2019-09-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14031: -- Assignee: Jimmy Wong > flink-examples-table should add the blink planner dependency >

[jira] [Commented] (FLINK-14031) flink-examples-table should add the blink planner dependency

2019-09-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930197#comment-16930197 ] Kurt Young commented on FLINK-14031: I will assign this to you [~GatsbyNewton] >

[jira] [Assigned] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-12061: -- Assignee: Leonard Xu (was: leesf) > Add more window operator contract tests to table

[jira] [Issue Comment Deleted] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-12061: --- Comment: was deleted (was: Thanks [~Leonard Xu], I will assign this to you.) > Add more window

[jira] [Commented] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928152#comment-16928152 ] Kurt Young commented on FLINK-12061: Thanks [~Leonard Xu], I will assign this to you. > Add more

[jira] [Commented] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928153#comment-16928153 ] Kurt Young commented on FLINK-12061: Hi [~xleesf] , are you still planing to work on this issue? >

[jira] [Assigned] (FLINK-12506) Add more over window unit tests

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-12506: -- Assignee: Leonard Xu > Add more over window unit tests > --- > >

[jira] [Commented] (FLINK-12506) Add more over window unit tests

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928151#comment-16928151 ] Kurt Young commented on FLINK-12506: Thanks [~Leonard Xu], I will assign this to you. > Add more

[jira] [Updated] (FLINK-14031) flink-examples-table should add the blink planner dependency

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14031: --- Fix Version/s: (was: 1.9.0) > flink-examples-table should add the blink planner dependency >

[jira] [Updated] (FLINK-12749) Getting Started - Docker Playgrounds - Flink Cluster Playground

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-12749: --- Fix Version/s: 1.9.1 1.8.2 > Getting Started - Docker Playgrounds - Flink

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13488: --- Fix Version/s: (was: 1.8.2) > flink-python fails to build on Travis due to

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13488: --- Fix Version/s: 1.8.2 > flink-python fails to build on Travis due to PackagesNotFoundError >

[jira] [Commented] (FLINK-13499) Remove dependency on MapR artifact repository

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16926280#comment-16926280 ] Kurt Young commented on FLINK-13499: also in 1.8: 80452f19e1712fd09d3b6b9a99c82d954f471a88 > Remove

[jira] [Updated] (FLINK-13499) Remove dependency on MapR artifact repository

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13499: --- Fix Version/s: 1.8.2 > Remove dependency on MapR artifact repository >

[jira] [Updated] (FLINK-9526) BucketingSink end-to-end test failed on Travis

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-9526: -- Fix Version/s: 1.8.2 > BucketingSink end-to-end test failed on Travis >

[jira] [Updated] (FLINK-14031) flink-examples-table should add the blink dependency

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14031: --- Fix Version/s: (was: 1.9.0) > flink-examples-table should add the blink dependency >

[jira] [Commented] (FLINK-12501) AvroTypeSerializer does not work with types generated by avrohugger

2019-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925549#comment-16925549 ] Kurt Young commented on FLINK-12501: Should we also fix it in 1.9 branch? > AvroTypeSerializer does

[jira] [Closed] (FLINK-13591) 'Completed Job List' in Flink web doesn't display right when job name is very long

2019-09-05 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13591. -- Resolution: Fixed merged in master: 60cf41ab6b9309979849e3310b4c32cf528a1568 > 'Completed Job List'

[jira] [Commented] (FLINK-12399) FilterableTableSource does not use filters on job run

2019-09-03 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921808#comment-16921808 ] Kurt Young commented on FLINK-12399: Hi [~walterddr], sorry for the delay, I will take a look at

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List

2019-09-03 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921318#comment-16921318 ] Kurt Young commented on FLINK-13943: Yes, I actually received such requirement from internal machine

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List

2019-09-03 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921288#comment-16921288 ] Kurt Young commented on FLINK-13943: One possible solution is we can return a Iterator for such API. 

[jira] [Comment Edited] (FLINK-13943) Provide api to convert flink table to java List

2019-09-03 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921288#comment-16921288 ] Kurt Young edited comment on FLINK-13943 at 9/3/19 9:32 AM: One possible

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List

2019-09-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1692#comment-1692 ] Kurt Young commented on FLINK-13943: cc [~twalthr] > Provide api to convert flink table to java

[jira] [Commented] (FLINK-13867) Write file only once when doing blocking broadcast shuffle

2019-08-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916407#comment-16916407 ] Kurt Young commented on FLINK-13867: This is similar with FLINK-10995 but is actually different >

[jira] [Created] (FLINK-13867) Write file only once when doing blocking broadcast shuffle

2019-08-27 Thread Kurt Young (Jira)
Kurt Young created FLINK-13867: -- Summary: Write file only once when doing blocking broadcast shuffle Key: FLINK-13867 URL: https://issues.apache.org/jira/browse/FLINK-13867 Project: Flink Issue

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13488: --- Fix Version/s: (was: 1.9.1) (was: 1.10.0) 1.9.0 >

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916399#comment-16916399 ] Kurt Young commented on FLINK-13488: Yeah, you're right. I will revert the change, thanks. >

[jira] [Updated] (FLINK-13359) Add documentation for DDL introduction

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13359: --- Fix Version/s: 1.10.0 > Add documentation for DDL introduction >

[jira] [Updated] (FLINK-13362) Add documentation for Kafka & ES & FileSystem DDL

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13362: --- Fix Version/s: 1.10.0 > Add documentation for Kafka & ES & FileSystem DDL >

[jira] [Updated] (FLINK-13105) Add documentation for blink planner's built-in functions

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13105: --- Fix Version/s: 1.10.0 > Add documentation for blink planner's built-in functions >

[jira] [Updated] (FLINK-13354) Add documentation for how to use blink planner

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13354: --- Fix Version/s: 1.10.0 > Add documentation for how to use blink planner >

[jira] [Updated] (FLINK-13564) blink planner should also throw exception if constant with YEAR TO MONTH resolution was used for group windows

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13564: --- Fix Version/s: 1.10.0 > blink planner should also throw exception if constant with YEAR TO MONTH >

[jira] [Commented] (FLINK-13599) Kinesis end-to-end test failed on Travis

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916349#comment-16916349 ] Kurt Young commented on FLINK-13599: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13599) Kinesis end-to-end test failed on Travis

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13599: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Kinesis end-to-end test failed on Travis

[jira] [Commented] (FLINK-13277) add documentation of Hive source/sink

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916347#comment-16916347 ] Kurt Young commented on FLINK-13277: Looks like this issue already merged, [~phoenixjiangnan] could

[jira] [Updated] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13738: --- Fix Version/s: 1.10.0 > NegativeArraySizeException in LongHybridHashTable >

[jira] [Updated] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13739: --- Fix Version/s: 1.10.0 > BinaryRowTest.testWriteString() fails in some environments >

[jira] [Updated] (FLINK-13742) Fix code generation when aggregation contains both distinct aggregate with and without filter

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13742: --- Fix Version/s: 1.10.0 > Fix code generation when aggregation contains both distinct aggregate with

[jira] [Updated] (FLINK-13277) add documentation of Hive source/sink

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13277: --- Fix Version/s: 1.10.0 > add documentation of Hive source/sink >

[jira] [Commented] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916346#comment-16916346 ] Kurt Young commented on FLINK-13737: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13737: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > flink-dist

[jira] [Commented] (FLINK-13688) HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with 1.9.0-rc2

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916344#comment-16916344 ] Kurt Young commented on FLINK-13688: [~till.rohrmann] Thanks for the heads up, this was planned. I'm

[jira] [Commented] (FLINK-13706) add documentation of how to use Hive functions in Flink

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916339#comment-16916339 ] Kurt Young commented on FLINK-13706: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13706) add documentation of how to use Hive functions in Flink

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13706: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > add

[jira] [Updated] (FLINK-13501) Fixes a few issues in documentation for Hive integration

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13501: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > Fixes a few

[jira] [Commented] (FLINK-13415) Document how to use hive connector in scala shell

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916338#comment-16916338 ] Kurt Young commented on FLINK-13415: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13415) Document how to use hive connector in scala shell

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13415: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > Document how

[jira] [Commented] (FLINK-13501) Fixes a few issues in documentation for Hive integration

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916337#comment-16916337 ] Kurt Young commented on FLINK-13501: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13534: --- Fix Version/s: 1.10.0 > Unable to query Hive table with decimal column >

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916336#comment-16916336 ] Kurt Young commented on FLINK-13488: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13488: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > flink-python

[jira] [Updated] (FLINK-13517) Restructure Hive Catalog documentation

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13517: --- Fix Version/s: 1.10.0 > Restructure Hive Catalog documentation >

[jira] [Updated] (FLINK-13490) Fix return null in JDBCUtils::getFieldFromResultSet

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13490: --- Fix Version/s: 1.10.0 > Fix return null in JDBCUtils::getFieldFromResultSet >

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13526: --- Fix Version/s: 1.10.0 > Switching to a non existing catalog or database crashes sql-client >

[jira] [Updated] (FLINK-13563) TumblingGroupWindow should implement toString method

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13563: --- Fix Version/s: 1.10.0 > TumblingGroupWindow should implement toString method >

[jira] [Updated] (FLINK-13562) throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13562: --- Fix Version/s: 1.10.0 > throws exception when FlinkRelMdColumnInterval meets two stage stream group

[jira] [Updated] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

2019-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13637: --- Fix Version/s: 1.10.0 > Anchors not working in document(building.md, common.md, queryable_state.md)

  1   2   3   4   5   6   7   8   >