[jira] [Created] (FLINK-38040) Documentation for VARIANT type and PARSE_JSON

Xuannan Su created FLINK-38040: -- Summary: Documentation for VARIANT type and PARSE_JSON Key: FLINK-38040 URL: https://issues.apache.org/jira/browse/FLINK-38040 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-37977) Variant implements Serializable

Xuannan Su created FLINK-37977: -- Summary: Variant implements Serializable Key: FLINK-37977 URL: https://issues.apache.org/jira/browse/FLINK-37977 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2

Xuannan Su created FLINK-37951: -- Summary: Enable VariantSerializerUpgradeTest in Flink 2.2 Key: FLINK-37951 URL: https://issues.apache.org/jira/browse/FLINK-37951 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-37926) Support type casting between variant and constructed type

Xuannan Su created FLINK-37926: -- Summary: Support type casting between variant and constructed type Key: FLINK-37926 URL: https://issues.apache.org/jira/browse/FLINK-37926 Project: Flink Issue T

[jira] [Created] (FLINK-37924) Support variant field accessing

Xuannan Su created FLINK-37924: -- Summary: Support variant field accessing Key: FLINK-37924 URL: https://issues.apache.org/jira/browse/FLINK-37924 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37925) Support type casting between variant and primitive type

Xuannan Su created FLINK-37925: -- Summary: Support type casting between variant and primitive type Key: FLINK-37925 URL: https://issues.apache.org/jira/browse/FLINK-37925 Project: Flink Issue Typ

[jira] [Created] (FLINK-37923) Introduce VARIANT type and PARSE_JSON to Flink SQL

Xuannan Su created FLINK-37923: -- Summary: Introduce VARIANT type and PARSE_JSON to Flink SQL Key: FLINK-37923 URL: https://issues.apache.org/jira/browse/FLINK-37923 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-37922) Integrating Variant Type into Flink

Xuannan Su created FLINK-37922: -- Summary: Integrating Variant Type into Flink Key: FLINK-37922 URL: https://issues.apache.org/jira/browse/FLINK-37922 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36811) MySQL CDC

Xuannan Su created FLINK-36811: -- Summary: MySQL CDC Key: FLINK-36811 URL: https://issues.apache.org/jira/browse/FLINK-36811 Project: Flink Issue Type: Improvement Components: Flink CDC

[jira] [Created] (FLINK-36437) Hive connector failed to compile with JDK 11

Xuannan Su created FLINK-36437: -- Summary: Hive connector failed to compile with JDK 11 Key: FLINK-36437 URL: https://issues.apache.org/jira/browse/FLINK-36437 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36311) Remove deprecated flink-formats config options

Xuannan Su created FLINK-36311: -- Summary: Remove deprecated flink-formats config options Key: FLINK-36311 URL: https://issues.apache.org/jira/browse/FLINK-36311 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-36308) Remove deprecated CEP config options

Xuannan Su created FLINK-36308: -- Summary: Remove deprecated CEP config options Key: FLINK-36308 URL: https://issues.apache.org/jira/browse/FLINK-36308 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36307) Remove deprecated config options

Xuannan Su created FLINK-36307: -- Summary: Remove deprecated config options Key: FLINK-36307 URL: https://issues.apache.org/jira/browse/FLINK-36307 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36305) Remove deprecated Table/SQL config options

Xuannan Su created FLINK-36305: -- Summary: Remove deprecated Table/SQL config options Key: FLINK-36305 URL: https://issues.apache.org/jira/browse/FLINK-36305 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36304) Remove deprecated Statebackend config options

Xuannan Su created FLINK-36304: -- Summary: Remove deprecated Statebackend config options Key: FLINK-36304 URL: https://issues.apache.org/jira/browse/FLINK-36304 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-35475) Introduce isInternalSorterSupport to OperatorAttributes

Xuannan Su created FLINK-35475: -- Summary: Introduce isInternalSorterSupport to OperatorAttributes Key: FLINK-35475 URL: https://issues.apache.org/jira/browse/FLINK-35475 Project: Flink Issue Typ

[jira] [Created] (FLINK-35461) Improve Runtime Configuration for Flink 2.0

