[jira] [Created] (FLINK-36946) optimize sink operator name truncate

tartarus created FLINK-36946: Summary: optimize sink operator name truncate Key: FLINK-36946 URL: https://issues.apache.org/jira/browse/FLINK-36946 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33050) Prompts user to close when atomicity implementation is not supported

tartarus created FLINK-33050: Summary: Prompts user to close when atomicity implementation is not supported Key: FLINK-33050 URL: https://issues.apache.org/jira/browse/FLINK-33050 Project: Flink

[jira] [Created] (FLINK-32581) Add document for atomic CTAS

tartarus created FLINK-32581: Summary: Add document for atomic CTAS Key: FLINK-32581 URL: https://issues.apache.org/jira/browse/FLINK-32581 Project: Flink Issue Type: Sub-task Reporte

[jira] [Created] (FLINK-32580) FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS)

tartarus created FLINK-32580: Summary: FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) Key: FLINK-32580 URL: https://issues.apache.org/jira/browse/FLINK-32580 Project: Flink Issue Type:

[jira] [Created] (FLINK-32349) Support atomic for CREATE TABLE AS SELECT(CTAS) statement

tartarus created FLINK-32349: Summary: Support atomic for CREATE TABLE AS SELECT(CTAS) statement Key: FLINK-32349 URL: https://issues.apache.org/jira/browse/FLINK-32349 Project: Flink Issue Type:

[jira] [Created] (FLINK-31721) Move JobStatusHook to flink-core module

tartarus created FLINK-31721: Summary: Move JobStatusHook to flink-core module Key: FLINK-31721 URL: https://issues.apache.org/jira/browse/FLINK-31721 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31655) Adaptive Channel selection for partitioner

tartarus created FLINK-31655: Summary: Adaptive Channel selection for partitioner Key: FLINK-31655 URL: https://issues.apache.org/jira/browse/FLINK-31655 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28770) CREATE TABLE AS SELECT supports explain

tartarus created FLINK-28770: Summary: CREATE TABLE AS SELECT supports explain Key: FLINK-28770 URL: https://issues.apache.org/jira/browse/FLINK-28770 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28720) Add Hive partition when flink has no data to write

tartarus created FLINK-28720: Summary: Add Hive partition when flink has no data to write Key: FLINK-28720 URL: https://issues.apache.org/jira/browse/FLINK-28720 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-28463) Flink SQL syntax support CREATE TABLE AS SELECT(CTAS)

tartarus created FLINK-28463: Summary: Flink SQL syntax support CREATE TABLE AS SELECT(CTAS) Key: FLINK-28463 URL: https://issues.apache.org/jira/browse/FLINK-28463 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-28462) Table API support CREATE TABLE AS SELECT(CTAS)

tartarus created FLINK-28462: Summary: Table API support CREATE TABLE AS SELECT(CTAS) Key: FLINK-28462 URL: https://issues.apache.org/jira/browse/FLINK-28462 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28460) Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS)

tartarus created FLINK-28460: Summary: Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS) Key: FLINK-28460 URL: https://issues.apache.org/jira/browse/FLINK-28460 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-28459) Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS)

tartarus created FLINK-28459: Summary: Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS) Key: FLINK-28459 URL: https://issues.apache.org/jira/browse/FLINK-28459 Project: Flink Issue Type

[jira] [Created] (FLINK-28457) Flink add JobStatusHook support

tartarus created FLINK-28457: Summary: Flink add JobStatusHook support Key: FLINK-28457 URL: https://issues.apache.org/jira/browse/FLINK-28457 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-28343) Hive dialect fails using union map type

tartarus created FLINK-28343: Summary: Hive dialect fails using union map type Key: FLINK-28343 URL: https://issues.apache.org/jira/browse/FLINK-28343 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28342) Flink batch support for Hive StorageHandlers

tartarus created FLINK-28342: Summary: Flink batch support for Hive StorageHandlers Key: FLINK-28342 URL: https://issues.apache.org/jira/browse/FLINK-28342 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28235) Min aggregate function support type: ''ARRAY''.

