[jira] [Created] (FLINK-31667) Should not enforce attached mode in RemoteEnvironment & RemoteStreamEnvironment

Jeff Zhang created FLINK-31667: -- Summary: Should not enforce attached mode in RemoteEnvironment & RemoteStreamEnvironment Key: FLINK-31667 URL: https://issues.apache.org/jira/browse/FLINK-31667 Project:

[jira] [Created] (FLINK-21607) Twitter table source connector

Jeff Zhang created FLINK-21607: -- Summary: Twitter table source connector Key: FLINK-21607 URL: https://issues.apache.org/jira/browse/FLINK-21607 Project: Flink Issue Type: New Feature Affect

[jira] [Created] (FLINK-18167) Flink Job hangs there when one vertex is failed and another is cancelled.

Jeff Zhang created FLINK-18167: -- Summary: Flink Job hangs there when one vertex is failed and another is cancelled. Key: FLINK-18167 URL: https://issues.apache.org/jira/browse/FLINK-18167 Project: Flink

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

Jeff Zhang created FLINK-17944: -- Summary: Wrong output in sql client's table mode Key: FLINK-17944 URL: https://issues.apache.org/jira/browse/FLINK-17944 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

Jeff Zhang created FLINK-17889: -- Summary: flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory Key: FLINK-17889 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-17870) scala shell jars are missing to be shipped to cluster

Jeff Zhang created FLINK-17870: -- Summary: scala shell jars are missing to be shipped to cluster Key: FLINK-17870 URL: https://issues.apache.org/jira/browse/FLINK-17870 Project: Flink Issue Type:

[jira] [Created] (FLINK-17788) scala shell in yarn mode is broken

Jeff Zhang created FLINK-17788: -- Summary: scala shell in yarn mode is broken Key: FLINK-17788 URL: https://issues.apache.org/jira/browse/FLINK-17788 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-17763) No log files when starting scala-shell

Jeff Zhang created FLINK-17763: -- Summary: No log files when starting scala-shell Key: FLINK-17763 URL: https://issues.apache.org/jira/browse/FLINK-17763 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode.

Jeff Zhang created FLINK-17588: -- Summary: Throw exception when hadoop jar is missing in flink scala's yarn mode. Key: FLINK-17588 URL: https://issues.apache.org/jira/browse/FLINK-17588 Project: Flink

[jira] [Created] (FLINK-16969) Unable to use case class in flink scala shell

Jeff Zhang created FLINK-16969: -- Summary: Unable to use case class in flink scala shell Key: FLINK-16969 URL: https://issues.apache.org/jira/browse/FLINK-16969 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16936) TablEnv creation and planner execution must be in the same thread

Jeff Zhang created FLINK-16936: -- Summary: TablEnv creation and planner execution must be in the same thread Key: FLINK-16936 URL: https://issues.apache.org/jira/browse/FLINK-16936 Project: Flink

[jira] [Created] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG

Jeff Zhang created FLINK-16797: -- Summary: Flink doesn't merge multiple sinks into one DAG Key: FLINK-16797 URL: https://issues.apache.org/jira/browse/FLINK-16797 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16604) Column key in JM configuration is too narrow

Jeff Zhang created FLINK-16604: -- Summary: Column key in JM configuration is too narrow Key: FLINK-16604 URL: https://issues.apache.org/jira/browse/FLINK-16604 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-16286) Support select from nothing

Jeff Zhang created FLINK-16286: -- Summary: Support select from nothing Key: FLINK-16286 URL: https://issues.apache.org/jira/browse/FLINK-16286 Project: Flink Issue Type: New Feature Affects V

[jira] [Created] (FLINK-15935) Unable to use watermark when depends both on flink planner and blink planner

Jeff Zhang created FLINK-15935: -- Summary: Unable to use watermark when depends both on flink planner and blink planner Key: FLINK-15935 URL: https://issues.apache.org/jira/browse/FLINK-15935 Project: Fli

[jira] [Created] (FLINK-15858) Unable to use HiveCatalog and kafka together

Jeff Zhang created FLINK-15858: -- Summary: Unable to use HiveCatalog and kafka together Key: FLINK-15858 URL: https://issues.apache.org/jira/browse/FLINK-15858 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15592) Streaming sql throw hive related sql when it doesn't use any hive table