Xuannan Su created FLINK-35461: -- Summary: Improve Runtime Configuration for Flink 2.0 Key: FLINK-35461 URL: https://issues.apache.org/jira/browse/FLINK-35461 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-35359) General Improvement to Configuration for Flink 2.0

Xuannan Su created FLINK-35359: -- Summary: General Improvement to Configuration for Flink 2.0 Key: FLINK-35359 URL: https://issues.apache.org/jira/browse/FLINK-35359 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-35089) Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes

Xuannan Su created FLINK-35089: -- Summary: Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes Key: FLINK-35089 URL: https://issues.apache.org/jira/browse/FLINK-35089 Project: F

[jira] [Created] (FLINK-34085) Remove deprecated string configuration keys in Flink 2.0

Xuannan Su created FLINK-34085: -- Summary: Remove deprecated string configuration keys in Flink 2.0 Key: FLINK-34085 URL: https://issues.apache.org/jira/browse/FLINK-34085 Project: Flink Issue Ty

[jira] [Created] (FLINK-34084) Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat

Xuannan Su created FLINK-34084: -- Summary: Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat Key: FLINK-34084 URL: https://issues.apache.org/jira/browse/FLINK-34084 Pro

[jira] [Created] (FLINK-34083) Deprecate string configuration keys and unused constants in ConfigConstants

Xuannan Su created FLINK-34083: -- Summary: Deprecate string configuration keys and unused constants in ConfigConstants Key: FLINK-34083 URL: https://issues.apache.org/jira/browse/FLINK-34083 Project: Flin

[jira] [Created] (FLINK-33890) Determine the initial status before receiving the first RecordAttributes

Xuannan Su created FLINK-33890: -- Summary: Determine the initial status before receiving the first RecordAttributes Key: FLINK-33890 URL: https://issues.apache.org/jira/browse/FLINK-33890 Project: Flink

[jira] [Created] (FLINK-33810) Propagate RecordAttributes that contains isProcessingBacklog status

Xuannan Su created FLINK-33810: -- Summary: Propagate RecordAttributes that contains isProcessingBacklog status Key: FLINK-33810 URL: https://issues.apache.org/jira/browse/FLINK-33810 Project: Flink

[jira] [Created] (FLINK-33399) Support switching from batch to stream mode for KeyedCoProcessOperator and IntervalJoinOperator

Xuannan Su created FLINK-33399: -- Summary: Support switching from batch to stream mode for KeyedCoProcessOperator and IntervalJoinOperator Key: FLINK-33399 URL: https://issues.apache.org/jira/browse/FLINK-33399

[jira] [Created] (FLINK-33398) Support switching from batch to stream mode for one input stream operator

Xuannan Su created FLINK-33398: -- Summary: Support switching from batch to stream mode for one input stream operator Key: FLINK-33398 URL: https://issues.apache.org/jira/browse/FLINK-33398 Project: Flink

[jira] [Created] (FLINK-33202) FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data

Xuannan Su created FLINK-33202: -- Summary: FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data Key: FLINK-33202 URL: https://issues.apache.org/jira/browse/FLINK-332

[jira] [Created] (FLINK-32476) Support configuring object-reuse for internal operators

Xuannan Su created FLINK-32476: -- Summary: Support configuring object-reuse for internal operators Key: FLINK-32476 URL: https://issues.apache.org/jira/browse/FLINK-32476 Project: Flink Issue Typ

[jira] [Created] (FLINK-32008) Protobuf format throws exception with Map datatype

Xuannan Su created FLINK-32008: -- Summary: Protobuf format throws exception with Map datatype Key: FLINK-32008 URL: https://issues.apache.org/jira/browse/FLINK-32008 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-31944) Protobuf format throw com.google.protobuf.InvalidProtocolBufferException

Xuannan Su created FLINK-31944: -- Summary: Protobuf format throw com.google.protobuf.InvalidProtocolBufferException Key: FLINK-31944 URL: https://issues.apache.org/jira/browse/FLINK-31944 Project: Flink

[jira] [Created] (FLINK-31943) Multiple t_env cause class loading problem

