[jira] [Created] (FLINK-21909) Unify API and implementation for Hive and Filesystem source connector

Jark Wu created FLINK-21909: --- Summary: Unify API and implementation for Hive and Filesystem source connector Key: FLINK-21909 URL: https://issues.apache.org/jira/browse/FLINK-21909 Project: Flink

[jira] [Created] (FLINK-21908) Support HiveSource to emit watermarks which is extract from partition values

Jark Wu created FLINK-21908: --- Summary: Support HiveSource to emit watermarks which is extract from partition values Key: FLINK-21908 URL: https://issues.apache.org/jira/browse/FLINK-21908 Project: Flink

[jira] [Created] (FLINK-21907) Support watermark syntax for Hive DDL dialect

Jark Wu created FLINK-21907: --- Summary: Support watermark syntax for Hive DDL dialect Key: FLINK-21907 URL: https://issues.apache.org/jira/browse/FLINK-21907 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21906) Support computed column syntax for Hive DDL dialect

Jark Wu created FLINK-21906: --- Summary: Support computed column syntax for Hive DDL dialect Key: FLINK-21906 URL: https://issues.apache.org/jira/browse/FLINK-21906 Project: Flink Issue Type:

[jira] [Created] (FLINK-21905) Hive streaming source should use FIFO FileSplitAssigner instead of LIFO

Jark Wu created FLINK-21905: --- Summary: Hive streaming source should use FIFO FileSplitAssigner instead of LIFO Key: FLINK-21905 URL: https://issues.apache.org/jira/browse/FLINK-21905 Project: Flink

[jira] [Created] (FLINK-21904) parseJmJvmArgsAndExportLogs: command not found warning when starting StateFun

Tzu-Li (Gordon) Tai created FLINK-21904: --- Summary: parseJmJvmArgsAndExportLogs: command not found warning when starting StateFun Key: FLINK-21904 URL: https://issues.apache.org/jira/browse/FLINK-21904

[jira] [Created] (FLINK-21903) Translate "Importing Flink into an IDE" page into Chinese

zhaoxing created FLINK-21903: Summary: Translate "Importing Flink into an IDE" page into Chinese Key: FLINK-21903 URL: https://issues.apache.org/jira/browse/FLINK-21903 Project: Flink Issue

[jira] [Created] (FLINK-21902) A deadlock while using K8s HA service

Yi Tang created FLINK-21902: --- Summary: A deadlock while using K8s HA service Key: FLINK-21902 URL: https://issues.apache.org/jira/browse/FLINK-21902 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21901) Update StateFun version to 3.0-SNAPSHOT

Tzu-Li (Gordon) Tai created FLINK-21901: --- Summary: Update StateFun version to 3.0-SNAPSHOT Key: FLINK-21901 URL: https://issues.apache.org/jira/browse/FLINK-21901 Project: Flink Issue

[jira] [Created] (FLINK-21900) flink-statebackend-rocksdb test core dump

Guowei Ma created FLINK-21900: - Summary: flink-statebackend-rocksdb test core dump Key: FLINK-21900 URL: https://issues.apache.org/jira/browse/FLINK-21900 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21899) Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source

Jark Wu created FLINK-21899: --- Summary: Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source Key: FLINK-21899 URL: https://issues.apache.org/jira/browse/FLINK-21899 Project: Flink

[jira] [Created] (FLINK-21898) JobRetrievalITCase crash

Guowei Ma created FLINK-21898: - Summary: JobRetrievalITCase crash Key: FLINK-21898 URL: https://issues.apache.org/jira/browse/FLINK-21898 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-21897) CalcITCase.testPrimitiveMapType[StateBackend=HEAP] fail because of "Not enough resources available for scheduling"

Guowei Ma created FLINK-21897: - Summary: CalcITCase.testPrimitiveMapType[StateBackend=HEAP] fail because of "Not enough resources available for scheduling" Key: FLINK-21897 URL:

[jira] [Created] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail

Guowei Ma created FLINK-21896: - Summary: GroupAggregateJsonPlanTest.testDistinctAggCalls fail Key: FLINK-21896 URL: https://issues.apache.org/jira/browse/FLINK-21896 Project: Flink Issue Type:

[jira] [Created] (FLINK-21895) IncrementalAggregateJsonPlanTest.testIncrementalAggregate fail

Guowei Ma created FLINK-21895: - Summary: IncrementalAggregateJsonPlanTest.testIncrementalAggregate fail Key: FLINK-21895 URL: https://issues.apache.org/jira/browse/FLINK-21895 Project: Flink

[jira] [Created] (FLINK-21894) Update type of HiveTablePartition#partitionSpec from Map to Map

Jark Wu created FLINK-21894: --- Summary: Update type of HiveTablePartition#partitionSpec from Map to Map Key: FLINK-21894 URL: https://issues.apache.org/jira/browse/FLINK-21894 Project: Flink Issue

[jira] [Created] (FLINK-21893) A ValidationException will be thrown out when deriveRowType of Rank if partition key is an expression result of Input Node.

Andy created FLINK-21893: Summary: A ValidationException will be thrown out when deriveRowType of Rank if partition key is an expression result of Input Node. Key: FLINK-21893 URL:

[jira] [Created] (FLINK-21892) Add documentation for the DESC statement syntax

Jark Wu created FLINK-21892: --- Summary: Add documentation for the DESC statement syntax Key: FLINK-21892 URL: https://issues.apache.org/jira/browse/FLINK-21892 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21891) The .staging_xxx directory isn't deleted after writing data to hive table in batch mode

Re0 Beatrice created FLINK-21891: Summary: The .staging_xxx directory isn't deleted after writing data to hive table in batch mode Key: FLINK-21891 URL: https://issues.apache.org/jira/browse/FLINK-21891

[jira] [Created] (FLINK-21890) Rename DAGProcessor to ExecNodeGraphProcessor

godfrey he created FLINK-21890: -- Summary: Rename DAGProcessor to ExecNodeGraphProcessor Key: FLINK-21890 URL: https://issues.apache.org/jira/browse/FLINK-21890 Project: Flink Issue Type: