[jira] [Created] (FLINK-35795) FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

2024-07-09 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-35795: --- Summary: FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2 Key: FLINK-35795 URL: https://issues.apache.org/jira/browse/FLINK-35795 Project: Flink

[jira] [Created] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-07-05 Thread Liu Liu (Jira)
Liu Liu created FLINK-35764: --- Summary: TimerGauge is incorrect when update is called during a measurement Key: FLINK-35764 URL: https://issues.apache.org/jira/browse/FLINK-35764 Project: Flink

[jira] [Created] (FLINK-35546) Elasticsearch 8 connector fails fast for non-retryable bulk request items

2024-06-07 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35546: - Summary: Elasticsearch 8 connector fails fast for non-retryable bulk request items Key: FLINK-35546 URL: https://issues.apache.org/jira/browse/FLINK-35546 Project:

[jira] [Created] (FLINK-35504) Improve Elasticsearch 8 connector observability

2024-06-01 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35504: - Summary: Improve Elasticsearch 8 connector observability Key: FLINK-35504 URL: https://issues.apache.org/jira/browse/FLINK-35504 Project: Flink Issue

[jira] [Created] (FLINK-35472) Improve tests for Elasticsearch 8 connector

2024-05-28 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35472: - Summary: Improve tests for Elasticsearch 8 connector Key: FLINK-35472 URL: https://issues.apache.org/jira/browse/FLINK-35472 Project: Flink Issue Type:

[jira] [Created] (FLINK-35424) Elasticsearch connector 8 supports SSL context

2024-05-22 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35424: - Summary: Elasticsearch connector 8 supports SSL context Key: FLINK-35424 URL: https://issues.apache.org/jira/browse/FLINK-35424 Project: Flink Issue Type:

[jira] [Created] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8

2024-05-03 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35287: - Summary: Builder builds NetworkConfig for Elasticsearch connector 8 Key: FLINK-35287 URL: https://issues.apache.org/jira/browse/FLINK-35287 Project: Flink

[jira] [Created] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser

2024-04-24 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-35221: --- Summary: Support SQL 2011 reserved keywords as identifiers in Flink HiveParser Key: FLINK-35221 URL: https://issues.apache.org/jira/browse/FLINK-35221 Project: Flink

[jira] [Created] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor

2024-04-17 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35148: - Summary: Improve InstantiationUtil for checking nullary public constructor Key: FLINK-35148 URL: https://issues.apache.org/jira/browse/FLINK-35148 Project: Flink

[jira] [Created] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

2024-03-08 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34632: - Summary: Log checkpoint Id when logging checkpoint processing delay Key: FLINK-34632 URL: https://issues.apache.org/jira/browse/FLINK-34632 Project: Flink

[jira] [Created] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-02-28 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-34543: --- Summary: Support Full Partition Processing On Non-keyed DataStream Key: FLINK-34543 URL: https://issues.apache.org/jira/browse/FLINK-34543 Project: Flink

[jira] [Created] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-34376: - Summary: FLINK SQL SUM() causes a precision error Key: FLINK-34376 URL: https://issues.apache.org/jira/browse/FLINK-34376 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34369) Elasticsearch connector supports SSL provider

2024-02-05 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34369: - Summary: Elasticsearch connector supports SSL provider Key: FLINK-34369 URL: https://issues.apache.org/jira/browse/FLINK-34369 Project: Flink Issue Type:

[jira] [Created] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception

2024-01-26 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34251: - Summary: ClosureCleaner to include reference classes for non-serialization exception Key: FLINK-34251 URL: https://issues.apache.org/jira/browse/FLINK-34251

[jira] [Created] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-26 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33949: --- Summary: METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible Key: FLINK-33949 URL: https://issues.apache.org/jira/browse/FLINK-33949

[jira] [Created] (FLINK-33905) FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

2023-12-20 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33905: --- Summary: FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs Key: FLINK-33905 URL: https://issues.apache.org/jira/browse/FLINK-33905 Project: Flink

[jira] [Created] (FLINK-33785) TableJdbcUpsertOutputFormat could not deal with DELETE record correctly when primary keys were set

2023-12-08 Thread Bodong Liu (Jira)
Bodong Liu created FLINK-33785: -- Summary: TableJdbcUpsertOutputFormat could not deal with DELETE record correctly when primary keys were set Key: FLINK-33785 URL: https://issues.apache.org/jira/browse/FLINK-33785

