Consume pulsar by WindowFunction occurs a error

16:58:50.803 [pulsar-client-io-1-2] WARN org.apache.pulsar.client.impl.ClientCnx - [id: 0x4a31a8e7, L:/127.0.0.1:26060 - R:localhost/127.0.0.1:6650] Received error from server: Topic does not have schema to check
16:58:50.806 [pulsar-client-io-1-2] WARN org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/default/cloudsafeline_statistics_edr-partition-0][public/default/EDRConverterFunction11] Failed to subscribe to topic on localhost/127.0.0.1:6650
16:58:50.808 [pulsar-client-io-1-2] WARN org.apache.pulsar.client.impl.MultiTopicsConsumerImpl - [cloudsafeline_statistics_edr] Failed to subscribe for topic [persistent://public/default/cloudsafeline_statistics_edr] in topics consumer org.apache.pulsar.client.api.PulsarClientException$IncompatibleSchemaException: Topic does not have schema to check
16:58:50.810 [pulsar-external-listener-3-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/default/cloudsafeline_statistics_edr-partition-0] [public/default/EDRConverterFunction11] Closed Consumer (not connected)
16:58:50.812 [pulsar-external-listener-3-1] WARN org.apache.pulsar.client.impl.MultiTopicsConsumerImpl - [cloudsafeline_statistics_edr] Failed to subscribe for topic [persistent://public/default/cloudsafeline_statistics_edr] in topics consumer, subscribe error: org.apache.pulsar.client.api.PulsarClientException$IncompatibleSchemaException: Topic does not have schema to check
16:58:50.812 [pulsar-external-listener-3-1] WARN org.apache.pulsar.client.impl.MultiTopicsConsumerImpl - Failed subscription for createPartitionedConsumer: cloudsafeline_statistics_edr 1, e:java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$IncompatibleSchemaException: Topic does not have schema to check
16:58:50.825 [main] INFO org.apache.pulsar.functions.LocalRunner - RuntimeSpawner quit because of
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$IncompatibleSchemaException: Failed to subscribe cloudsafeline_statistics_edr with 1 partitions
Topic does not have schema to check

Start by reproducing consumption by the WindowFunction using the topic and local broker details in the report. Trace the subscription failure around ConsumerImpl, MultiTopicsConsumerImpl, and LocalRunner, then verify that the consumer no longer fails with IncompatibleSchemaException: Topic does not have schema to check.

Written by the indexing model from the issue text.