Xuannan Su created FLINK-31943: -- Summary: Multiple t_env cause class loading problem Key: FLINK-31943 URL: https://issues.apache.org/jira/browse/FLINK-31943 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30607) Table.to_pandas doesn't support Map type

Xuannan Su created FLINK-30607: -- Summary: Table.to_pandas doesn't support Map type Key: FLINK-30607 URL: https://issues.apache.org/jira/browse/FLINK-30607 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30258) PyFlink supports closing loop back server

Xuannan Su created FLINK-30258: -- Summary: PyFlink supports closing loop back server Key: FLINK-30258 URL: https://issues.apache.org/jira/browse/FLINK-30258 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30078) Temporal join should finish when the left table is bounded and finished

Xuannan Su created FLINK-30078: -- Summary: Temporal join should finish when the left table is bounded and finished Key: FLINK-30078 URL: https://issues.apache.org/jira/browse/FLINK-30078 Project: Flink

[jira] [Created] (FLINK-29951) Kafka SQL connector supports setting end offset/timestamp

Xuannan Su created FLINK-29951: -- Summary: Kafka SQL connector supports setting end offset/timestamp Key: FLINK-29951 URL: https://issues.apache.org/jira/browse/FLINK-29951 Project: Flink Issue T

[jira] [Created] (FLINK-29753) FileSource throws exception reading file with name that ends with xz

Xuannan Su created FLINK-29753: -- Summary: FileSource throws exception reading file with name that ends with xz Key: FLINK-29753 URL: https://issues.apache.org/jira/browse/FLINK-29753 Project: Flink

[jira] [Created] (FLINK-29231) PyFlink udtaf produces different results in the same sliding window

Xuannan Su created FLINK-29231: -- Summary: PyFlink udtaf produces different results in the same sliding window Key: FLINK-29231 URL: https://issues.apache.org/jira/browse/FLINK-29231 Project: Flink

[jira] [Created] (FLINK-28988) Incorrect result for filter after temporal join

Xuannan Su created FLINK-28988: -- Summary: Incorrect result for filter after temporal join Key: FLINK-28988 URL: https://issues.apache.org/jira/browse/FLINK-28988 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28964) Release Testing: Verify FLIP-205 Cache in DataStream for Batch Processing

Xuannan Su created FLINK-28964: -- Summary: Release Testing: Verify FLIP-205 Cache in DataStream for Batch Processing Key: FLINK-28964 URL: https://issues.apache.org/jira/browse/FLINK-28964 Project: Flink

[jira] [Created] (FLINK-28857) Add Document for DataStream Cache API

Xuannan Su created FLINK-28857: -- Summary: Add Document for DataStream Cache API Key: FLINK-28857 URL: https://issues.apache.org/jira/browse/FLINK-28857 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28742) Table.to_pandas fails with lit("xxx")

Xuannan Su created FLINK-28742: -- Summary: Table.to_pandas fails with lit("xxx") Key: FLINK-28742 URL: https://issues.apache.org/jira/browse/FLINK-28742 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-28528) Table.getSchema fails on table with watermark

Xuannan Su created FLINK-28528: -- Summary: Table.getSchema fails on table with watermark Key: FLINK-28528 URL: https://issues.apache.org/jira/browse/FLINK-28528 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28527) Fail to lateral join with UDTF from Table with timstamp column

Xuannan Su created FLINK-28527: -- Summary: Fail to lateral join with UDTF from Table with timstamp column Key: FLINK-28527 URL: https://issues.apache.org/jira/browse/FLINK-28527 Project: Flink I

[jira] [Created] (FLINK-28526) Fail to lateral join with UDTF from Table with timstamp column

Xuannan Su created FLINK-28526: -- Summary: Fail to lateral join with UDTF from Table with timstamp column Key: FLINK-28526 URL: https://issues.apache.org/jira/browse/FLINK-28526 Project: Flink I

[jira] [Created] (FLINK-28461) PyFlink Table should add get_resolved_schema method

Xuannan Su created FLINK-28461: -- Summary: PyFlink Table should add get_resolved_schema method Key: FLINK-28461 URL: https://issues.apache.org/jira/browse/FLINK-28461 Project: Flink Issue Type: I

