[jira] [Created] (FLINK-35233) HBase lookup result is wrong when lookup cache is enabled

2024-04-24 Thread tanjialiang (Jira)
tanjialiang created FLINK-35233: --- Summary: HBase lookup result is wrong when lookup cache is enabled Key: FLINK-35233 URL: https://issues.apache.org/jira/browse/FLINK-35233 Project: Flink

[jira] [Created] (FLINK-34089) Missing check of subscribed and assigned topics at job startup

2024-01-15 Thread tanjialiang (Jira)
tanjialiang created FLINK-34089: --- Summary: Missing check of subscribed and assigned topics at job startup Key: FLINK-34089 URL: https://issues.apache.org/jira/browse/FLINK-34089 Project: Flink

[jira] [Created] (FLINK-33304) Atomicity of RowMutations would broken when Delete and Put on same columnFamily/column/row

2023-10-18 Thread tanjialiang (Jira)
tanjialiang created FLINK-33304: --- Summary: Atomicity of RowMutations would broken when Delete and Put on same columnFamily/column/row Key: FLINK-33304 URL: https://issues.apache.org/jira/browse/FLINK-33304

[jira] [Created] (FLINK-33208) Support the timestamp writable metadata for hbase connector

2023-10-08 Thread tanjialiang (Jira)
tanjialiang created FLINK-33208: --- Summary: Support the timestamp writable metadata for hbase connector Key: FLINK-33208 URL: https://issues.apache.org/jira/browse/FLINK-33208 Project: Flink

[jira] [Created] (FLINK-33207) Scan hbase table will throw error when table is empty

2023-10-08 Thread tanjialiang (Jira)
tanjialiang created FLINK-33207: --- Summary: Scan hbase table will throw error when table is empty Key: FLINK-33207 URL: https://issues.apache.org/jira/browse/FLINK-33207 Project: Flink Issue

[jira] [Created] (FLINK-33206) Verify the existence of hbase table before read/write

2023-10-08 Thread tanjialiang (Jira)
tanjialiang created FLINK-33206: --- Summary: Verify the existence of hbase table before read/write Key: FLINK-33206 URL: https://issues.apache.org/jira/browse/FLINK-33206 Project: Flink Issue

[jira] [Created] (FLINK-33173) Support currentFetchEventTimeLag metrics for KafkaSource

2023-09-30 Thread tanjialiang (Jira)
tanjialiang created FLINK-33173: --- Summary: Support currentFetchEventTimeLag metrics for KafkaSource Key: FLINK-33173 URL: https://issues.apache.org/jira/browse/FLINK-33173 Project: Flink Issue

[jira] [Created] (FLINK-33164) HBase connector support ignore null value for partial update

2023-09-27 Thread tanjialiang (Jira)
tanjialiang created FLINK-33164: --- Summary: HBase connector support ignore null value for partial update Key: FLINK-33164 URL: https://issues.apache.org/jira/browse/FLINK-33164 Project: Flink

[jira] [Created] (FLINK-33153) Kafka using latest-offset maybe missing data

2023-09-25 Thread tanjialiang (Jira)
tanjialiang created FLINK-33153: --- Summary: Kafka using latest-offset maybe missing data Key: FLINK-33153 URL: https://issues.apache.org/jira/browse/FLINK-33153 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32252) SELECT COUNT(*) will return nothing when source no data return

2023-06-05 Thread tanjialiang (Jira)
tanjialiang created FLINK-32252: --- Summary: SELECT COUNT(*) will return nothing when source no data return Key: FLINK-32252 URL: https://issues.apache.org/jira/browse/FLINK-32252 Project: Flink

[jira] [Created] (FLINK-31686) All of connector should replace the shallow copy with a deep copy

2023-04-01 Thread tanjialiang (Jira)
tanjialiang created FLINK-31686: --- Summary: All of connector should replace the shallow copy with a deep copy Key: FLINK-31686 URL: https://issues.apache.org/jira/browse/FLINK-31686 Project: Flink

[jira] [Created] (FLINK-31541) Get metrics in Flink WEB UI error

2023-03-21 Thread tanjialiang (Jira)
tanjialiang created FLINK-31541: --- Summary: Get metrics in Flink WEB UI error Key: FLINK-31541 URL: https://issues.apache.org/jira/browse/FLINK-31541 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31367) Support filter's function push down

