[jira] [Created] (FLINK-20685) Flink connect incorrect address of yarn's resouceManager scheduler

Spongebob created FLINK-20685: - Summary: Flink connect incorrect address of yarn's resouceManager scheduler Key: FLINK-20685 URL: https://issues.apache.org/jira/browse/FLINK-20685 Project: Flink

[jira] [Created] (FLINK-20917) can not drop hive partition on flink

Spongebob created FLINK-20917: - Summary: can not drop hive partition on flink Key: FLINK-20917 URL: https://issues.apache.org/jira/browse/FLINK-20917 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20923) insert hive failed using old planner

Spongebob created FLINK-20923: - Summary: insert hive failed using old planner Key: FLINK-20923 URL: https://issues.apache.org/jira/browse/FLINK-20923 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

Spongebob created FLINK-21060: - Summary: Could not create the DispatcherResourceManagerComponent Key: FLINK-21060 URL: https://issues.apache.org/jira/browse/FLINK-21060 Project: Flink Issue

[jira] [Created] (FLINK-20984) can not convert an array into Table

Spongebob created FLINK-20984: - Summary: can not convert an array into Table Key: FLINK-20984 URL: https://issues.apache.org/jira/browse/FLINK-20984 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21279) flink on yarn sink nothing

Spongebob created FLINK-21279: - Summary: flink on yarn sink nothing Key: FLINK-21279 URL: https://issues.apache.org/jira/browse/FLINK-21279 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-22874) flink table partition trigger doesn't effect as expectation when sink into hive table

Spongebob created FLINK-22874: - Summary: flink table partition trigger doesn't effect as expectation when sink into hive table Key: FLINK-22874 URL: https://issues.apache.org/jira/browse/FLINK-22874

[jira] [Created] (FLINK-23177) watermarks generated in dateStream can not flow into table

Spongebob created FLINK-23177: - Summary: watermarks generated in dateStream can not flow into table Key: FLINK-23177 URL: https://issues.apache.org/jira/browse/FLINK-23177 Project: Flink Issue

[jira] [Created] (FLINK-22458) Failed when operating empty catalog table

Spongebob created FLINK-22458: - Summary: Failed when operating empty catalog table Key: FLINK-22458 URL: https://issues.apache.org/jira/browse/FLINK-22458 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21914) Trying to access closed classloader

Spongebob created FLINK-21914: - Summary: Trying to access closed classloader Key: FLINK-21914 URL: https://issues.apache.org/jira/browse/FLINK-21914 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21527) fromValues function cost enormous network buffer

Spongebob created FLINK-21527: - Summary: fromValues function cost enormous network buffer Key: FLINK-21527 URL: https://issues.apache.org/jira/browse/FLINK-21527 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22165) How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv

Spongebob created FLINK-22165: - Summary: How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv Key: FLINK-22165 URL: https://issues.apache.org/jira/browse/FLINK-22165 Project: Flink

[jira] [Created] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

Spongebob created FLINK-22190: - Summary: no guarantee on Flink exactly_once sink to Kafka Key: FLINK-22190 URL: https://issues.apache.org/jira/browse/FLINK-22190 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22247) can not pass AddressList when connecting to rabbitmq

Spongebob created FLINK-22247: - Summary: can not pass AddressList when connecting to rabbitmq Key: FLINK-22247 URL: https://issues.apache.org/jira/browse/FLINK-22247 Project: Flink Issue Type:

[jira] [Created] (FLINK-22422) -ynm option doesn't effect when deploying flink on yarn

Spongebob created FLINK-22422: - Summary: -ynm option doesn't effect when deploying flink on yarn Key: FLINK-22422 URL: https://issues.apache.org/jira/browse/FLINK-22422 Project: Flink Issue

[jira] [Created] (FLINK-24104) incorrect validation of sink schema

Spongebob created FLINK-24104: - Summary: incorrect validation of sink schema Key: FLINK-24104 URL: https://issues.apache.org/jira/browse/FLINK-24104 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24338) Provide an interface to validate flinksql

Spongebob created FLINK-24338: - Summary: Provide an interface to validate flinksql Key: FLINK-24338 URL: https://issues.apache.org/jira/browse/FLINK-24338 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-24289) Load data repeatedly between different jobs

Spongebob created FLINK-24289: - Summary: Load data repeatedly between different jobs Key: FLINK-24289 URL: https://issues.apache.org/jira/browse/FLINK-24289 Project: Flink Issue Type:

[jira] [Created] (FLINK-24473) getString value from any datatype columns

Spongebob created FLINK-24473: - Summary: getString value from any datatype columns Key: FLINK-24473 URL: https://issues.apache.org/jira/browse/FLINK-24473 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-25373) task manager can not free memory when jobs are finished

Spongebob created FLINK-25373: - Summary: task manager can not free memory when jobs are finished Key: FLINK-25373 URL: https://issues.apache.org/jira/browse/FLINK-25373 Project: Flink Issue

[jira] [Created] (FLINK-25502) eval method of Flink ScalerFunction only run one time

Spongebob created FLINK-25502: - Summary: eval method of Flink ScalerFunction only run one time Key: FLINK-25502 URL: https://issues.apache.org/jira/browse/FLINK-25502 Project: Flink Issue Type:

[jira] [Created] (FLINK-24837) submit flink job failed via restapi

Spongebob created FLINK-24837: - Summary: submit flink job failed via restapi Key: FLINK-24837 URL: https://issues.apache.org/jira/browse/FLINK-24837 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26327) throw not a literal exception in callContext.getArgumentValue when getTypeInference

Spongebob created FLINK-26327: - Summary: throw not a literal exception in callContext.getArgumentValue when getTypeInference Key: FLINK-26327 URL: https://issues.apache.org/jira/browse/FLINK-26327

[jira] [Created] (FLINK-26461) Throw CannotPlanException in TableFunction

Spongebob created FLINK-26461: - Summary: Throw CannotPlanException in TableFunction Key: FLINK-26461 URL: https://issues.apache.org/jira/browse/FLINK-26461 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26384) This exception indicates that the query uses an unsupported SQL feature.

Spongebob created FLINK-26384: - Summary: This exception indicates that the query uses an unsupported SQL feature. Key: FLINK-26384 URL: https://issues.apache.org/jira/browse/FLINK-26384 Project: Flink

[jira] [Created] (FLINK-26925) loss scale in union situation

Spongebob created FLINK-26925: - Summary: loss scale in union situation Key: FLINK-26925 URL: https://issues.apache.org/jira/browse/FLINK-26925 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32970) could not load external class using "-C" option

Spongebob created FLINK-32970: - Summary: could not load external class using "-C" option Key: FLINK-32970 URL: https://issues.apache.org/jira/browse/FLINK-32970 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27638) failed to join with table function

Spongebob created FLINK-27638: - Summary: failed to join with table function Key: FLINK-27638 URL: https://issues.apache.org/jira/browse/FLINK-27638 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27969) StreamPhysicalOverAggregate doesn't support consuming update and delete changes

Spongebob created FLINK-27969: - Summary: StreamPhysicalOverAggregate doesn't support consuming update and delete changes Key: FLINK-27969 URL: https://issues.apache.org/jira/browse/FLINK-27969 Project:

[jira] [Created] (FLINK-27462) could not trigger checkpoint when using table function

Spongebob created FLINK-27462: - Summary: could not trigger checkpoint when using table function Key: FLINK-27462 URL: https://issues.apache.org/jira/browse/FLINK-27462 Project: Flink Issue Type:

[jira] [Created] (FLINK-27436) option `properties.group.id` is not effective in kafka connector for finksql

Spongebob created FLINK-27436: - Summary: option `properties.group.id` is not effective in kafka connector for finksql Key: FLINK-27436 URL: https://issues.apache.org/jira/browse/FLINK-27436 Project:

[jira] [Created] (FLINK-29216) rows belong to update rowkind are transfered into delete and insert

Spongebob created FLINK-29216: - Summary: rows belong to update rowkind are transfered into delete and insert Key: FLINK-29216 URL: https://issues.apache.org/jira/browse/FLINK-29216 Project: Flink

[jira] [Created] (FLINK-29428) got an ambigious exception in flinksql

Spongebob created FLINK-29428: - Summary: got an ambigious exception in flinksql Key: FLINK-29428 URL: https://issues.apache.org/jira/browse/FLINK-29428 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30500) Got an null pointer exception when using table environment in sub-thread

Spongebob created FLINK-30500: - Summary: Got an null pointer exception when using table environment in sub-thread Key: FLINK-30500 URL: https://issues.apache.org/jira/browse/FLINK-30500 Project: Flink

[jira] [Created] (FLINK-32274) kafka class could not be found while using appliction mode.

Spongebob created FLINK-32274: - Summary: kafka class could not be found while using appliction mode. Key: FLINK-32274 URL: https://issues.apache.org/jira/browse/FLINK-32274 Project: Flink Issue

[jira] [Created] (FLINK-32308) RestClusterClient submit job to remote cluster

Spongebob created FLINK-32308: - Summary: RestClusterClient submit job to remote cluster Key: FLINK-32308 URL: https://issues.apache.org/jira/browse/FLINK-32308 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32739) restarting not work

Spongebob created FLINK-32739: - Summary: restarting not work Key: FLINK-32739 URL: https://issues.apache.org/jira/browse/FLINK-32739 Project: Flink Issue Type: Bug Components: API /

[jira] [Created] (FLINK-32361) error after replace dependent jar file

Spongebob created FLINK-32361: - Summary: error after replace dependent jar file Key: FLINK-32361 URL: https://issues.apache.org/jira/browse/FLINK-32361 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32065) Got NoSuchFileException when initialize source function.

Spongebob created FLINK-32065: - Summary: Got NoSuchFileException when initialize source function. Key: FLINK-32065 URL: https://issues.apache.org/jira/browse/FLINK-32065 Project: Flink Issue

[jira] [Created] (FLINK-33855) send flag message like checkpoint barrier

Spongebob created FLINK-33855: - Summary: send flag message like checkpoint barrier Key: FLINK-33855 URL: https://issues.apache.org/jira/browse/FLINK-33855 Project: Flink Issue Type: Technical