tartarus created FLINK-28235: Summary: Min aggregate function support type: ''ARRAY''. Key: FLINK-28235 URL: https://issues.apache.org/jira/browse/FLINK-28235 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28158) Flink supports all modes of Hive UDAF (PARTIAL1, PARTIAL2, FINAL, COMPLETE)

tartarus created FLINK-28158: Summary: Flink supports all modes of Hive UDAF (PARTIAL1, PARTIAL2, FINAL, COMPLETE) Key: FLINK-28158 URL: https://issues.apache.org/jira/browse/FLINK-28158 Project: Flink

[jira] [Created] (FLINK-27677) Kubernetes reuse rest.bind-port, but do not support a range of ports

tartarus created FLINK-27677: Summary: Kubernetes reuse rest.bind-port, but do not support a range of ports Key: FLINK-27677 URL: https://issues.apache.org/jira/browse/FLINK-27677 Project: Flink

[jira] [Created] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

tartarus created FLINK-27450: Summary: [JDK 11] Hive SessionState can't be initialized due to classloader problem Key: FLINK-27450 URL: https://issues.apache.org/jira/browse/FLINK-27450 Project: Flink

[jira] [Created] (FLINK-27391) Support Hive bucket table

tartarus created FLINK-27391: Summary: Support Hive bucket table Key: FLINK-27391 URL: https://issues.apache.org/jira/browse/FLINK-27391 Project: Flink Issue Type: Sub-task Affects Versions:

[jira] [Created] (FLINK-27387) Support Insert Multi-Table

tartarus created FLINK-27387: Summary: Support Insert Multi-Table Key: FLINK-27387 URL: https://issues.apache.org/jira/browse/FLINK-27387 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-27386) throw NPE if multi MAPJOIN hint union all

tartarus created FLINK-27386: Summary: throw NPE if multi MAPJOIN hint union all Key: FLINK-27386 URL: https://issues.apache.org/jira/browse/FLINK-27386 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27385) Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression index($0, 0)

tartarus created FLINK-27385: Summary: Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression index($0, 0) Key: FLINK-27385 URL: https://issues.apache.org/jira/browse/FLINK-27385 Project

[jira] [Created] (FLINK-27380) Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox

tartarus created FLINK-27380: Summary: Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox Key: FLINK-27380 URL: https://issues.apache.org/jira/browse/FLINK-27380

[jira] [Created] (FLINK-27379) CodeGenException: Unable to find common type of

tartarus created FLINK-27379: Summary: CodeGenException: Unable to find common type of Key: FLINK-27379 URL: https://issues.apache.org/jira/browse/FLINK-27379 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27378) Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess

tartarus created FLINK-27378: Summary: Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess Key: FLINK-27378 URL: https://issues.apache.org/jira/browse/FLINK-27378 Project: Flink Issue Type

[jira] [Created] (FLINK-27305) Hive Dialect support implicit conversion

tartarus created FLINK-27305: Summary: Hive Dialect support implicit conversion Key: FLINK-27305 URL: https://issues.apache.org/jira/browse/FLINK-27305 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27304) Flink doesn't support Hive primitive type void yet

tartarus created FLINK-27304: Summary: Flink doesn't support Hive primitive type void yet Key: FLINK-27304 URL: https://issues.apache.org/jira/browse/FLINK-27304 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected

tartarus created FLINK-27296: Summary: CalcOperator CodeGenException: Boolean expression type expected Key: FLINK-27296 URL: https://issues.apache.org/jira/browse/FLINK-27296 Project: Flink Issu

[jira] [Created] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS)

tartarus created FLINK-26942: Summary: Support SELECT clause in CREATE TABLE(CTAS) Key: FLINK-26942 URL: https://issues.apache.org/jira/browse/FLINK-26942 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

