[jira] [Created] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

yuemeng created FLINK-29801: --- Summary: OperatorCoordinator need open the way to operate metricGroup interface Key: FLINK-29801 URL: https://issues.apache.org/jira/browse/FLINK-29801 Project: Flink

[jira] [Created] (FLINK-20935) can't write flink configuration to tmp file and add it to local resource in yarn session mode

yuemeng created FLINK-20935: --- Summary: can't write flink configuration to tmp file and add it to local resource in yarn session mode Key: FLINK-20935 URL: https://issues.apache.org/jira/browse/FLINK-20935 P

[jira] [Created] (FLINK-14666) support multiple catalog in flink table sql

yuemeng created FLINK-14666: --- Summary: support multiple catalog in flink table sql Key: FLINK-14666 URL: https://issues.apache.org/jira/browse/FLINK-14666 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-11057) where in grammar will cause stream inner join loigcal

yuemeng created FLINK-11057: --- Summary: where in grammar will cause stream inner join loigcal Key: FLINK-11057 URL: https://issues.apache.org/jira/browse/FLINK-11057 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

yuemeng created FLINK-9329: -- Summary: hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source Key: FLINK-9329 URL: https://issues.apache.org/jira/browse/FLINK-9329 Project: Flink

[jira] [Created] (FLINK-9201) same merge window will fire twice if watermark already pass the window for merge windows

yuemeng created FLINK-9201: -- Summary: same merge window will fire twice if watermark already pass the window for merge windows Key: FLINK-9201 URL: https://issues.apache.org/jira/browse/FLINK-9201 Project: F

[jira] [Created] (FLINK-7151) FLINK SQL support create temporary function and table

yuemeng created FLINK-7151: -- Summary: FLINK SQL support create temporary function and table Key: FLINK-7151 URL: https://issues.apache.org/jira/browse/FLINK-7151 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-7148) Flink SQL API support DDL

yuemeng created FLINK-7148: -- Summary: Flink SQL API support DDL Key: FLINK-7148 URL: https://issues.apache.org/jira/browse/FLINK-7148 Project: Flink Issue Type: Bug Components: Table API

[jira] [Created] (FLINK-7145) Flink SQL API should support multiple parameters for UserDefinedAggFunction

yuemeng created FLINK-7145: -- Summary: Flink SQL API should support multiple parameters for UserDefinedAggFunction Key: FLINK-7145 URL: https://issues.apache.org/jira/browse/FLINK-7145 Project: Flink

[jira] [Created] (FLINK-7146) FLINK SQLs support DDL

yuemeng created FLINK-7146: -- Summary: FLINK SQLs support DDL Key: FLINK-7146 URL: https://issues.apache.org/jira/browse/FLINK-7146 Project: Flink Issue Type: Sub-task Components: Table API

[jira] [Created] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode

yuemeng created FLINK-5324: -- Summary: JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode Key: FLINK-5324 URL: https://issues.apache.org/jira/browse/FLINK-5324 Pr

[jira] [Created] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

yuemeng created FLINK-4879: -- Summary: class KafkaTableSource should be public just like KafkaTableSink Key: FLINK-4879 URL: https://issues.apache.org/jira/browse/FLINK-4879 Project: Flink Issue Typ

[jira] [Created] (FLINK-4827) Sql on streaming example use scala with wrong variable name

yuemeng created FLINK-4827: -- Summary: Sql on streaming example use scala with wrong variable name Key: FLINK-4827 URL: https://issues.apache.org/jira/browse/FLINK-4827 Project: Flink Issue Type: Bu