Jeff Zhang created FLINK-15592: -- Summary: Streaming sql throw hive related sql when it doesn't use any hive table Key: FLINK-15592 URL: https://issues.apache.org/jira/browse/FLINK-15592 Project: Flink

[jira] [Created] (FLINK-15569) Incorrect sample code in udf document

Jeff Zhang created FLINK-15569: -- Summary: Incorrect sample code in udf document Key: FLINK-15569 URL: https://issues.apache.org/jira/browse/FLINK-15569 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

Jeff Zhang created FLINK-15566: -- Summary: Flink implicitly order the fields in PojoTypeInfo Key: FLINK-15566 URL: https://issues.apache.org/jira/browse/FLINK-15566 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-15562) Unable to create walk through project

Jeff Zhang created FLINK-15562: -- Summary: Unable to create walk through project Key: FLINK-15562 URL: https://issues.apache.org/jira/browse/FLINK-15562 Project: Flink Issue Type: Bug Affects

[jira] [Created] (FLINK-15439) Incorrect SQL Document about DDL support

Jeff Zhang created FLINK-15439: -- Summary: Incorrect SQL Document about DDL support Key: FLINK-15439 URL: https://issues.apache.org/jira/browse/FLINK-15439 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15395) No API for execute insert into statement

Jeff Zhang created FLINK-15395: -- Summary: No API for execute insert into statement Key: FLINK-15395 URL: https://issues.apache.org/jira/browse/FLINK-15395 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

Jeff Zhang created FLINK-15384: -- Summary: Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment Key: FLINK-15384 URL: https://issues.apache.org/jira/browse/FLINK-15384 Projec

[jira] [Created] (FLINK-15380) Unable to set number of TM and number of Slot for MiniCluster in Scala shell

Jeff Zhang created FLINK-15380: -- Summary: Unable to set number of TM and number of Slot for MiniCluster in Scala shell Key: FLINK-15380 URL: https://issues.apache.org/jira/browse/FLINK-15380 Project: Fli

[jira] [Created] (FLINK-15093) FLINK-13708 still exist in StreamExecutionEnvironment

Jeff Zhang created FLINK-15093: -- Summary: FLINK-13708 still exist in StreamExecutionEnvironment Key: FLINK-15093 URL: https://issues.apache.org/jira/browse/FLINK-15093 Project: Flink Issue Type:

[jira] [Created] (FLINK-14836) Unable to set yarn container number for scala shell in yarn mode

Jeff Zhang created FLINK-14836: -- Summary: Unable to set yarn container number for scala shell in yarn mode Key: FLINK-14836 URL: https://issues.apache.org/jira/browse/FLINK-14836 Project: Flink

[jira] [Created] (FLINK-14807) Add Table#collect api for fetching data to client

Jeff Zhang created FLINK-14807: -- Summary: Add Table#collect api for fetching data to client Key: FLINK-14807 URL: https://issues.apache.org/jira/browse/FLINK-14807 Project: Flink Issue Type: New

[jira] [Created] (FLINK-13951) Unable to call limit without sort for batch mode

Jeff Zhang created FLINK-13951: -- Summary: Unable to call limit without sort for batch mode Key: FLINK-13951 URL: https://issues.apache.org/jira/browse/FLINK-13951 Project: Flink Issue Type: Impr

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

Jeff Zhang created FLINK-13943: -- Summary: Provide api to convert flink table to java List Key: FLINK-13943 URL: https://issues.apache.org/jira/browse/FLINK-13943 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-13851) Time unit of garbage collection in Flink Web UI is not displayed

Jeff Zhang created FLINK-13851: -- Summary: Time unit of garbage collection in Flink Web UI is not displayed Key: FLINK-13851 URL: https://issues.apache.org/jira/browse/FLINK-13851 Project: Flink

[jira] [Created] (FLINK-13811) Support converting flink table to pandas dataframe

Jeff Zhang created FLINK-13811: -- Summary: Support converting flink table to pandas dataframe Key: FLINK-13811 URL: https://issues.apache.org/jira/browse/FLINK-13811 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-13744) Improper error message when submit flink job in yarn-cluster mode without hadoop lib bundled

