Re: [DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job

2022-12-14 Thread Caizhi Weng
Hi all. It seems that we've reached at an agreement. We'll rename "full" scan.mode to "latest-full" and "compacted" scan.mode to "compacted-full". I've created a ticket about this [1] and will work on it soon. [1] https://issues.apache.org/jira/browse/FLINK-30410 Shammon FY 于2022年12月12日周一 16:0

Re: [DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job

2022-12-12 Thread Shammon FY
Hi jinsong, caizhi Thank you for your reply. I found that what really confused me was the starting position of the streaming job to read data. As @caizhi mentioned in kafka, streaming jobs only read incremental data and its definition is very clear. In the Table Store, streaming jobs also have th

Re: [DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job

2022-12-11 Thread Caizhi Weng
Thanks Shammon for bringing up the discussion. My opinion is to combine everything into scan.mode so that we don't have orthogonal options. You first mention that there are two disadvantages for this solution. *1. The behaviors of some StartupModes in Stream and Batch jobs are inconsistent* This

Re: [DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job

2022-12-09 Thread Jingsong Li
Thanks Shammon! Your summary was very good and very detailed. I thought about it again. ## Solution 1 Actually, according to what you said, there should be so many modes in theory. - Runtime-mode: streaming or batch. - Range: full or incremental. - Position: Latest, timestamp, snapshot-id, compa

[DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job

2022-12-08 Thread Shammon FY
Hi devs: I'm an engineer from ByteDance, and here I'd link to discuss "Scan mode in Table Store for Flink Stream and Batch job". Users can execute Flink Steam and Batch jobs on Table Store. In Table Store 0.2 there're two items which determine how the Stream and Batch jobs' sources read data: Sta