[jira] [Created] (FLINK-32315) Support local file upload in K8s mode

Paul Lin created FLINK-32315: Summary: Support local file upload in K8s mode Key: FLINK-32315 URL: https://issues.apache.org/jira/browse/FLINK-32315 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-32143) Automatic cleanup of terminated flinkdeployments

Paul Lin created FLINK-32143: Summary: Automatic cleanup of terminated flinkdeployments Key: FLINK-32143 URL: https://issues.apache.org/jira/browse/FLINK-32143 Project: Flink Issue Type: New Feat

[jira] [Created] (FLINK-31965) Fix ClassNotFoundException in benchmarks

Paul Lin created FLINK-31965: Summary: Fix ClassNotFoundException in benchmarks Key: FLINK-31965 URL: https://issues.apache.org/jira/browse/FLINK-31965 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-30538) Improve error handling of stop job operation

Paul Lin created FLINK-30538: Summary: Improve error handling of stop job operation Key: FLINK-30538 URL: https://issues.apache.org/jira/browse/FLINK-30538 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28685) Optimize CatalogManager getTable implementation

Paul Lin created FLINK-28685: Summary: Optimize CatalogManager getTable implementation Key: FLINK-28685 URL: https://issues.apache.org/jira/browse/FLINK-28685 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-28658) Add document for job lifecycle statements

Paul Lin created FLINK-28658: Summary: Add document for job lifecycle statements Key: FLINK-28658 URL: https://issues.apache.org/jira/browse/FLINK-28658 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28657) Support drop savepoint statement in SqlGatewayService

Paul Lin created FLINK-28657: Summary: Support drop savepoint statement in SqlGatewayService Key: FLINK-28657 URL: https://issues.apache.org/jira/browse/FLINK-28657 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-28656) Support savepoint statements in SqlGatewayService

Paul Lin created FLINK-28656: Summary: Support savepoint statements in SqlGatewayService Key: FLINK-28656 URL: https://issues.apache.org/jira/browse/FLINK-28656 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-28655) Support show jobs statement in SqlGatewatService

Paul Lin created FLINK-28655: Summary: Support show jobs statement in SqlGatewatService Key: FLINK-28655 URL: https://issues.apache.org/jira/browse/FLINK-28655 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28617) Support stop job statement in SqlGatewayService

Paul Lin created FLINK-28617: Summary: Support stop job statement in SqlGatewayService Key: FLINK-28617 URL: https://issues.apache.org/jira/browse/FLINK-28617 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28391) DefaultBlocklistHandlerTest unstable

Paul Lin created FLINK-28391: Summary: DefaultBlocklistHandlerTest unstable Key: FLINK-28391 URL: https://issues.apache.org/jira/browse/FLINK-28391 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-28363) Support drop savepoint statement in SQL client

Paul Lin created FLINK-28363: Summary: Support drop savepoint statement in SQL client Key: FLINK-28363 URL: https://issues.apache.org/jira/browse/FLINK-28363 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28362) Support savepoint statements in SQL client

Paul Lin created FLINK-28362: Summary: Support savepoint statements in SQL client Key: FLINK-28362 URL: https://issues.apache.org/jira/browse/FLINK-28362 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28361) Support show jobs operation in SQL client

Paul Lin created FLINK-28361: Summary: Support show jobs operation in SQL client Key: FLINK-28361 URL: https://issues.apache.org/jira/browse/FLINK-28361 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28360) Support stop job operation in SQL client

Paul Lin created FLINK-28360: Summary: Support stop job operation in SQL client Key: FLINK-28360 URL: https://issues.apache.org/jira/browse/FLINK-28360 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27585) JdbcOutpuFormat fails to flush data on checkpoint and causes data loss

Paul Lin created FLINK-27585: Summary: JdbcOutpuFormat fails to flush data on checkpoint and causes data loss Key: FLINK-27585 URL: https://issues.apache.org/jira/browse/FLINK-27585 Project: Flink

[jira] [Created] (FLINK-27344) FLIP-222: Support full query lifecycle statements in SQL client

Paul Lin created FLINK-27344: Summary: FLIP-222: Support full query lifecycle statements in SQL client Key: FLINK-27344 URL: https://issues.apache.org/jira/browse/FLINK-27344 Project: Flink Issu

[jira] [Created] (FLINK-26720) Support stop-with-savepoint on web UI

Paul Lin created FLINK-26720: Summary: Support stop-with-savepoint on web UI Key: FLINK-26720 URL: https://issues.apache.org/jira/browse/FLINK-26720 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

Paul Lin created FLINK-26618: Summary: Remove jar statement not aligned with pipleline.jars Key: FLINK-26618 URL: https://issues.apache.org/jira/browse/FLINK-26618 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25558) TableResult OK may be empty if returned by multiple queries

Paul Lin created FLINK-25558: Summary: TableResult OK may be empty if returned by multiple queries Key: FLINK-25558 URL: https://issues.apache.org/jira/browse/FLINK-25558 Project: Flink Issue Ty

[jira] [Created] (FLINK-24948) Special character in column names breaks JDBC statement parsing