[jira] [Created] (FLINK-33569) Could not deploy yarn-application when using yarn over s3a filesystem.

2023-11-16 Thread Bodong Liu (Jira)
Bodong Liu created FLINK-33569: -- Summary: Could not deploy yarn-application when using yarn over s3a filesystem. Key: FLINK-33569 URL: https://issues.apache.org/jira/browse/FLINK-33569 Project: Flink

[jira] [Created] (FLINK-33445) Translate DataSet migration guideline to Chinese

2023-11-02 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33445: --- Summary: Translate DataSet migration guideline to Chinese Key: FLINK-33445 URL: https://issues.apache.org/jira/browse/FLINK-33445 Project: Flink Issue Type:

[jira] [Created] (FLINK-33144) Deprecate Iteration API in DataStream

2023-09-24 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33144: --- Summary: Deprecate Iteration API in DataStream Key: FLINK-33144 URL: https://issues.apache.org/jira/browse/FLINK-33144 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-33079) The gap between the checkpoint timeout and the interval settings is too large

2023-09-13 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-33079: - Summary: The gap between the checkpoint timeout and the interval settings is too large Key: FLINK-33079 URL: https://issues.apache.org/jira/browse/FLINK-33079

[jira] [Created] (FLINK-33041) Add an introduction about how to migrate DataSet API to DataStream

2023-09-05 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33041: --- Summary: Add an introduction about how to migrate DataSet API to DataStream Key: FLINK-33041 URL: https://issues.apache.org/jira/browse/FLINK-33041 Project: Flink

[jira] [Created] (FLINK-32979) Deprecate WindowAssigner#getDefaultTrigger(StreamExecutionEnvironment env)

2023-08-28 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32979: --- Summary: Deprecate WindowAssigner#getDefaultTrigger(StreamExecutionEnvironment env) Key: FLINK-32979 URL: https://issues.apache.org/jira/browse/FLINK-32979 Project:

[jira] [Created] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2023-08-28 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32978: --- Summary: Deprecate RichFunction#open(Configuration parameters) Key: FLINK-32978 URL: https://issues.apache.org/jira/browse/FLINK-32978 Project: Flink Issue

[jira] [Created] (FLINK-32770) Fix the inaccurate backlog number of Hybrid Shuffle

2023-08-07 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32770: --- Summary: Fix the inaccurate backlog number of Hybrid Shuffle Key: FLINK-32770 URL: https://issues.apache.org/jira/browse/FLINK-32770 Project: Flink Issue

[jira] [Created] (FLINK-32742) Remove flink-examples-batch module

2023-08-03 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32742: --- Summary: Remove flink-examples-batch module Key: FLINK-32742 URL: https://issues.apache.org/jira/browse/FLINK-32742 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-32741) Remove DataSet related descriptions in doc

2023-08-03 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32741: --- Summary: Remove DataSet related descriptions in doc Key: FLINK-32741 URL: https://issues.apache.org/jira/browse/FLINK-32741 Project: Flink Issue Type:

[jira] [Created] (FLINK-32708) Fix the write logic in remote tier of hybrid shuffle

2023-07-27 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32708: --- Summary: Fix the write logic in remote tier of hybrid shuffle Key: FLINK-32708 URL: https://issues.apache.org/jira/browse/FLINK-32708 Project: Flink Issue

[jira] [Created] (FLINK-32593) DelimitedInputFormat will cause record loss for multi-bytes delimit when a delimit is seperated to two splits

2023-07-14 Thread Zhaofu Liu (Jira)
Zhaofu Liu created FLINK-32593: -- Summary: DelimitedInputFormat will cause record loss for multi-bytes delimit when a delimit is seperated to two splits Key: FLINK-32593 URL:

[jira] [Created] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

2023-05-19 Thread Liu (Jira)
Liu created FLINK-32133: --- Summary: Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers Key: FLINK-32133 URL: https://issues.apache.org/jira/browse/FLINK-32133

[jira] [Created] (FLINK-32121) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

2023-05-17 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32121: --- Summary: Avro Confluent Schema Registry nightly end-to-end test failed due to timeout Key: FLINK-32121 URL: https://issues.apache.org/jira/browse/FLINK-32121 Project:

