ASiegeLion commented on issue #6137:
URL: https://github.com/apache/paimon/issues/6137#issuecomment-3224411069
thanks, I have two questions：
1 ，Why doesn't DeleteAction support the write-only=true options?
2 , flink batch sql:
`delete from paimon.hainadw.yydw_dm_entity_person_paimon_mini/*+
OPTIONS('write-only'='true') */
where last_update_dt < TIMESTAMPADD(DAY, -366, CURRENT_DATE);`
This write-only seems to only work on scanTable, not sink table, because
when I ran Flink's delete unit test, I found that the sink table could not get
options.
<img width="1197" height="117" alt="Image"
src="https://github.com/user-attachments/assets/5b40b4c9-14cb-4c40-ab15-e4da0b80faae";
/>
<img width="995" height="575" alt="Image"
src="https://github.com/user-attachments/assets/cabb3fbb-3420-4ab8-b295-02121e7bca1d";
/>
From the above, we can see that LogicalSink did not get options, only
LogicalTableScan got options. This seems to be a problem with the Flink delete
from sql parsing hint?
> Can you pls explain the expectation more clearly
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