Jeff Zhang created FLINK-13744: -- Summary: Improper error message when submit flink job in yarn-cluster mode without hadoop lib bundled Key: FLINK-13744 URL: https://issues.apache.org/jira/browse/FLINK-13744

[jira] [Created] (FLINK-13659) Add method listDatabases(catalog) and listTables(catalog, database) in TableEnvironment

Jeff Zhang created FLINK-13659: -- Summary: Add method listDatabases(catalog) and listTables(catalog, database) in TableEnvironment Key: FLINK-13659 URL: https://issues.apache.org/jira/browse/FLINK-13659 P

[jira] [Created] (FLINK-13645) Error in code-gen when using blink planner in scala shell

Jeff Zhang created FLINK-13645: -- Summary: Error in code-gen when using blink planner in scala shell Key: FLINK-13645 URL: https://issues.apache.org/jira/browse/FLINK-13645 Project: Flink Issue T

[jira] [Created] (FLINK-13462) Add table api examples into flink-quickstart

Jeff Zhang created FLINK-13462: -- Summary: Add table api examples into flink-quickstart Key: FLINK-13462 URL: https://issues.apache.org/jira/browse/FLINK-13462 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-13432) Set max polling interval threshold for job result polling

Jeff Zhang created FLINK-13432: -- Summary: Set max polling interval threshold for job result polling Key: FLINK-13432 URL: https://issues.apache.org/jira/browse/FLINK-13432 Project: Flink Issue T

[jira] [Created] (FLINK-13423) Unable to find aggregation function in hive 1

Jeff Zhang created FLINK-13423: -- Summary: Unable to find aggregation function in hive 1 Key: FLINK-13423 URL: https://issues.apache.org/jira/browse/FLINK-13423 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-13420) Supported hive versions are hard coded

Jeff Zhang created FLINK-13420: -- Summary: Supported hive versions are hard coded Key: FLINK-13420 URL: https://issues.apache.org/jira/browse/FLINK-13420 Project: Flink Issue Type: Improvement

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

Jeff Zhang created FLINK-13415: -- Summary: Document how to use hive connector in scala shell Key: FLINK-13415 URL: https://issues.apache.org/jira/browse/FLINK-13415 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-13413) Put flink-table jar under lib folder

Jeff Zhang created FLINK-13413: -- Summary: Put flink-table jar under lib folder Key: FLINK-13413 URL: https://issues.apache.org/jira/browse/FLINK-13413 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13411) SqlClient swallow the error when fails to submit job

Jeff Zhang created FLINK-13411: -- Summary: SqlClient swallow the error when fails to submit job Key: FLINK-13411 URL: https://issues.apache.org/jira/browse/FLINK-13411 Project: Flink Issue Type:

[jira] [Created] (FLINK-13379) Make Flink work without flink-shaded-hadoop jar

Jeff Zhang created FLINK-13379: -- Summary: Make Flink work without flink-shaded-hadoop jar Key: FLINK-13379 URL: https://issues.apache.org/jira/browse/FLINK-13379 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-13163) Default value of slot.request.timeout is too small for batch job

Jeff Zhang created FLINK-13163: -- Summary: Default value of slot.request.timeout is too small for batch job Key: FLINK-13163 URL: https://issues.apache.org/jira/browse/FLINK-13163 Project: Flink

[jira] [Created] (FLINK-13162) Default value of slot.idle.timeout is too large for batch job

Jeff Zhang created FLINK-13162: -- Summary: Default value of slot.idle.timeout is too large for batch job Key: FLINK-13162 URL: https://issues.apache.org/jira/browse/FLINK-13162 Project: Flink Is

[jira] [Created] (FLINK-13152) Unable to run query when using HiveCatalog and DataSet api

Jeff Zhang created FLINK-13152: -- Summary: Unable to run query when using HiveCatalog and DataSet api Key: FLINK-13152 URL: https://issues.apache.org/jira/browse/FLINK-13152 Project: Flink Issue

[jira] [Created] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

Jeff Zhang created FLINK-13150: -- Summary: defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment Key: FLINK-13150 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-13144) Add takeAsList to Table