Paul Lin created FLINK-24948: Summary: Special character in column names breaks JDBC statement parsing Key: FLINK-24948 URL: https://issues.apache.org/jira/browse/FLINK-24948 Project: Flink Issu

[jira] [Created] (FLINK-24628) Invalid JDBC query template when no fields are selected

Paul Lin created FLINK-24628: Summary: Invalid JDBC query template when no fields are selected Key: FLINK-24628 URL: https://issues.apache.org/jira/browse/FLINK-24628 Project: Flink Issue Type: B

[jira] [Created] (FLINK-24319) Jar not found in ClassLoaderITCase

Paul Lin created FLINK-24319: Summary: Jar not found in ClassLoaderITCase Key: FLINK-24319 URL: https://issues.apache.org/jira/browse/FLINK-24319 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

Paul Lin created FLINK-23868: Summary: JobExecutionResult printed event if suppressSysout is on Key: FLINK-23868 URL: https://issues.apache.org/jira/browse/FLINK-23868 Project: Flink Issue Type:

[jira] [Created] (FLINK-23727) Skip null values in SimpleStringSchema

Paul Lin created FLINK-23727: Summary: Skip null values in SimpleStringSchema Key: FLINK-23727 URL: https://issues.apache.org/jira/browse/FLINK-23727 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-23703) Support unrecoverable exception class list in configuration

Paul Lin created FLINK-23703: Summary: Support unrecoverable exception class list in configuration Key: FLINK-23703 URL: https://issues.apache.org/jira/browse/FLINK-23703 Project: Flink Issue Ty

[jira] [Created] (FLINK-23700) Add `since` field to configuration options

Paul Lin created FLINK-23700: Summary: Add `since` field to configuration options Key: FLINK-23700 URL: https://issues.apache.org/jira/browse/FLINK-23700 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

Paul Lin created FLINK-22506: Summary: YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted Key: FLINK-22506 URL: https://issues.apache.org/jira/browse/FLINK-22506 Project: Fli

[jira] [Created] (FLINK-21251) Last valid checkpoint metadata lost after job exits restart loop

Paul Lin created FLINK-21251: Summary: Last valid checkpoint metadata lost after job exits restart loop Key: FLINK-21251 URL: https://issues.apache.org/jira/browse/FLINK-21251 Project: Flink Iss

[jira] [Created] (FLINK-20997) YarnTestBaseTest fails due to NPE

Paul Lin created FLINK-20997: Summary: YarnTestBaseTest fails due to NPE Key: FLINK-20997 URL: https://issues.apache.org/jira/browse/FLINK-20997 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-20918) Avoid excessive flush of Hadoop output stream

Paul Lin created FLINK-20918: Summary: Avoid excessive flush of Hadoop output stream Key: FLINK-20918 URL: https://issues.apache.org/jira/browse/FLINK-20918 Project: Flink Issue Type: Bug Aff

[jira] [Created] (FLINK-20185) Containerized environment variables may be misinterpreted in launch script

Paul Lin created FLINK-20185: Summary: Containerized environment variables may be misinterpreted in launch script Key: FLINK-20185 URL: https://issues.apache.org/jira/browse/FLINK-20185 Project: Flink

[jira] [Created] (FLINK-19778) Failed job reinitiated with wrong checkpoint after a ZK reconnection

Paul Lin created FLINK-19778: Summary: Failed job reinitiated with wrong checkpoint after a ZK reconnection Key: FLINK-19778 URL: https://issues.apache.org/jira/browse/FLINK-19778 Project: Flink

[jira] [Created] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

Paul Lin created FLINK-19198: Summary: Invalid default value for consume-start-offset in Hive streaming Key: FLINK-19198 URL: https://issues.apache.org/jira/browse/FLINK-19198 Project: Flink Iss

[jira] [Created] (FLINK-18542) GPUDiscoveryScriptTest fails for permission denied

Paul Lin created FLINK-18542: Summary: GPUDiscoveryScriptTest fails for permission denied Key: FLINK-18542 URL: https://issues.apache.org/jira/browse/FLINK-18542 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17403) Fix invalid classpath in BashJavaUtilsITCase

Paul Lin created FLINK-17403: Summary: Fix invalid classpath in BashJavaUtilsITCase Key: FLINK-17403 URL: https://issues.apache.org/jira/browse/FLINK-17403 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17091) AvroRowSerializationSchema doesn't support new Timestamp conversion classes

Paul Lin created FLINK-17091: Summary: AvroRowSerializationSchema doesn't support new Timestamp conversion classes Key: FLINK-17091 URL: https://issues.apache.org/jira/browse/FLINK-17091 Project: Flink

[jira] [Created] (FLINK-16693) Legacy planner incompatible with Timestamp backed by LocalDateTime

Paul Lin created FLINK-16693: Summary: Legacy planner incompatible with Timestamp backed by LocalDateTime Key: FLINK-16693 URL: https://issues.apache.org/jira/browse/FLINK-16693 Project: Flink I

[jira] [Created] (FLINK-15872) Remove unnecessary code in InputFormat