[jira] [Created] (FLINK-32066) Flink Ci service on Azure stops responding to pull requests

2023-05-12 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32066: --- Summary: Flink Ci service on Azure stops responding to pull requests Key: FLINK-32066 URL: https://issues.apache.org/jira/browse/FLINK-32066 Project: Flink

[jira] [Created] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

2023-05-06 Thread Liu (Jira)
Liu created FLINK-32023: --- Summary: execution.buffer-timeout cannot be set to -1 ms Key: FLINK-32023 URL: https://issues.apache.org/jira/browse/FLINK-32023 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31984) Savepoint on S3 should be relocatable if entropy injection is not effective

2023-05-02 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-31984: - Summary: Savepoint on S3 should be relocatable if entropy injection is not effective Key: FLINK-31984 URL: https://issues.apache.org/jira/browse/FLINK-31984

[jira] [Created] (FLINK-31841) Redundant local variables in AllWindowedStream#reduce

2023-04-18 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-31841: --- Summary: Redundant local variables in AllWindowedStream#reduce Key: FLINK-31841 URL: https://issues.apache.org/jira/browse/FLINK-31841 Project: Flink Issue

[jira] [Created] (FLINK-31463) When I use apache flink1.12.2 version, the following akka error often occurs.

2023-03-15 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-31463: --- Summary: When I use apache flink1.12.2 version, the following akka error often occurs. Key: FLINK-31463 URL: https://issues.apache.org/jira/browse/FLINK-31463 Project:

[jira] [Created] (FLINK-31357) A record is deleted before being inserted, it will be deleted

2023-03-07 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-31357: - Summary: A record is deleted before being inserted, it will be deleted Key: FLINK-31357 URL: https://issues.apache.org/jira/browse/FLINK-31357 Project: Flink

[jira] [Created] (FLINK-31124) Add it case for HiveTableSink speculative execution

2023-02-17 Thread Biao Liu (Jira)
Biao Liu created FLINK-31124: Summary: Add it case for HiveTableSink speculative execution Key: FLINK-31124 URL: https://issues.apache.org/jira/browse/FLINK-31124 Project: Flink Issue Type:

[jira] [Created] (FLINK-31123) Add it case for FileSink speculative execution

2023-02-17 Thread Biao Liu (Jira)
Biao Liu created FLINK-31123: Summary: Add it case for FileSink speculative execution Key: FLINK-31123 URL: https://issues.apache.org/jira/browse/FLINK-31123 Project: Flink Issue Type:

[jira] [Created] (FLINK-31110) Web UI shows "User Configuration" preserving lines and whitespaces

2023-02-16 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-31110: - Summary: Web UI shows "User Configuration" preserving lines and whitespaces Key: FLINK-31110 URL: https://issues.apache.org/jira/browse/FLINK-31110 Project: Flink

[jira] [Created] (FLINK-30842) Add document for sink supports speculative execution

2023-01-30 Thread Biao Liu (Jira)
Biao Liu created FLINK-30842: Summary: Add document for sink supports speculative execution Key: FLINK-30842 URL: https://issues.apache.org/jira/browse/FLINK-30842 Project: Flink Issue Type:

[jira] [Created] (FLINK-30823) Enable speculative execution for some of the typical built-in sinks

2023-01-30 Thread Biao Liu (Jira)
Biao Liu created FLINK-30823: Summary: Enable speculative execution for some of the typical built-in sinks Key: FLINK-30823 URL: https://issues.apache.org/jira/browse/FLINK-30823 Project: Flink

[jira] [Created] (FLINK-30799) Make SinkFunction support speculative execution for batch jobs

2023-01-26 Thread Biao Liu (Jira)
Biao Liu created FLINK-30799: Summary: Make SinkFunction support speculative execution for batch jobs Key: FLINK-30799 URL: https://issues.apache.org/jira/browse/FLINK-30799 Project: Flink

[jira] [Created] (FLINK-30798) Make OutputFormat support speculative execution for batch jobs

2023-01-26 Thread Biao Liu (Jira)
Biao Liu created FLINK-30798: Summary: Make OutputFormat support speculative execution for batch jobs Key: FLINK-30798 URL: https://issues.apache.org/jira/browse/FLINK-30798 Project: Flink

[jira] [Created] (FLINK-30755) Make SinkV2 support speculative execution for batch jobs