Jeff Zhang created FLINK-13144: -- Summary: Add takeAsList to Table Key: FLINK-13144 URL: https://issues.apache.org/jira/browse/FLINK-13144 Project: Flink Issue Type: Improvement Compone

[jira] [Created] (FLINK-13138) Make SqlCommandParser.SqlCommand as public

Jeff Zhang created FLINK-13138: -- Summary: Make SqlCommandParser.SqlCommand as public Key: FLINK-13138 URL: https://issues.apache.org/jira/browse/FLINK-13138 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-12629) Add integration test for scala shell in yarn mode

Jeff Zhang created FLINK-12629: -- Summary: Add integration test for scala shell in yarn mode Key: FLINK-12629 URL: https://issues.apache.org/jira/browse/FLINK-12629 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-12621) Use MiniCluster instead of JobExecutor

Jeff Zhang created FLINK-12621: -- Summary: Use MiniCluster instead of JobExecutor Key: FLINK-12621 URL: https://issues.apache.org/jira/browse/FLINK-12621 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12596) Unify all kinds of cluster into ClusterClient in FlinkShell

Jeff Zhang created FLINK-12596: -- Summary: Unify all kinds of cluster into ClusterClient in FlinkShell Key: FLINK-12596 URL: https://issues.apache.org/jira/browse/FLINK-12596 Project: Flink Issu

[jira] [Created] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent

Jeff Zhang created FLINK-12422: -- Summary: Remove IN_TESTS for make test code and production code consistent Key: FLINK-12422 URL: https://issues.apache.org/jira/browse/FLINK-12422 Project: Flink

[jira] [Created] (FLINK-12283) Allow non static UDF

Jeff Zhang created FLINK-12283: -- Summary: Allow non static UDF Key: FLINK-12283 URL: https://issues.apache.org/jira/browse/FLINK-12283 Project: Flink Issue Type: New Feature Components

[jira] [Created] (FLINK-12272) Enable session in ExecutionEnvironment

Jeff Zhang created FLINK-12272: -- Summary: Enable session in ExecutionEnvironment Key: FLINK-12272 URL: https://issues.apache.org/jira/browse/FLINK-12272 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

Jeff Zhang created FLINK-1: -- Summary: No way to ship custom jars to yarn cluster in scala-shell Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink Issue T

[jira] [Created] (FLINK-12214) Add JobListener to capture job submission process

Jeff Zhang created FLINK-12214: -- Summary: Add JobListener to capture job submission process Key: FLINK-12214 URL: https://issues.apache.org/jira/browse/FLINK-12214 Project: Flink Issue Type: New

[jira] [Created] (FLINK-12159) Enable YarnMiniCluster integration test under non-secure mode

Jeff Zhang created FLINK-12159: -- Summary: Enable YarnMiniCluster integration test under non-secure mode Key: FLINK-12159 URL: https://issues.apache.org/jira/browse/FLINK-12159 Project: Flink Is

[jira] [Created] (FLINK-12027) Flink Web UI is not accessible in local mode

Jeff Zhang created FLINK-12027: -- Summary: Flink Web UI is not accessible in local mode Key: FLINK-12027 URL: https://issues.apache.org/jira/browse/FLINK-12027 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

Jeff Zhang created FLINK-11970: -- Summary: TableEnvironment#registerFunction should overwrite if the same name function existed. Key: FLINK-11970 URL: https://issues.apache.org/jira/browse/FLINK-11970 Pr

[jira] [Created] (FLINK-11305) Allow developer to test flink without building the whole flink project

Jeff Zhang created FLINK-11305: -- Summary: Allow developer to test flink without building the whole flink project Key: FLINK-11305 URL: https://issues.apache.org/jira/browse/FLINK-11305 Project: Flink

[jira] [Created] (FLINK-11264) Fail to start scala shell

Jeff Zhang created FLINK-11264: -- Summary: Fail to start scala shell Key: FLINK-11264 URL: https://issues.apache.org/jira/browse/FLINK-11264 Project: Flink Issue Type: Bug Reporter: J

[jira] [Created] (FLINK-11224) Log is missing in scala-shell