[jira] [Created] (FLINK-28443) Provide official Flink image for PyFlink

Xuannan Su created FLINK-28443: -- Summary: Provide official Flink image for PyFlink Key: FLINK-28443 URL: https://issues.apache.org/jira/browse/FLINK-28443 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28126) Iteration gets stuck when replayable datastream and its downstream operator have different parallelism

Xuannan Su created FLINK-28126: -- Summary: Iteration gets stuck when replayable datastream and its downstream operator have different parallelism Key: FLINK-28126 URL: https://issues.apache.org/jira/browse/FLINK-28126

[jira] [Created] (FLINK-27524) Introduce cache API to DataStream

Xuannan Su created FLINK-27524: -- Summary: Introduce cache API to DataStream Key: FLINK-27524 URL: https://issues.apache.org/jira/browse/FLINK-27524 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27523) Runtime supports producing and consuming cached intermediate result

Xuannan Su created FLINK-27523: -- Summary: Runtime supports producing and consuming cached intermediate result Key: FLINK-27523 URL: https://issues.apache.org/jira/browse/FLINK-27523 Project: Flink

[jira] [Created] (FLINK-27521) FLIP-205: Support Cache in DataStream for Batch Processing

Xuannan Su created FLINK-27521: -- Summary: FLIP-205: Support Cache in DataStream for Batch Processing Key: FLINK-27521 URL: https://issues.apache.org/jira/browse/FLINK-27521 Project: Flink Issue

[jira] [Created] (FLINK-26171) pyFlink -py options has issue with path that starts with //

Xuannan Su created FLINK-26171: -- Summary: pyFlink -py options has issue with path that starts with // Key: FLINK-26171 URL: https://issues.apache.org/jira/browse/FLINK-26171 Project: Flink Issu

[jira] [Created] (FLINK-25685) RestClusterClient gets stuck on submitting job with local user artifact

Xuannan Su created FLINK-25685: -- Summary: RestClusterClient gets stuck on submitting job with local user artifact Key: FLINK-25685 URL: https://issues.apache.org/jira/browse/FLINK-25685 Project: Flink

[jira] [Created] (FLINK-20018) pipeline.cached-files option cannot escape ':' in path

Xuannan Su created FLINK-20018: -- Summary: pipeline.cached-files option cannot escape ':' in path Key: FLINK-20018 URL: https://issues.apache.org/jira/browse/FLINK-20018 Project: Flink Issue Type

[jira] [Created] (FLINK-19761) Add lookup method for registered ShuffleDescriptor in ShuffleMaster

Xuannan Su created FLINK-19761: -- Summary: Add lookup method for registered ShuffleDescriptor in ShuffleMaster Key: FLINK-19761 URL: https://issues.apache.org/jira/browse/FLINK-19761 Project: Flink

[jira] [Created] (FLINK-19669) PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method

Xuannan Su created FLINK-19669: -- Summary: PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check should use isBlocking method Key: FLINK-19669 URL: https://issues.apache.org/jira/browse/FLINK-19669

[jira] [Created] (FLINK-19476) Introduce CacheManager in CatalogManager to keep track of the ClusterPartitionDescriptor

Xuannan Su created FLINK-19476: -- Summary: Introduce CacheManager in CatalogManager to keep track of the ClusterPartitionDescriptor Key: FLINK-19476 URL: https://issues.apache.org/jira/browse/FLINK-19476

[jira] [Created] (FLINK-19354) Add invalidateCache() method in CachedTable

Xuannan Su created FLINK-19354: -- Summary: Add invalidateCache() method in CachedTable Key: FLINK-19354 URL: https://issues.apache.org/jira/browse/FLINK-19354 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19352) Add cache() method to Table

Xuannan Su created FLINK-19352: -- Summary: Add cache() method to Table Key: FLINK-19352 URL: https://issues.apache.org/jira/browse/FLINK-19352 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-19353) BlinkPlanner translate and optimize CacheOperation

Xuannan Su created FLINK-19353: -- Summary: BlinkPlanner translate and optimize CacheOperation Key: FLINK-19353 URL: https://issues.apache.org/jira/browse/FLINK-19353 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-19355) Add close() method to TableEnvironment