2023-01-19 Thread Biao Liu (Jira)
Biao Liu created FLINK-30755: Summary: Make SinkV2 support speculative execution for batch jobs Key: FLINK-30755 URL: https://issues.apache.org/jira/browse/FLINK-30755 Project: Flink Issue Type:

[jira] [Created] (FLINK-30725) FLIP-281: Sink Supports Speculative Execution For Batch Job

2023-01-17 Thread Biao Liu (Jira)
Biao Liu created FLINK-30725: Summary: FLIP-281: Sink Supports Speculative Execution For Batch Job Key: FLINK-30725 URL: https://issues.apache.org/jira/browse/FLINK-30725 Project: Flink Issue

[jira] [Created] (FLINK-30483) Make Avro format support for TIMESTAMP_LTZ

2022-12-22 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30483: - Summary: Make Avro format support for TIMESTAMP_LTZ Key: FLINK-30483 URL: https://issues.apache.org/jira/browse/FLINK-30483 Project: Flink Issue Type:

[jira] [Created] (FLINK-30479) Document flink-connector-files for local execution

2022-12-21 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30479: - Summary: Document flink-connector-files for local execution Key: FLINK-30479 URL: https://issues.apache.org/jira/browse/FLINK-30479 Project: Flink Issue

[jira] [Created] (FLINK-30459) SQL Client supports "SET 'property'"

2022-12-20 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30459: - Summary: SQL Client supports "SET 'property'" Key: FLINK-30459 URL: https://issues.apache.org/jira/browse/FLINK-30459 Project: Flink Issue Type:

[jira] [Created] (FLINK-30179) Stop stringifying exception for logging

2022-11-23 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30179: - Summary: Stop stringifying exception for logging Key: FLINK-30179 URL: https://issues.apache.org/jira/browse/FLINK-30179 Project: Flink Issue Type:

[jira] [Created] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2022-11-17 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30081: - Summary: Local executor can not accept different jvm-overhead.min/max values Key: FLINK-30081 URL: https://issues.apache.org/jira/browse/FLINK-30081 Project: Flink

[jira] [Created] (FLINK-30079) Stop using deprecated TM options in doc

2022-11-17 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30079: - Summary: Stop using deprecated TM options in doc Key: FLINK-30079 URL: https://issues.apache.org/jira/browse/FLINK-30079 Project: Flink Issue Type:

[jira] [Created] (FLINK-29961) Make referencing custom image clearer for Docker

2022-11-09 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-29961: - Summary: Make referencing custom image clearer for Docker Key: FLINK-29961 URL: https://issues.apache.org/jira/browse/FLINK-29961 Project: Flink Issue

[jira] [Created] (FLINK-29940) ExecutionGraph logs job state change at ERROR level when job fails

2022-11-08 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-29940: - Summary: ExecutionGraph logs job state change at ERROR level when job fails Key: FLINK-29940 URL: https://issues.apache.org/jira/browse/FLINK-29940 Project: Flink

[jira] [Created] (FLINK-29920) Minor reformat Kafka connector documentation

2022-11-07 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-29920: - Summary: Minor reformat Kafka connector documentation Key: FLINK-29920 URL: https://issues.apache.org/jira/browse/FLINK-29920 Project: Flink Issue Type:

[jira] [Created] (FLINK-29750) Improve PostgresCatalog#listTables() by reusing resources

2022-10-25 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-29750: - Summary: Improve PostgresCatalog#listTables() by reusing resources Key: FLINK-29750 URL: https://issues.apache.org/jira/browse/FLINK-29750 Project: Flink

[jira] [Created] (FLINK-29640) Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher

2022-10-14 Thread Liu (Jira)
Liu created FLINK-29640: --- Summary: Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher Key: FLINK-29640 URL: https://issues.apache.org/jira/browse/FLINK-29640

[jira] [Created] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-10-14 Thread Liu (Jira)
Liu created FLINK-29639: --- Summary: Add ResourceId in TransportException for debugging Key: FLINK-29639 URL: https://issues.apache.org/jira/browse/FLINK-29639 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29164) There is a problem when compiling Flink 1.15.rc-2 in Windows operations

2022-09-01 Thread mindest liu (Jira)
mindest liu created FLINK-29164: --- Summary: There is a problem when compiling Flink 1.15.rc-2 in Windows operations Key: FLINK-29164 URL: https://issues.apache.org/jira/browse/FLINK-29164 Project: Flink

