Liu created FLINK-37314:
---
Summary: The watermark and lateness document has an error which
may mislead users
Key: FLINK-37314
URL: https://issues.apache.org/jira/browse/FLINK-37314
Project: Flink
Issue
Jinkun Liu created FLINK-37257:
--
Summary: Add an API on keyedStream to allow users to customize the
hash method from key to parallelism.
Key: FLINK-37257
URL: https://issues.apache.org/jira/browse/FLINK-37257
Naijie Liu created FLINK-37146:
--
Summary: Prometheus Push Gateway not work on 1.18.1
Key: FLINK-37146
URL: https://issues.apache.org/jira/browse/FLINK-37146
Project: Flink
Issue Type: Bug
liting liu created FLINK-37013:
--
Summary: Job failed to restart on time
Key: FLINK-37013
URL: https://issues.apache.org/jira/browse/FLINK-37013
Project: Flink
Issue Type: Bug
Component
Mingliang Liu created FLINK-36780:
-
Summary: Kafka source disable partition discovery unexpectedly
Key: FLINK-36780
URL: https://issues.apache.org/jira/browse/FLINK-36780
Project: Flink
Issue
Mingliang Liu created FLINK-36679:
-
Summary: Add a metric to track checkpoint _metadata size
Key: FLINK-36679
URL: https://issues.apache.org/jira/browse/FLINK-36679
Project: Flink
Issue Type:
Mingliang Liu created FLINK-36604:
-
Summary: StreamingJobGraphGenerator::setOperatorConfig checks
input serializer lengh
Key: FLINK-36604
URL: https://issues.apache.org/jira/browse/FLINK-36604
Project
LIU created FLINK-36579:
---
Summary: mysql cdc charset collation sort not equals java string
compare.
Key: FLINK-36579
URL: https://issues.apache.org/jira/browse/FLINK-36579
Project: Flink
Issue Type: I
liting liu created FLINK-36567:
--
Summary: Planner module didn't use the setting from flink-conf.yaml
Key: FLINK-36567
URL: https://issues.apache.org/jira/browse/FLINK-36567
Project: Flink
Issue
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
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
Iss
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:
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 Type:
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: Imp
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:
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
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
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
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
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
Issue
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
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: I
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
Project
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
Proj
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
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
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
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: Im
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 Deb
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
Proje
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
Wencong Liu created FLINK-32979:
---
Summary: Deprecate
WindowAssigner#getDefaultTrigger(StreamExecutionEnvironment env)
Key: FLINK-32979
URL: https://issues.apache.org/jira/browse/FLINK-32979
Project: Fli
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 Typ
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 Type:
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
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: Technica
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 Type
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: https://issues.apache.org/jira/browse/FLIN
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
Project
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: F
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
Is
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
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
Project
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 Typ
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:
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
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: Impro
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: Improvemen
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
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: Sub-
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
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
Issue
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
Issue
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:
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 Ty
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: Impr
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 Ty
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: Improvemen
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: Improve
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
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: Improve
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 Type
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
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: Bu
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
I
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
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
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
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
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
Compo
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
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
Is
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
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: Improvem
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: Impr
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
Affec
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
Issue
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
I
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 T
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
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: Flink
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: Bu
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 Type
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
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
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
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 Type
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
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
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
Com
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
Components:
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
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
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
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
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: Improvemen
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
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
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
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
Issue
1 - 100 of 252 matches
Mail list logo
