tanjialiang created FLINK-35630:
---
Summary: Kafka source may reset the consume offset to earliest
when the partition leader changes
Key: FLINK-35630
URL: https://issues.apache.org/jira/browse/FLINK-35630
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
Hi, devs! I want to prepare a FLIP and start a discussion on the dev mailing
list, but I find I don't have the access, can someone give me access to
confluence?
My Confluence username: tanjialiang
Best regards,
tanjialiang
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
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
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
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
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
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
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
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
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
Hi, devs.
Do anyone has any question about this discussion? I'm looking forwards to your
feedback.
Best regards,
tanjialiang.
Replied Message
| From | tanjialiang |
| Date | 4/13/2023 10:05 |
| To | dev@flink.apache.org |
| Subject | [DISCUSS] EncodingFormat and DecondingF
Hi, Aitozi,
Thanks you for your feedback, and +1 for your point of view.
Best,
tanjialiang.
Replied Message
| From | Aitozi |
| Date | 4/14/2023 16:19 |
| To | |
| Subject | Re: [DISCUSS] EncodingFormat and DecondingFormat provide copy API |
Hi tanjialiang
Thanks for reporting this, I
dingFormat#applyFilters.
Looking forwards to your feedback.
[1]: [https://issues.apache.org/jira/browse/FLINK-31686]
Best regards,
tanjialiang
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
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
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: Improv
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:
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
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
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
Proj
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
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
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
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
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
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
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
Hi everyone,
I would like to start a discussion thread on "Flink SQL support data quality"
For example, I have a SQL job, in this job i have a source table with a column
named phone, and i want to set the data quality of the data in the column
phone's pattern, such as it must match the pattern
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
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
32 matches
Mail list logo