[jira] [Created] (FLINK-29163) There is a problem when compiling Flink 1.15.rc-2 and flink-1.14.3-rc1 in Windows operations

2022-08-31 Thread mindest liu (Jira)
mindest liu created FLINK-29163: --- Summary: There is a problem when compiling Flink 1.15.rc-2 and flink-1.14.3-rc1 in Windows operations Key: FLINK-29163 URL: https://issues.apache.org/jira/browse/FLINK-29163

[jira] [Created] (FLINK-29160) 在windows 编译flink 1.15.rc-2时出现问题

2022-08-31 Thread mindest liu (Jira)
mindest liu created FLINK-29160: --- Summary: 在windows 编译flink 1.15.rc-2时出现问题 Key: FLINK-29160 URL: https://issues.apache.org/jira/browse/FLINK-29160 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29097) Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-24 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-29097: --- Summary: Moving json se/deserializers from sql-gateway-api to sql-gateway Key: FLINK-29097 URL: https://issues.apache.org/jira/browse/FLINK-29097 Project: Flink

[jira] [Created] (FLINK-28974) Add doc for the API and Option of sql gateway rest endpoint

2022-08-15 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-28974: --- Summary: Add doc for the API and Option of sql gateway rest endpoint Key: FLINK-28974 URL: https://issues.apache.org/jira/browse/FLINK-28974 Project: Flink

[jira] [Created] (FLINK-28963) Add API compatibility test for Sql Gateway Rest Endpoint

2022-08-14 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-28963: --- Summary: Add API compatibility test for Sql Gateway Rest Endpoint Key: FLINK-28963 URL: https://issues.apache.org/jira/browse/FLINK-28963 Project: Flink Issue

[jira] [Created] (FLINK-28924) Translate "LIMIT clause" page into Chinese

2022-08-11 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-28924: --- Summary: Translate "LIMIT clause" page into Chinese Key: FLINK-28924 URL: https://issues.apache.org/jira/browse/FLINK-28924 Project: Flink Issue Type:

[jira] [Created] (FLINK-28922) Translate "ORDER BY clause" page into Chinese

2022-08-11 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-28922: --- Summary: Translate "ORDER BY clause" page into Chinese Key: FLINK-28922 URL: https://issues.apache.org/jira/browse/FLINK-28922 Project: Flink Issue Type:

[jira] [Created] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

2022-08-09 Thread Liu (Jira)
Liu created FLINK-28897: --- Summary: Fail to use udf in added jar when enabling checkpoint Key: FLINK-28897 URL: https://issues.apache.org/jira/browse/FLINK-28897 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28883) Report hive tasks' file number, total number and total size to metastore

2022-08-09 Thread Liu (Jira)
Liu created FLINK-28883: --- Summary: Report hive tasks' file number, total number and total size to metastore Key: FLINK-28883 URL: https://issues.apache.org/jira/browse/FLINK-28883 Project: Flink

[jira] [Created] (FLINK-28796) Add Statement Completement API for sql gateway rest endpoint

2022-08-03 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-28796: --- Summary: Add Statement Completement API for sql gateway rest endpoint Key: FLINK-28796 URL: https://issues.apache.org/jira/browse/FLINK-28796 Project: Flink

[jira] [Created] (FLINK-28777) Add configure session API for sql gateway rest endpoint

2022-08-02 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-28777: --- Summary: Add configure session API for sql gateway rest endpoint Key: FLINK-28777 URL: https://issues.apache.org/jira/browse/FLINK-28777 Project: Flink Issue

[jira] [Created] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException

2022-07-13 Thread Liu (Jira)
Liu created FLINK-28548: --- Summary: The commit partition base path is not created when no data is sent which may cause FileNotFoundException Key: FLINK-28548 URL: https://issues.apache.org/jira/browse/FLINK-28548

[jira] [Created] (FLINK-28208) The method createBatchSink in class HiveTableSink should setParallelism for map operator

2022-06-22 Thread Liu (Jira)
Liu created FLINK-28208: --- Summary: The method createBatchSink in class HiveTableSink should setParallelism for map operator Key: FLINK-28208 URL: https://issues.apache.org/jira/browse/FLINK-28208 Project:

