[
https://issues.apache.org/jira/browse/FLINK-37207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37207:
----------------------------
Description:
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].
It has side effect that distributed cache set before will be cleared.
> 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
>
> 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].
> It has side effect that distributed cache set before will be cleared.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
