[jira] [Created] (FLINK-20255) Nested decorrelate failed

godfrey he created FLINK-20255: -- Summary: Nested decorrelate failed Key: FLINK-20255 URL: https://issues.apache.org/jira/browse/FLINK-20255 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

Robert Metzger created FLINK-20254: -- Summary: HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out Key: FLINK-20254 URL: https://issues.apache.org/jira/browse/FLINK-20254 Project:

[jira] [Created] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

zouyunhe created FLINK-20253: Summary: `JsonRowDeserializationSchema` can not deserialize non utf-8 json string Key: FLINK-20253 URL: https://issues.apache.org/jira/browse/FLINK-20253 Project: Flink

[jira] [Created] (FLINK-20252) Manual Test for Approximate Local Recovery

Yuan Mei created FLINK-20252: Summary: Manual Test for Approximate Local Recovery Key: FLINK-20252 URL: https://issues.apache.org/jira/browse/FLINK-20252 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20251) Can't import all release-signing keys

Bob created FLINK-20251: --- Summary: Can't import all release-signing keys Key: FLINK-20251 URL: https://issues.apache.org/jira/browse/FLINK-20251 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method

hailong wang created FLINK-20250: Summary: NPE when invoking AsyncLookupJoinRunner#close method Key: FLINK-20250 URL: https://issues.apache.org/jira/browse/FLINK-20250 Project: Flink Issue

[jira] [Created] (FLINK-20249) Rethink the necessity of the k8s internal Service even on non-HA mode

jiang7chengzitc created FLINK-20249: --- Summary: Rethink the necessity of the k8s internal Service even on non-HA mode Key: FLINK-20249 URL: https://issues.apache.org/jira/browse/FLINK-20249 Project:

[jira] [Created] (FLINK-20248) `ParquetSchemaConverter` can not convert Array type to parquet Type

zouyunhe created FLINK-20248: Summary: `ParquetSchemaConverter` can not convert Array type to parquet Type Key: FLINK-20248 URL: https://issues.apache.org/jira/browse/FLINK-20248 Project: Flink

[jira] [Created] (FLINK-20247) Hide unused unaligned checkpoint configuration options

Arvid Heise created FLINK-20247: --- Summary: Hide unused unaligned checkpoint configuration options Key: FLINK-20247 URL: https://issues.apache.org/jira/browse/FLINK-20247 Project: Flink Issue

[jira] [Created] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page

Dian Fu created FLINK-20246: --- Summary: Add documentation on Python worker memory tuning in the memory tuning page Key: FLINK-20246 URL: https://issues.apache.org/jira/browse/FLINK-20246 Project: Flink

[jira] [Created] (FLINK-20245) Document how to create a Hive catalog from DDL

Dawid Wysakowicz created FLINK-20245: Summary: Document how to create a Hive catalog from DDL Key: FLINK-20245 URL: https://issues.apache.org/jira/browse/FLINK-20245 Project: Flink Issue

[jira] [Created] (FLINK-20244) RMQSource does not ACK duplicated messages

Thomas Eckestad created FLINK-20244: --- Summary: RMQSource does not ACK duplicated messages Key: FLINK-20244 URL: https://issues.apache.org/jira/browse/FLINK-20244 Project: Flink Issue Type:

[jira] [Created] (FLINK-20243) Remove useless words in documents

xiaozilong created FLINK-20243: -- Summary: Remove useless words in documents Key: FLINK-20243 URL: https://issues.apache.org/jira/browse/FLINK-20243 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20242) Can not set job name in StatementSet.execute() method

zouyunhe created FLINK-20242: Summary: Can not set job name in StatementSet.execute() method Key: FLINK-20242 URL: https://issues.apache.org/jira/browse/FLINK-20242 Project: Flink Issue Type:

[jira] [Created] (FLINK-20241) Cannot read/write orc table from Hive

Dawid Wysakowicz created FLINK-20241: Summary: Cannot read/write orc table from Hive Key: FLINK-20241 URL: https://issues.apache.org/jira/browse/FLINK-20241 Project: Flink Issue Type:

[jira] [Created] (FLINK-20240) Add setter in the environment for the `execution.runtime-mode`

Kostas Kloudas created FLINK-20240: -- Summary: Add setter in the environment for the `execution.runtime-mode` Key: FLINK-20240 URL: https://issues.apache.org/jira/browse/FLINK-20240 Project: Flink

[jira] [Created] (FLINK-20239) Confusing pages: "Hive Read & Write" and "Hive Streaming"

Dawid Wysakowicz created FLINK-20239: Summary: Confusing pages: "Hive Read & Write" and "Hive Streaming" Key: FLINK-20239 URL: https://issues.apache.org/jira/browse/FLINK-20239 Project: Flink

[jira] [Created] (FLINK-20238) flink-sql-connector-elasticsearch does not support Elasticsearch auth

liu created FLINK-20238: --- Summary: flink-sql-connector-elasticsearch does not support Elasticsearch auth Key: FLINK-20238 URL: https://issues.apache.org/jira/browse/FLINK-20238 Project: Flink Issue

[jira] [Created] (FLINK-20237) Do not recommend putting hive-exec in flink/lib

Dawid Wysakowicz created FLINK-20237: Summary: Do not recommend putting hive-exec in flink/lib Key: FLINK-20237 URL: https://issues.apache.org/jira/browse/FLINK-20237 Project: Flink

[jira] [Created] (FLINK-20235) Missing Hive dependencies

Dawid Wysakowicz created FLINK-20235: Summary: Missing Hive dependencies Key: FLINK-20235 URL: https://issues.apache.org/jira/browse/FLINK-20235 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

CloseRiver created FLINK-20236: -- Summary: flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar Key: FLINK-20236 URL: https://issues.apache.org/jira/browse/FLINK-20236 Project: Flink

[jira] [Created] (FLINK-20234) Json format supports SE/DE null elements of ARRAY type field

Danny Chen created FLINK-20234: -- Summary: Json format supports SE/DE null elements of ARRAY type field Key: FLINK-20234 URL: https://issues.apache.org/jira/browse/FLINK-20234 Project: Flink