[jira] [Created] (FLINK-28156) Flink KafkaSource with Bounded Throw Exception

2022-06-20 Thread Jiangfei Liu (Jira)
Jiangfei Liu created FLINK-28156: Summary: Flink KafkaSource with Bounded Throw Exception Key: FLINK-28156 URL: https://issues.apache.org/jira/browse/FLINK-28156 Project: Flink Issue Type:

[jira] [Created] (FLINK-28148) Unable to load jar connector to a Python Table API app

2022-06-20 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-28148: -- Summary: Unable to load jar connector to a Python Table API app Key: FLINK-28148 URL: https://issues.apache.org/jira/browse/FLINK-28148 Project: Flink Issue

[jira] [Created] (FLINK-28123) When a flink job is restarted, the metaspce size of the taskmanager does not decrease but keeps increasing. After several restarts, the flink job metaspce oom.

2022-06-19 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-28123: --- Summary: When a flink job is restarted, the metaspce size of the taskmanager does not decrease but keeps increasing. After several restarts, the flink job metaspce oom. Key: FLINK-28123

[jira] [Created] (FLINK-28093) Flink SQL Kafka Source Can Not Support Recovery On Checkpoint

2022-06-16 Thread Jiangfei Liu (Jira)
Jiangfei Liu created FLINK-28093: Summary: Flink SQL Kafka Source Can Not Support Recovery On Checkpoint Key: FLINK-28093 URL: https://issues.apache.org/jira/browse/FLINK-28093 Project: Flink

[jira] [Created] (FLINK-28062) Flink SQL Upsert-Kafka can not support Flink1.14.x With Sink Buffer

2022-06-14 Thread Jiangfei Liu (Jira)
Jiangfei Liu created FLINK-28062: Summary: Flink SQL Upsert-Kafka can not support Flink1.14.x With Sink Buffer Key: FLINK-28062 URL: https://issues.apache.org/jira/browse/FLINK-28062 Project: Flink

[jira] [Created] (FLINK-28037) Flink SQL Upsert-Kafka can not support Flink1.14.x

2022-06-13 Thread Jiangfei Liu (Jira)
Jiangfei Liu created FLINK-28037: Summary: Flink SQL Upsert-Kafka can not support Flink1.14.x Key: FLINK-28037 URL: https://issues.apache.org/jira/browse/FLINK-28037 Project: Flink Issue

[jira] [Created] (FLINK-28027) Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy

2022-06-13 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-28027: -- Summary: Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy Key: FLINK-28027 URL: https://issues.apache.org/jira/browse/FLINK-28027

[jira] [Created] (FLINK-28007) Tests for AWS Connectors Using SDK v2 to use Synchronous Clients

2022-06-10 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-28007: -- Summary: Tests for AWS Connectors Using SDK v2 to use Synchronous Clients Key: FLINK-28007 URL: https://issues.apache.org/jira/browse/FLINK-28007 Project: Flink

[jira] [Created] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

2022-05-28 Thread Jiangfei Liu (Jira)
Jiangfei Liu created FLINK-27828: Summary: FlinkKafkaProducer VS KafkaSink Key: FLINK-27828 URL: https://issues.apache.org/jira/browse/FLINK-27828 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27805) Bump ORC version to 1.7.2

2022-05-26 Thread jia liu (Jira)
jia liu created FLINK-27805: --- Summary: Bump ORC version to 1.7.2 Key: FLINK-27805 URL: https://issues.apache.org/jira/browse/FLINK-27805 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27775) FlinkKafkaProducer VS KafkaSink

2022-05-25 Thread Jiangfei Liu (Jira)
Jiangfei Liu created FLINK-27775: Summary: FlinkKafkaProducer VS KafkaSink Key: FLINK-27775 URL: https://issues.apache.org/jira/browse/FLINK-27775 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27670) Python wrappers for Kinesis Sinks

2022-05-17 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-27670: -- Summary: Python wrappers for Kinesis Sinks Key: FLINK-27670 URL: https://issues.apache.org/jira/browse/FLINK-27670 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

2022-05-12 Thread Liu (Jira)
Liu created FLINK-27579: --- Summary: The param client.timeout can not be set by dynamic properties when stopping the job Key: FLINK-27579 URL: https://issues.apache.org/jira/browse/FLINK-27579 Project: Flink