Xuannan Su created FLINK-19355: -- Summary: Add close() method to TableEnvironment Key: FLINK-19355 URL: https://issues.apache.org/jira/browse/FLINK-19355 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19350) StreamingJobGraphGenerator generate job graph with cached node

Xuannan Su created FLINK-19350: -- Summary: StreamingJobGraphGenerator generate job graph with cached node Key: FLINK-19350 URL: https://issues.apache.org/jira/browse/FLINK-19350 Project: Flink I

[jira] [Created] (FLINK-19351) StreamingJobGraphGenerator set the caching node to BoundedBlockingType

Xuannan Su created FLINK-19351: -- Summary: StreamingJobGraphGenerator set the caching node to BoundedBlockingType Key: FLINK-19351 URL: https://issues.apache.org/jira/browse/FLINK-19351 Project: Flink

[jira] [Created] (FLINK-19348) Introduce CacheSource and CacheSink

Xuannan Su created FLINK-19348: -- Summary: Introduce CacheSource and CacheSink Key: FLINK-19348 URL: https://issues.apache.org/jira/browse/FLINK-19348 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19349) StreamGraph handle CacheSource and CacheSink

Xuannan Su created FLINK-19349: -- Summary: StreamGraph handle CacheSource and CacheSink Key: FLINK-19349 URL: https://issues.apache.org/jira/browse/FLINK-19349 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19347) Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor

Xuannan Su created FLINK-19347: -- Summary: Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor Key: FLINK-19347 URL: https://issues.apache.org/jira/browse/FLINK-19347 P

[jira] [Created] (FLINK-19346) Generate and put ClusterPartitionDescriptor of ClusterPartition in JobResult when job finishes

Xuannan Su created FLINK-19346: -- Summary: Generate and put ClusterPartitionDescriptor of ClusterPartition in JobResult when job finishes Key: FLINK-19346 URL: https://issues.apache.org/jira/browse/FLINK-19346

[jira] [Created] (FLINK-19343) FLIP-36: Support Interactive Programming in Flink

Xuannan Su created FLINK-19343: -- Summary: FLIP-36: Support Interactive Programming in Flink Key: FLINK-19343 URL: https://issues.apache.org/jira/browse/FLINK-19343 Project: Flink Issue Type: New

[jira] [Created] (FLINK-18820) SourceOperator should send MAX_WATERMARK to downstream operator when closed

Xuannan Su created FLINK-18820: -- Summary: SourceOperator should send MAX_WATERMARK to downstream operator when closed Key: FLINK-18820 URL: https://issues.apache.org/jira/browse/FLINK-18820 Project: Flin

[jira] [Created] (FLINK-13576) Enable configuring IntermediateResultStorage with YAML

Xuannan Su created FLINK-13576: -- Summary: Enable configuring IntermediateResultStorage with YAML Key: FLINK-13576 URL: https://issues.apache.org/jira/browse/FLINK-13576 Project: Flink Issue Type

[jira] [Created] (FLINK-13575) Introduce IntermediateResultStorageDescriptor

Xuannan Su created FLINK-13575: -- Summary: Introduce IntermediateResultStorageDescriptor Key: FLINK-13575 URL: https://issues.apache.org/jira/browse/FLINK-13575 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-13574) Introduce IntermediateResultStorage Interface

Xuannan Su created FLINK-13574: -- Summary: Introduce IntermediateResultStorage Interface Key: FLINK-13574 URL: https://issues.apache.org/jira/browse/FLINK-13574 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-13572) Introduce Configurable, TableCreationHook and TableCleanupHook Interfaces

Xuannan Su created FLINK-13572: -- Summary: Introduce Configurable, TableCreationHook and TableCleanupHook Interfaces Key: FLINK-13572 URL: https://issues.apache.org/jira/browse/FLINK-13572 Project: Flink

[jira] [Created] (FLINK-13570) Pluggable Intermediate Result Storage

Xuannan Su created FLINK-13570: -- Summary: Pluggable Intermediate Result Storage Key: FLINK-13570 URL: https://issues.apache.org/jira/browse/FLINK-13570 Project: Flink Issue Type: New Feature