请问如何在PYFLINK1.15下将connect steam进行sink？

可以使用 DataStream.add_sink() 方法将数据流连接到 Sink 上。

参考这个示例代码：

from pyflink.common.serialization import SimpleStringEncoder
from pyflink.common.serialization import SimpleStringSchema
from pyflink.common.typeinfo import Types
from pyflink.datastream import StreamExecutionEnvironment
from pyflink.datastream.connectors import StreamingFileSink

# 创建 StreamExecutionEnvironment 对象
env = StreamExecutionEnvironment.get_execution_environment()

# 创建数据流
data_stream = env.from_collection([(1, "hello"), (2, "world")], Types.TUPLE([Types.INT(), Types.STRING()]))

# 创建 StreamingFileSink 对象
sink = StreamingFileSink \
    .for_row_format('./output', SimpleStringEncoder('utf-8')) \
    .with_rolling_policy(
        file_size=1024 * 1024 * 128,  # 文件大小
        rollover_interval=1000 * 60,  # 滚动间隔
        inactivity_interval=1000)  # 空闲间隔

# 连接数据流和 Sink
data_stream.add_sink(sink)

# 执行作业
env.execute("Write data stream to local file system")