[jira] [Created] (FLINK-27537) Remove requirement for Async Sink's RequestEntryT to be serializable

2022-05-06 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-27537: -- Summary: Remove requirement for Async Sink's RequestEntryT to be serializable Key: FLINK-27537 URL: https://issues.apache.org/jira/browse/FLINK-27537 Project: Flink

[jira] [Created] (FLINK-27536) Rename method parameter in AsyncSinkWriter

2022-05-06 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-27536: -- Summary: Rename method parameter in AsyncSinkWriter Key: FLINK-27536 URL: https://issues.apache.org/jira/browse/FLINK-27536 Project: Flink Issue Type:

[jira] [Created] (FLINK-27516) The config execution.attached doesn't take effect because it is override by Cli param

2022-05-05 Thread Liu (Jira)
Liu created FLINK-27516: --- Summary: The config execution.attached doesn't take effect because it is override by Cli param Key: FLINK-27516 URL: https://issues.apache.org/jira/browse/FLINK-27516 Project: Flink

[jira] [Created] (FLINK-27505) Add javadoc comments to AsyncSinkBase

2022-05-05 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-27505: -- Summary: Add javadoc comments to AsyncSinkBase Key: FLINK-27505 URL: https://issues.apache.org/jira/browse/FLINK-27505 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27278) Fix wrong indentation in doc dev/datastream/operators/windows.md

2022-04-17 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-27278: - Summary: Fix wrong indentation in doc dev/datastream/operators/windows.md Key: FLINK-27278 URL: https://issues.apache.org/jira/browse/FLINK-27278 Project: Flink

[jira] [Created] (FLINK-27275) Support null value not update in flink-connector-jdbc

2022-04-17 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-27275: - Summary: Support null value not update in flink-connector-jdbc Key: FLINK-27275 URL: https://issues.apache.org/jira/browse/FLINK-27275 Project: Flink

[jira] [Created] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese

2022-04-12 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-27205: --- Summary: Translate "Concepts -> Glossary" page into Chinese Key: FLINK-27205 URL: https://issues.apache.org/jira/browse/FLINK-27205 Project: Flink Issue Type:

[jira] [Created] (FLINK-26909) Support AdaptiveBatch when parallelism is -1 from Cli

2022-03-29 Thread Liu (Jira)
Liu created FLINK-26909: --- Summary: Support AdaptiveBatch when parallelism is -1 from Cli Key: FLINK-26909 URL: https://issues.apache.org/jira/browse/FLINK-26909 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26906) Spelling error for AdaptiveBatch in elastic_scaling.md

2022-03-29 Thread Liu (Jira)
Liu created FLINK-26906: --- Summary: Spelling error for AdaptiveBatch in elastic_scaling.md Key: FLINK-26906 URL: https://issues.apache.org/jira/browse/FLINK-26906 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26868) In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job lead

2022-03-25 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-26868: --- Summary: In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job leader actions." Key:

[jira] [Created] (FLINK-26693) Modify the grammar mistakes in savepoints.md

2022-03-16 Thread Liu (Jira)
Liu created FLINK-26693: --- Summary: Modify the grammar mistakes in savepoints.md Key: FLINK-26693 URL: https://issues.apache.org/jira/browse/FLINK-26693 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

2022-03-16 Thread Liu (Jira)
Liu created FLINK-26683: --- Summary: Terminate the job anyway if savepoint finished when stop-with-savepoint Key: FLINK-26683 URL: https://issues.apache.org/jira/browse/FLINK-26683 Project: Flink Issue

[jira] [Created] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks

2022-03-10 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-26589: -- Summary: Update the logging level of Kinesis Streams and Firehose sinks Key: FLINK-26589 URL: https://issues.apache.org/jira/browse/FLINK-26589 Project: Flink

[jira] [Created] (FLINK-26491) In org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java#L173 the annotation should be "if" instead of "iff"

2022-03-04 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-26491: --- Summary: In org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java#L173 the annotation should be "if" instead of "iff" Key: FLINK-26491 URL:

[jira] [Created] (FLINK-26380) Pending record count must be zero at this point: 5592

2022-02-26 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-26380: - Summary: Pending record count must be zero at this point: 5592 Key: FLINK-26380 URL: https://issues.apache.org/jira/browse/FLINK-26380 Project: Flink

  1   2   3   >