Paul Lin created FLINK-15872: Summary: Remove unnecessary code in InputFormat Key: FLINK-15872 URL: https://issues.apache.org/jira/browse/FLINK-15872 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15560) Timestamp literal support for startFromTimestamp in KafkaTableSource

Paul Lin created FLINK-15560: Summary: Timestamp literal support for startFromTimestamp in KafkaTableSource Key: FLINK-15560 URL: https://issues.apache.org/jira/browse/FLINK-15560 Project: Flink

[jira] [Created] (FLINK-15220) Add startFromTimestamp in KafkaTableSource

Paul Lin created FLINK-15220: Summary: Add startFromTimestamp in KafkaTableSource Key: FLINK-15220 URL: https://issues.apache.org/jira/browse/FLINK-15220 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14242) Collapse task names in job graph visualization if too long

Paul Lin created FLINK-14242: Summary: Collapse task names in job graph visualization if too long Key: FLINK-14242 URL: https://issues.apache.org/jira/browse/FLINK-14242 Project: Flink Issue Type

[jira] [Created] (FLINK-14207) YarnMiniCluster failed to start in YARNSessionFIFOSecuredITCase

Paul Lin created FLINK-14207: Summary: YarnMiniCluster failed to start in YARNSessionFIFOSecuredITCase Key: FLINK-14207 URL: https://issues.apache.org/jira/browse/FLINK-14207 Project: Flink Issu

[jira] [Created] (FLINK-13829) Incorrect doc version of 1.9 docs

Paul Lin created FLINK-13829: Summary: Incorrect doc version of 1.9 docs Key: FLINK-13829 URL: https://issues.apache.org/jira/browse/FLINK-13829 Project: Flink Issue Type: Task Componen

[jira] [Created] (FLINK-13749) Make Flink client respect classloading policy

Paul Lin created FLINK-13749: Summary: Make Flink client respect classloading policy Key: FLINK-13749 URL: https://issues.apache.org/jira/browse/FLINK-13749 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12741) Update docs about Kafka fault tolerant guarantees

Paul Lin created FLINK-12741: Summary: Update docs about Kafka fault tolerant guarantees Key: FLINK-12741 URL: https://issues.apache.org/jira/browse/FLINK-12741 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-12356) Optimise version experssion of flink-shaded-hadoop2(-uber)

Paul Lin created FLINK-12356: Summary: Optimise version experssion of flink-shaded-hadoop2(-uber) Key: FLINK-12356 URL: https://issues.apache.org/jira/browse/FLINK-12356 Project: Flink Issue Type

[jira] [Created] (FLINK-12042) RocksDBStateBackend mistakenly uses default filesystem

Paul Lin created FLINK-12042: Summary: RocksDBStateBackend mistakenly uses default filesystem Key: FLINK-12042 URL: https://issues.apache.org/jira/browse/FLINK-12042 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-12022) Enable StreamWriter to update file length on sync flush

Paul Lin created FLINK-12022: Summary: Enable StreamWriter to update file length on sync flush Key: FLINK-12022 URL: https://issues.apache.org/jira/browse/FLINK-12022 Project: Flink Issue Type: I

[jira] [Created] (FLINK-11135) Reduce priority of the deprecated Hadoop specific Flink conf options

Paul Lin created FLINK-11135: Summary: Reduce priority of the deprecated Hadoop specific Flink conf options Key: FLINK-11135 URL: https://issues.apache.org/jira/browse/FLINK-11135 Project: Flink

[jira] [Created] (FLINK-11126) Filter out AMRMToken in the TaskManager credentials

Paul Lin created FLINK-11126: Summary: Filter out AMRMToken in the TaskManager credentials Key: FLINK-11126 URL: https://issues.apache.org/jira/browse/FLINK-11126 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-10943) Flink runtime test failed caused by curator dependency conflicts

Paul Lin created FLINK-10943: Summary: Flink runtime test failed caused by curator dependency conflicts Key: FLINK-10943 URL: https://issues.apache.org/jira/browse/FLINK-10943 Project: Flink Iss

[jira] [Created] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

Paul Lin created FLINK-10680: Summary: Unable to set negative offsets for TumblingEventTimeWindow Key: FLINK-10680 URL: https://issues.apache.org/jira/browse/FLINK-10680 Project: Flink Issue Type

[jira] [Created] (FLINK-10601) Make user home dir consistent with Flink default filesystem

Paul Lin created FLINK-10601: Summary: Make user home dir consistent with Flink default filesystem Key: FLINK-10601 URL: https://issues.apache.org/jira/browse/FLINK-10601 Project: Flink Issue Ty

[jira] [Created] (FLINK-10224) Web frontend does not handle scientific notation properly

Paul Lin created FLINK-10224: Summary: Web frontend does not handle scientific notation properly Key: FLINK-10224 URL: https://issues.apache.org/jira/browse/FLINK-10224 Project: Flink Issue Type:

[jira] [Created] (FLINK-10218) Allow write DataSet without path parameter

Paul Lin created FLINK-10218: Summary: Allow write DataSet without path parameter Key: FLINK-10218 URL: https://issues.apache.org/jira/browse/FLINK-10218 Project: Flink Issue Type: Improvement