Re: [DISCUSS] Release 2.0 Work Items

Tue, 18 Jul 2023 01:39:48 -0700 

On 18/07/2023 10:33, Wencong Liu wrote:

For FLINK-6912:

     There are three implementations of RichFunction that actually use
the Configuration parameter in RichFunction#open:
     1. ContinuousFileMonitoringFunction#open: It uses the configuration
to configure the FileInputFormat. [1]
     2. OutputFormatSinkFunction#open: It uses the configuration
to configure the OutputFormat. [2]
     3. InputFormatSourceFunction#open: It uses the configuration
  to configure the InputFormat. [3]


And none of them should have any effect since the configuration is empty.

See org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator#open.

Reply via email to