[
https://issues.apache.org/jira/browse/FLINK-37207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37207:
-----------------------------------
Labels: pull-request-available (was: )
> Distributed cache set in the DataStream API does not work if a job use both
> the Table API & DataStream API
> ----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-37207
> URL: https://issues.apache.org/jira/browse/FLINK-37207
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Reporter: Dian Fu
> Assignee: Dian Fu
> Priority: Major
> Labels: pull-request-available
> Attachments: image-2025-01-23-15-34-13-242.png
>
>
> It will clear the distributed cache in the method
> [StreamExecutionEnvironment.configure|https://github.com/apache/flink/blob/7b2e9c410344126a265ed318c81f9b9cad8fbe63/flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java#L731].
>
> !image-2025-01-23-15-34-13-242.png!
> It has side effect that distributed caches set before will be cleared. It may
> happen in the case that a job mixes use of the DataStream API and Java Table
> API and it has set distributed cache in the DataStream API. I encountered
> this issue in a PyFlink job which mixes use of DataStream API and Table API.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
