[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120902#comment-17120902 ] Kurt Young commented on FLINK-17918: cc [~jark]    > Blink Jobs are loosing data on recovery >

[jira] [Updated] (FLINK-15390) List/Map/Struct types support for vectorized orc reader

[ https://issues.apache.org/jira/browse/FLINK-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15390: --- Fix Version/s: (was: 1.11.0) > List/Map/Struct types support for vectorized orc reader >

[jira] [Updated] (FLINK-15526) Add RollingPolicy to PartitionWriters

[ https://issues.apache.org/jira/browse/FLINK-15526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15526: --- Fix Version/s: (was: 1.11.0) > Add RollingPolicy to PartitionWriters >

[jira] [Updated] (FLINK-15853) Use the new type inference for hive udf

[ https://issues.apache.org/jira/browse/FLINK-15853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15853: --- Fix Version/s: (was: 1.11.0) > Use the new type inference for hive udf >

[jira] [Updated] (FLINK-15855) Use the new type inference for hive udaf

[ https://issues.apache.org/jira/browse/FLINK-15855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15855: --- Fix Version/s: (was: 1.11.0) > Use the new type inference for hive udaf >

[jira] [Updated] (FLINK-15854) Use the new type inference for hive udtf

[ https://issues.apache.org/jira/browse/FLINK-15854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15854: --- Fix Version/s: (was: 1.11.0) > Use the new type inference for hive udtf >

[jira] [Updated] (FLINK-16903) Add sink.parallelism for file system factory

[ https://issues.apache.org/jira/browse/FLINK-16903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16903: --- Fix Version/s: (was: 1.11.0) > Add sink.parallelism for file system factory >

[jira] [Updated] (FLINK-16904) Migrate FileSystem descriptor to new table factory

[ https://issues.apache.org/jira/browse/FLINK-16904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16904: --- Fix Version/s: (was: 1.11.0) > Migrate FileSystem descriptor to new table factory >

[jira] [Assigned] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17553: -- Assignee: Terry Wang > Constant exists in group window key leads to error: Unsupported

[jira] [Assigned] (FLINK-17937) Change some hive connector tests to IT cases

[ https://issues.apache.org/jira/browse/FLINK-17937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17937: -- Assignee: Rui Li > Change some hive connector tests to IT cases >

[jira] [Assigned] (FLINK-17944) Wrong output in sql client's table mode

[ https://issues.apache.org/jira/browse/FLINK-17944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17944: -- Assignee: Jeff Zhang > Wrong output in sql client's table mode >

[jira] [Assigned] (FLINK-17113) Refactor view support in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17113: -- Assignee: Danny Chen > Refactor view support in SQL Client >

[jira] [Updated] (FLINK-18003) Table hints support multi Options

[ https://issues.apache.org/jira/browse/FLINK-18003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18003: --- Fix Version/s: (was: 1.11.0) > Table hints support multi Options >

[jira] [Updated] (FLINK-16709) add a set command to set job name when submit job on sql client

[ https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16709: --- Fix Version/s: (was: 1.11.0) > add a set command to set job name when submit job on sql client

[jira] [Updated] (FLINK-16731) Support show partitions table command in sql client

[ https://issues.apache.org/jira/browse/FLINK-16731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16731: --- Fix Version/s: (was: 1.11.0) > Support show partitions table command in sql client >

[jira] [Updated] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

[ https://issues.apache.org/jira/browse/FLINK-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16698: --- Fix Version/s: (was: 1.11.0) > fllink need catalog listener to do such as preCreate/PreDrop* >

[jira] [Updated] (FLINK-16824) Creating Temporal Table Function via DDL

[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16824: --- Fix Version/s: 1.12.0 > Creating Temporal Table Function via DDL >

[jira] [Updated] (FLINK-16824) Creating Temporal Table Function via DDL

[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16824: --- Fix Version/s: (was: 1.11.0) > Creating Temporal Table Function via DDL >

[jira] [Commented] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117717#comment-17117717 ] Kurt Young commented on FLINK-17600: [~jark] could you check whether this issue still exist? If not,

[jira] [Commented] (FLINK-17617) Flink SQL CLI Autocomplete does not return correct hints

[ https://issues.apache.org/jira/browse/FLINK-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117716#comment-17117716 ] Kurt Young commented on FLINK-17617: I noticed the PR has been merged, should we also close this

[jira] [Updated] (FLINK-17943) HiveFunctionWrapper#getUDFClass should use Thread.currentThread().getContextClassLoader()

[ https://issues.apache.org/jira/browse/FLINK-17943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17943: --- Affects Version/s: (was: 1.11.0) 1.10.1 >

[jira] [Updated] (FLINK-17931) Document fromValues clause

[ https://issues.apache.org/jira/browse/FLINK-17931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17931: --- Fix Version/s: 1.11.0 > Document fromValues clause > -- > >

[jira] [Updated] (FLINK-17943) HiveFunctionWrapper#getUDFClass should use Thread.currentThread().getContextClassLoader()

[ https://issues.apache.org/jira/browse/FLINK-17943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17943: --- Fix Version/s: 1.11.0 > HiveFunctionWrapper#getUDFClass should use >

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115970#comment-17115970 ] Kurt Young commented on FLINK-16636: +1 to close this for now and reopen this after it shows again.

[jira] [Closed] (FLINK-17864) Update document about removing #registerTableSource

[ https://issues.apache.org/jira/browse/FLINK-17864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17864. -- Resolution: Duplicate > Update document about removing #registerTableSource >

[jira] [Commented] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111971#comment-17111971 ] Kurt Young commented on FLINK-15066: why this is marked as won't fix? > Cannot run multiple `insert

[jira] [Reopened] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-15066: > Cannot run multiple `insert into csvTable values ()` >

[jira] [Commented] (FLINK-17756) Drop table/view shouldn't take effect on each other

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111970#comment-17111970 ] Kurt Young commented on FLINK-17756: assigned to you [~danny0405], thanks > Drop table/view

[jira] [Assigned] (FLINK-17756) Drop table/view shouldn't take effect on each other

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17756: -- Assignee: Danny Chen > Drop table/view shouldn't take effect on each other >

[jira] [Commented] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111700#comment-17111700 ] Kurt Young commented on FLINK-17817: cc [~TsReaper] > CollectResultFetcher fails with EOFException

[jira] [Assigned] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17806: -- Assignee: Caizhi Weng > CollectSinkFunctionTest.testCheckpointedFunction fails with

[jira] [Commented] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110976#comment-17110976 ] Kurt Young commented on FLINK-17806: cc [~TsReaper] >

[jira] [Comment Edited] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110976#comment-17110976 ] Kurt Young edited comment on FLINK-17806 at 5/19/20, 8:46 AM: -- cc

[jira] [Updated] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17806: --- Affects Version/s: (was: 1.12.0) 1.11.0 >

[jira] [Updated] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17806: --- Fix Version/s: 1.11.0 > CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50>

[jira] [Updated] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17806: --- Priority: Blocker (was: Major) > CollectSinkFunctionTest.testCheckpointedFunction fails with

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110707#comment-17110707 ] Kurt Young commented on FLINK-17793: I also agree that view and table are not very different from

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110068#comment-17110068 ] Kurt Young commented on FLINK-17793: +1, how about calling it `CatalogTableSchema` or something

[jira] [Closed] (FLINK-17715) Supports function DDLs in SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-17715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17715. -- Assignee: Danny Chen Resolution: Fixed master: 20c28ac77ecd6b8d11e38ed84c9a5c36317721f3 >

[jira] [Closed] (FLINK-17791) Combine collecting sink and iterator to support collecting query results under all execution and network environments

[ https://issues.apache.org/jira/browse/FLINK-17791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17791. -- Assignee: Caizhi Weng Resolution: Fixed master: cfeaedd9df677b90c8e31214ca7704eead4e6655 >

[jira] [Updated] (FLINK-17735) Add specialized collecting iterator

[ https://issues.apache.org/jira/browse/FLINK-17735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17735: --- Component/s: (was: Table SQL / Planner) API / DataStream > Add specialized

[jira] [Closed] (FLINK-17735) Add specialized collecting iterator

[ https://issues.apache.org/jira/browse/FLINK-17735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17735. -- Assignee: Caizhi Weng Resolution: Fixed master: 8650e409763a9b4eba92c77cc02ca22edc0230af > Add

[jira] [Updated] (FLINK-17735) Add specialized collecting iterator

[ https://issues.apache.org/jira/browse/FLINK-17735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17735: --- Summary: Add specialized collecting iterator (was: Add specialized collecting iterator to Blink

[jira] [Closed] (FLINK-17428) Support SupportsProjectionPushDown in planner

[ https://issues.apache.org/jira/browse/FLINK-17428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17428. -- Fix Version/s: 1.11.0 Resolution: Fixed master: 7c7137173a2b14f49c4f87b191ff26026af2a4d0 >

[jira] [Closed] (FLINK-17451) Implement view DDLs for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17451. -- Assignee: Rui Li Resolution: Fixed master: 81c37384e5c607cc8abd65b7db79fce78c925a62 >

[jira] [Closed] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17754. -- Assignee: Kurt Young Resolution: Fixed > Walkthrough Table Java nightly end-to-end test failed

[jira] [Commented] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109095#comment-17109095 ] Kurt Young commented on FLINK-17754: Yes, it's been fixed. We changed some API, these source codes

[jira] [Assigned] (FLINK-17756) Drop table/view shouldn't take effect on each other

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17756: -- Assignee: (was: Kurt Young) > Drop table/view shouldn't take effect on each other >

[jira] [Updated] (FLINK-17756) Drop table/view shouldn't take effect on each other

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17756: --- Summary: Drop table/view shouldn't take effect on each other (was: Drop table/view shouldn't take

[jira] [Created] (FLINK-17756) Drop table/view shouldn't take affect on each other

Kurt Young created FLINK-17756: -- Summary: Drop table/view shouldn't take affect on each other Key: FLINK-17756 URL: https://issues.apache.org/jira/browse/FLINK-17756 Project: Flink Issue Type:

[jira] [Closed] (FLINK-17734) Add specialized collecting sink function

[ https://issues.apache.org/jira/browse/FLINK-17734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17734. -- Assignee: Caizhi Weng Resolution: Fixed master: 7c6251ede2e164ce29749088a4cd0903f6a486aa > Add

[jira] [Closed] (FLINK-17450) Implement function & catalog DDLs for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17450. -- Assignee: Rui Li Resolution: Fixed master: 677867ab89549d33654b7fad69d8bc586febd848 >

[jira] [Closed] (FLINK-15896) Stop using TableSource::getTableSchema

[ https://issues.apache.org/jira/browse/FLINK-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15896. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15895) Stop using TableSource::getReturnType except for compatibility purpose

[ https://issues.apache.org/jira/browse/FLINK-15895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15895. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15877) Stop using deprecated methods from TableSource interface

[ https://issues.apache.org/jira/browse/FLINK-15877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15877. -- Fix Version/s: (was: 1.11.0) Resolution: Not A Problem This will be fixed by design after

[jira] [Closed] (FLINK-15892) Stop overriding TableSource::getTableSchema in csv table source

[ https://issues.apache.org/jira/browse/FLINK-15892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15892. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't

[jira] [Closed] (FLINK-15894) Stop overriding TableSource::getTableSchema in flink walkthrough

[ https://issues.apache.org/jira/browse/FLINK-15894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15894. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15893) Stop overriding TableSource::getTableSchema in python table source

[ https://issues.apache.org/jira/browse/FLINK-15893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15893. -- Fix Version/s: (was: 1.11.0) Resolution: Won't Fix This will be fixed by design after we

[jira] [Closed] (FLINK-15891) Stop overriding TableSource::getTableSchema in parquet table source

[ https://issues.apache.org/jira/browse/FLINK-15891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15891. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't

[jira] [Closed] (FLINK-15889) Stop overriding TableSource::getTableSchema in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-15889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15889. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Zhenghua Gao) Resolution: Won't

[jira] [Closed] (FLINK-15890) Stop overriding TableSource::getTableSchema in orc table source

[ https://issues.apache.org/jira/browse/FLINK-15890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15890. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't

[jira] [Closed] (FLINK-15886) Stop overriding TableSource::getTableSchema in hive table source

[ https://issues.apache.org/jira/browse/FLINK-15886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15886. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Rui Li) Resolution: Won't Fix

[jira] [Closed] (FLINK-15888) Stop overriding TableSource::getTableSchema in hbase

[ https://issues.apache.org/jira/browse/FLINK-15888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15888. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Leonard Xu) Resolution: Won't Fix

[jira] [Closed] (FLINK-15887) Stop overriding TableSource::getTableSchema in kafka

[ https://issues.apache.org/jira/browse/FLINK-15887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15887. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jark Wu) Resolution: Won't Fix

[jira] [Closed] (FLINK-15883) Stop overriding TableSource::getReturnType in parquet table source

[ https://issues.apache.org/jira/browse/FLINK-15883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15883. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Fixed

[jira] [Closed] (FLINK-15885) Stop overriding TableSource::getTableSchema in tests

[ https://issues.apache.org/jira/browse/FLINK-15885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15885. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15884) Stop overriding TableSource::getReturnType in python table source

[ https://issues.apache.org/jira/browse/FLINK-15884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15884. -- Fix Version/s: (was: 1.11.0) Resolution: Won't Fix This will be fixed by design after we

[jira] [Closed] (FLINK-15879) Stop overriding TableSource::getReturnType in kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15879. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jark Wu) Resolution: Won't Fix

[jira] [Closed] (FLINK-15880) Stop overriding TableSource::getReturnType in hbase connector

[ https://issues.apache.org/jira/browse/FLINK-15880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15880. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Leonard Xu) Resolution: Won't Fix

[jira] [Closed] (FLINK-15882) Stop overriding TableSource::getReturnType in orc table source

[ https://issues.apache.org/jira/browse/FLINK-15882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15882. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't

[jira] [Closed] (FLINK-15878) Stop overriding TableSource::getReturnType in tests

[ https://issues.apache.org/jira/browse/FLINK-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15878. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Updated] (FLINK-17749) Remove fromTableSource method from TableEnvironment

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

[jira] [Updated] (FLINK-17749) Remove fromTableSource method from TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17749: --- Fix Version/s: (was: 1.11.0) > Remove fromTableSource method from TableEnvironment >

[jira] [Assigned] (FLINK-17749) Remove fromTableSource method from TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17749: -- Assignee: (was: Kurt Young) > Remove fromTableSource method from TableEnvironment >

[jira] [Created] (FLINK-17749) Remove fromTableSource method from TableEnvironment

Kurt Young created FLINK-17749: -- Summary: Remove fromTableSource method from TableEnvironment Key: FLINK-17749 URL: https://issues.apache.org/jira/browse/FLINK-17749 Project: Flink Issue Type:

[jira] [Closed] (FLINK-17748) Remove registration of TableSource/TableSink in Table Env

[ https://issues.apache.org/jira/browse/FLINK-17748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17748. -- Resolution: Fixed master: 32b79d1cdbf3fd463048d5b98a0c4893dfd6ae28 > Remove registration of

[jira] [Created] (FLINK-17748) Remove registration of TableSource/TableSink in Table Env

Kurt Young created FLINK-17748: -- Summary: Remove registration of TableSource/TableSink in Table Env Key: FLINK-17748 URL: https://issues.apache.org/jira/browse/FLINK-17748 Project: Flink Issue

[jira] [Commented] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107796#comment-17107796 ] Kurt Young commented on FLINK-17693: I don't think "Because other places already used this then I

[jira] [Closed] (FLINK-17667) Implement INSERT for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17667. -- Assignee: Rui Li Resolution: Fixed master: 74b8bb565c9e43d2deeef9ce60e9b642a23e1c2a >

[jira] [Updated] (FLINK-17667) Implement INSERT for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17667: --- Fix Version/s: 1.11.0 > Implement INSERT for Hive dialect > - > >

[jira] [Commented] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107316#comment-17107316 ] Kurt Young commented on FLINK-17693: TypeInformation will cause some confuse for table users. It's

[jira] [Commented] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107299#comment-17107299 ] Kurt Young commented on FLINK-17693: isn't TypeSerializer enough? > Add createTypeInformation to

[jira] [Commented] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

[ https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106150#comment-17106150 ] Kurt Young commented on FLINK-17591: According to surefire's document [1], the tests will be

[jira] [Assigned] (FLINK-17028) Introduce a new HBase connector with new property keys

[ https://issues.apache.org/jira/browse/FLINK-17028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17028: -- Assignee: Jark Wu > Introduce a new HBase connector with new property keys >

[jira] [Closed] (FLINK-16364) Deprecate the methods in TableEnvironment proposed by FLIP-84

[ https://issues.apache.org/jira/browse/FLINK-16364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16364. -- Resolution: Fixed master: 5324b0c53d3ad73cea1f97e9861b7b7373d49f77 > Deprecate the methods in

[jira] [Created] (FLINK-17635) Add documentation about view support

Kurt Young created FLINK-17635: -- Summary: Add documentation about view support Key: FLINK-17635 URL: https://issues.apache.org/jira/browse/FLINK-17635 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-17112) Support DESCRIBE view_name in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17112. -- Resolution: Fixed master: c5c6b7612d0b5492ec4db8233709bf0a1093a1fe > Support DESCRIBE view_name in

[jira] [Updated] (FLINK-17624) "TPC-DS end-to-end test (Blink planner)" is unstable

[ https://issues.apache.org/jira/browse/FLINK-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17624: --- Component/s: (was: Table SQL / Planner) Runtime / Network > "TPC-DS end-to-end

[jira] [Closed] (FLINK-17252) supports SELECT statement in TableEnvironment#executeSql and Table#execute api

[ https://issues.apache.org/jira/browse/FLINK-17252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17252. -- Resolution: Fixed master: 2160c3294ef87143ab9a4e8138cb618651499792 > supports SELECT statement in

[jira] [Assigned] (FLINK-17615) flink batch job name doesn't show as defined in program

[ https://issues.apache.org/jira/browse/FLINK-17615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17615: -- Assignee: akisaya > flink batch job name doesn't show as defined in program >

[jira] [Commented] (FLINK-17615) flink batch job name doesn't show as defined in program

[ https://issues.apache.org/jira/browse/FLINK-17615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104400#comment-17104400 ] Kurt Young commented on FLINK-17615: Sure [~akisaya] > flink batch job name doesn't show as defined

[jira] [Closed] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

[ https://issues.apache.org/jira/browse/FLINK-17601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17601. -- Resolution: Fixed master: 51c7d61f3e7661f6aad331245ca94ecb82be3994 >

[jira] [Created] (FLINK-17599) Update documents due to FLIP-84

Kurt Young created FLINK-17599: -- Summary: Update documents due to FLIP-84 Key: FLINK-17599 URL: https://issues.apache.org/jira/browse/FLINK-17599 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-17252) supports SELECT statement in TableEnvironment#executeSql and Table#execute api

[ https://issues.apache.org/jira/browse/FLINK-17252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17252: -- Assignee: godfrey he > supports SELECT statement in TableEnvironment#executeSql and

[jira] [Assigned] (FLINK-16364) Deprecate the methods in TableEnvironment proposed by FLIP-84

[ https://issues.apache.org/jira/browse/FLINK-16364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16364: -- Assignee: godfrey he > Deprecate the methods in TableEnvironment proposed by FLIP-84 >

[jira] [Closed] (FLINK-16367) Introduce createStatementSet method in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16367. -- Assignee: godfrey he Resolution: Fixed master: 55d04d59825cb1a365cf2940930f15c176a81988 >

[jira] [Closed] (FLINK-17267) supports EXPLAIN statement in TableEnvironment#executeSql and Table#explain api

[ https://issues.apache.org/jira/browse/FLINK-17267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17267. -- Assignee: godfrey he Resolution: Fixed master: 59ca355f05b668f1cb41cae02ce182ccc7c4d707 ~ 

[jira] [Closed] (FLINK-17251) supports INSERT statement in TableEnvironment#executeSql and Table#executeInsert api

[ https://issues.apache.org/jira/browse/FLINK-17251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17251. -- Resolution: Fixed master: 1de54fe48472b43e469cccbb95935d46163c8b16 > supports INSERT statement in

[jira] [Assigned] (FLINK-17112) Support DESCRIBE view_name in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17112: -- Assignee: Zhenghua Gao > Support DESCRIBE view_name in Flink SQL >

[jira] [Closed] (FLINK-16029) Remove register source and sink in test cases of blink planner

[ https://issues.apache.org/jira/browse/FLINK-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16029. -- Fix Version/s: 1.11.0 Assignee: Zhenghua Gao Resolution: Fixed master: 

<    1   2   3   4   5   6   7   8   9   10   >