2023-03-08 Thread tanjialiang (Jira)
tanjialiang created FLINK-31367: --- Summary: Support filter's function push down Key: FLINK-31367 URL: https://issues.apache.org/jira/browse/FLINK-31367 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31308) JobManager's metaspace out-of-memory when submit a flinksessionjobs

2023-03-02 Thread tanjialiang (Jira)
tanjialiang created FLINK-31308: --- Summary: JobManager's metaspace out-of-memory when submit a flinksessionjobs Key: FLINK-31308 URL: https://issues.apache.org/jira/browse/FLINK-31308 Project: Flink

[jira] [Created] (FLINK-30922) SQL validate fail to parse writing metadata

2023-02-06 Thread tanjialiang (Jira)
tanjialiang created FLINK-30922: --- Summary: SQL validate fail to parse writing metadata Key: FLINK-30922 URL: https://issues.apache.org/jira/browse/FLINK-30922 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30687) FILTER not effect in count(*)

2023-01-13 Thread tanjialiang (Jira)
tanjialiang created FLINK-30687: --- Summary: FILTER not effect in count(*) Key: FLINK-30687 URL: https://issues.apache.org/jira/browse/FLINK-30687 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread tanjialiang (Jira)
tanjialiang created FLINK-30520: --- Summary: Arguments contains with '#' will error split in loadYAMLResource Key: FLINK-30520 URL: https://issues.apache.org/jira/browse/FLINK-30520 Project: Flink

[jira] [Created] (FLINK-30498) frocksdb throw an UnsatisfiedLinkError

2022-12-23 Thread tanjialiang (Jira)
tanjialiang created FLINK-30498: --- Summary: frocksdb throw an UnsatisfiedLinkError Key: FLINK-30498 URL: https://issues.apache.org/jira/browse/FLINK-30498 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30460) Support writing HBase's CEIL TTL metadata

2022-12-20 Thread tanjialiang (Jira)
tanjialiang created FLINK-30460: --- Summary: Support writing HBase's CEIL TTL metadata Key: FLINK-30460 URL: https://issues.apache.org/jira/browse/FLINK-30460 Project: Flink Issue Type:

[jira] [Created] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-14 Thread tanjialiang (Jira)
tanjialiang created FLINK-30411: --- Summary: Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource Key: FLINK-30411 URL: https://issues.apache.org/jira/browse/FLINK-30411

[jira] [Created] (FLINK-30222) Suspended a job in last-state mode bug

2022-11-27 Thread tanjialiang (Jira)
tanjialiang created FLINK-30222: --- Summary: Suspended a job in last-state mode bug Key: FLINK-30222 URL: https://issues.apache.org/jira/browse/FLINK-30222 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28728) Support to set the end offset for streaming connector

2022-07-28 Thread tanjialiang (Jira)
tanjialiang created FLINK-28728: --- Summary: Support to set the end offset for streaming connector Key: FLINK-28728 URL: https://issues.apache.org/jira/browse/FLINK-28728 Project: Flink Issue

[jira] [Created] (FLINK-27574) [QUESTION] In Flink k8s Application mode with HA can not using History Server for history backend

2022-05-11 Thread tanjialiang (Jira)
tanjialiang created FLINK-27574: --- Summary: [QUESTION] In Flink k8s Application mode with HA can not using History Server for history backend Key: FLINK-27574 URL: https://issues.apache.org/jira/browse/FLINK-27574

[jira] [Created] (FLINK-27110) using TIMESTAMP_LTZ cause Flink web ui watermark display problem

2022-04-07 Thread tanjialiang (Jira)
tanjialiang created FLINK-27110: --- Summary: using TIMESTAMP_LTZ cause Flink web ui watermark display problem Key: FLINK-27110 URL: https://issues.apache.org/jira/browse/FLINK-27110 Project: Flink

[jira] [Created] (FLINK-25618) Data quality by apache flink

2022-01-11 Thread tanjialiang (Jira)
tanjialiang created FLINK-25618: --- Summary: Data quality by apache flink Key: FLINK-25618 URL: https://issues.apache.org/jira/browse/FLINK-25618 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-25384) Job can not migrate from flink-1.12 to flink-1.13

2021-12-20 Thread tanjialiang (Jira)
tanjialiang created FLINK-25384: --- Summary: Job can not migrate from flink-1.12 to flink-1.13 Key: FLINK-25384 URL: https://issues.apache.org/jira/browse/FLINK-25384 Project: Flink Issue Type: