statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java (2 lines):
	- line 149: // TODO type field may be empty in current master only because SDKs are not yet updated;
	- line 150: // TODO once SDKs are updated, we should expect that the type is always specified


statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/Harness.java (2 lines):
	- line 62: // TODO: consider closure cleaner
	- line 79: // TODO: consider closure cleaner


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueSerializerSnapshot.java (2 lines):
	- line 79: // TODO would this mess with Flink's schema compatibility checks?
	- line 80: // TODO this should be fine, since at the moment, if we return incompatible, Flink immediately


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/StaticallyRegisteredTypes.java (1 line):
	- line 67: // TODO: we may want to restrict the allowed typeInfo here to theses that respect shcema


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java (1 line):
	- line 165: // TODO: consider preemption if too many local messages.


statefun-sdk-js/src/types.ts (1 line):
	- line 33: // TODO: should we use BigNums here?


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseValidator.java (1 line):
	- line 23: // TODO: complete this


statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressSpec.java (1 line):
	- line 82: // TODO: we eventually want to make the ingress work out-of-the-box without the need to set the


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncSink.java (1 line):
	- line 64: final long futureId = ThreadLocalRandom.current().nextLong(); // TODO: is this is good enough?


statefun-sdk-js/src/storage.ts (1 line):
	- line 115: // TODO: consider caching and setting the newly received states by calling setValue on each individual value.


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger/InputStreamUtils.java (1 line):
	- line 40: * <p>TODO we can remove this once we upgrade to Flink 1.12.x, since {@link


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettySharedResources.java (1 line):
	- line 46: // TODO: configure DNS resolving


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/DynamicallyRegisteredTypes.java (1 line):
	- line 58: // TODO: we may want to restrict the allowed typeInfo here to theses that respect schema


statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/ExtensionResolverAccessor.java (1 line):
	- line 24: * TODO This is a temporary workaround for accessing the {@link ExtensionResolver}. TODO We should