Jeff Zhang created FLINK-11224: -- Summary: Log is missing in scala-shell Key: FLINK-11224 URL: https://issues.apache.org/jira/browse/FLINK-11224 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-11161) Unable to import java packages in scala-shell

Jeff Zhang created FLINK-11161: -- Summary: Unable to import java packages in scala-shell Key: FLINK-11161 URL: https://issues.apache.org/jira/browse/FLINK-11161 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-11060) Unable to set number of task manager and slot per task number in scala shell local mode

Jeff Zhang created FLINK-11060: -- Summary: Unable to set number of task manager and slot per task number in scala shell local mode Key: FLINK-11060 URL: https://issues.apache.org/jira/browse/FLINK-11060 P

[jira] [Created] (FLINK-11049) Unable to execute partial DAG

Jeff Zhang created FLINK-11049: -- Summary: Unable to execute partial DAG Key: FLINK-11049 URL: https://issues.apache.org/jira/browse/FLINK-11049 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-10892) Flink Yarn app name is hard coded

Jeff Zhang created FLINK-10892: -- Summary: Flink Yarn app name is hard coded Key: FLINK-10892 URL: https://issues.apache.org/jira/browse/FLINK-10892 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10889) Semantic inconsistency between DataSet#print and DataStream#print

Jeff Zhang created FLINK-10889: -- Summary: Semantic inconsistency between DataSet#print and DataStream#print Key: FLINK-10889 URL: https://issues.apache.org/jira/browse/FLINK-10889 Project: Flink

[jira] [Created] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

Jeff Zhang created FLINK-10873: -- Summary: Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable Key: FLINK-10873 URL: https://issues.apache.org/jira/browse/FLINK-10873 Project:

[jira] [Created] (FLINK-10871) ExecutionEnvironment & TableEnvironment should be singleton

Jeff Zhang created FLINK-10871: -- Summary: ExecutionEnvironment & TableEnvironment should be singleton Key: FLINK-10871 URL: https://issues.apache.org/jira/browse/FLINK-10871 Project: Flink Issu

[jira] [Created] (FLINK-10702) Yarn app is not killed when scala shell is terminated

Jeff Zhang created FLINK-10702: -- Summary: Yarn app is not killed when scala shell is terminated Key: FLINK-10702 URL: https://issues.apache.org/jira/browse/FLINK-10702 Project: Flink Issue Type:

[jira] [Created] (FLINK-10341) Add option to print flink command when running bin/flink

Jeff Zhang created FLINK-10341: -- Summary: Add option to print flink command when running bin/flink Key: FLINK-10341 URL: https://issues.apache.org/jira/browse/FLINK-10341 Project: Flink Issue Ty

[jira] [Created] (FLINK-9718) Add enviroment variable in start-scala-shell.sh to enable remote debug

Jeff Zhang created FLINK-9718: - Summary: Add enviroment variable in start-scala-shell.sh to enable remote debug Key: FLINK-9718 URL: https://issues.apache.org/jira/browse/FLINK-9718 Project: Flink

[jira] [Created] (FLINK-9699) Add api to replace table

Jeff Zhang created FLINK-9699: - Summary: Add api to replace table Key: FLINK-9699 URL: https://issues.apache.org/jira/browse/FLINK-9699 Project: Flink Issue Type: Improvement Reporter

[jira] [Created] (FLINK-9698) "case class must be static and globally accessible" is too constrained

Jeff Zhang created FLINK-9698: - Summary: "case class must be static and globally accessible" is too constrained Key: FLINK-9698 URL: https://issues.apache.org/jira/browse/FLINK-9698 Project: Flink

[jira] [Created] (FLINK-9555) Support table api in scala shell

Jeff Zhang created FLINK-9555: - Summary: Support table api in scala shell Key: FLINK-9555 URL: https://issues.apache.org/jira/browse/FLINK-9555 Project: Flink Issue Type: New Feature Co

[jira] [Created] (FLINK-9554) flink scala shell doesn't work in yarn mode

Jeff Zhang created FLINK-9554: - Summary: flink scala shell doesn't work in yarn mode Key: FLINK-9554 URL: https://issues.apache.org/jira/browse/FLINK-9554 Project: Flink Issue Type: Bug