Flink广播状态的并行度大于1。

在Flink中，广播状态的并行度大于1可以通过以下步骤来实现：

1. 定义广播状态的描述符

BroadcastStateDescriptor<String, Integer> broadcastStateDescriptor = new BroadcastStateDescriptor<>(
    "broadcast-state",
    TypeInformation.of(new TypeHint<String>() {}),
    TypeInformation.of(new TypeHint<Integer>() {})
);

2. 创建一个广播流

DataStream<String> broadcastStream = env.fromElements("key1", "key2", "key3")
    .broadcast(broadcastStateDescriptor);

3. 定义主流数据处理逻辑，并使用广播状态

DataStream<String> mainStream = ...
mainStream
    .connect(broadcastStream)
    .process(new BroadcastProcessFunction<String, String, String>() {
        private MapStateDescriptor<String, Integer> broadcastStateDescriptor;

        @Override
        public void open(Configuration parameters) throws Exception {
            broadcastStateDescriptor = new MapStateDescriptor<>(
                "broadcast-state",
                TypeInformation.of(new TypeHint<String>() {}),
                TypeInformation.of(new TypeHint<Integer>() {})
            );
        }

        @Override
        public void processElement(String value, ReadOnlyContext ctx, Collector<String> out) throws Exception {
            ReadOnlyBroadcastState<String, Integer> broadcastState = ctx.getBroadcastState(broadcastStateDescriptor);
            Integer broadcastValue = broadcastState.get(value);
            // 使用广播状态进行相应的处理
            // ...
        }

        @Override
        public void processBroadcastElement(String value, Context ctx, Collector<String> out) throws Exception {
            BroadcastState<String, Integer> broadcastState = ctx.getBroadcastState(broadcastStateDescriptor);
            // 更新广播状态
            // ...
        }
    });

在上述代码中，我们首先定义了一个广播状态描述符broadcastStateDescriptor，然后使用broadcast方法将一个DataStream转换为广播流broadcastStream。接下来，我们定义了主流数据的处理逻辑，并使用connect方法将主流和广播流连接起来。在processElement方法中，我们可以通过getBroadcastState方法获取广播状态，并使用它进行相应的处理。在processBroadcastElement方法中，我们可以通过getBroadcastState方法获取广播状态，并更新它。

请注意，上述代码仅为示例，实际应用中的逻辑可能会有所变化。