tartarus created FLINK-26460: Summary: Fix Unsupported type when convertTypeToSpec: MAP Key: FLINK-26460 URL: https://issues.apache.org/jira/browse/FLINK-26460 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25204) Spell one more as in the DataStream interval join docs

tartarus created FLINK-25204: Summary: Spell one more as in the DataStream interval join docs Key: FLINK-25204 URL: https://issues.apache.org/jira/browse/FLINK-25204 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-24761) Fix PartitionPruner code gen compile fail

tartarus created FLINK-24761: Summary: Fix PartitionPruner code gen compile fail Key: FLINK-24761 URL: https://issues.apache.org/jira/browse/FLINK-24761 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-23715) Support for reading fields that do not exist in Parquet files

tartarus created FLINK-23715: Summary: Support for reading fields that do not exist in Parquet files Key: FLINK-23715 URL: https://issues.apache.org/jira/browse/FLINK-23715 Project: Flink Issue

[jira] [Created] (FLINK-23531) Allow skip everytime change log for row-time deduplicate mini-batch

tartarus created FLINK-23531: Summary: Allow skip everytime change log for row-time deduplicate mini-batch Key: FLINK-23531 URL: https://issues.apache.org/jira/browse/FLINK-23531 Project: Flink

[jira] [Created] (FLINK-23425) The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup

tartarus created FLINK-23425: Summary: The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup Key: FLINK-23425 URL: https://issues.

[jira] [Created] (FLINK-23134) add URL decode for metric rest

tartarus created FLINK-23134: Summary: add URL decode for metric rest Key: FLINK-23134 URL: https://issues.apache.org/jira/browse/FLINK-23134 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-22716) Add metrics watermarkAlignedChannelNum

tartarus created FLINK-22716: Summary: Add metrics watermarkAlignedChannelNum Key: FLINK-22716 URL: https://issues.apache.org/jira/browse/FLINK-22716 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

tartarus created FLINK-22455: Summary: FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse Key: FLINK-22455 URL: https://issues.apache.org/jira/browse/FLINK-22455 Project: Fl

[jira] [Created] (FLINK-22412) SplitAggregateRule support optimization of aggregate function reuse

tartarus created FLINK-22412: Summary: SplitAggregateRule support optimization of aggregate function reuse Key: FLINK-22412 URL: https://issues.apache.org/jira/browse/FLINK-22412 Project: Flink

[jira] [Created] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

tartarus created FLINK-21923: Summary: SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time Key: FLINK-21923 URL: https://issues.apache.org/jira/browse/FLINK-21923 Proje

[jira] [Created] (FLINK-19022) AkkaRpcActor failed to start but no exception information

tartarus created FLINK-19022: Summary: AkkaRpcActor failed to start but no exception information Key: FLINK-19022 URL: https://issues.apache.org/jira/browse/FLINK-19022 Project: Flink Issue Type:

[jira] [Created] (FLINK-18663) Fix Flink On YARN AM not exit

tartarus created FLINK-18663: Summary: Fix Flink On YARN AM not exit Key: FLINK-18663 URL: https://issues.apache.org/jira/browse/FLINK-18663 Project: Flink Issue Type: Bug Components: R

[jira] [Created] (FLINK-18638) FutureUtils support timeout message

tartarus created FLINK-18638: Summary: FutureUtils support timeout message Key: FLINK-18638 URL: https://issues.apache.org/jira/browse/FLINK-18638 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18636) Asynchronous close via configurable timeout in seconds for CompletedOperationCache

tartarus created FLINK-18636: Summary: Asynchronous close via configurable timeout in seconds for CompletedOperationCache Key: FLINK-18636 URL: https://issues.apache.org/jira/browse/FLINK-18636 Project: F

[jira] [Created] (FLINK-18332) Add error message to precondition in KeyGroupPartitionedPriorityQueue

tartarus created FLINK-18332: Summary: Add error message to precondition in KeyGroupPartitionedPriorityQueue Key: FLINK-18332 URL: https://issues.apache.org/jira/browse/FLINK-18332 Project: Flink