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
dingFormat#applyFilters.
Looking forwards to your feedback.
[1]: [https://issues.apache.org/jira/browse/FLINK-31686]
Best regards,
tanjialiang
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
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
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
Hi Martijn, Ferenc
Thanks all for driving this. As Ferenc said, HBase 1.x is dead, so on the way
forward it should be safe to drop it. Same view as mine. So +1 for this.
Best!
tanjialiang
发件人: Ferenc Csaky
发送时间: 2024年1月30日 22:14
收件人: dev@flink.apache.org
主题: Re: [DISCUSS] Drop support for HBase
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
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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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
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-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
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-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
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-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
33 matches
Mail list logo
