Closed big-andy-coates closed 3 years ago
Needs this AK fix: https://issues.apache.org/jira/browse/KAFKA-10494
Adding needs-triage so that we will assign it in our weekly meeting.
Removed needs triage label as I'm already working on it :p
@big-andy-coates is this on track to be fixed in the coming week. cc @vpapavas
also cc @mjsax who may have context.
The AK ticket linked above is already merged: https://github.com/confluentinc/ksql/issues/6406#issuecomment-707243636 -- not sure if there is any ksql follow up work to do or if this can be closed.
Description
AK commit apache/kafka#9156 introduced a compatibility breaking change: it's causing table source nodes to be materialized into a state store, even through the later mapValues node is already materialized. This MUST be fixed before we release off of master.
The following historic tests have been disabled:
ksqldb-functional-tests/src/test/resources/historicalplans/joins-_table_table_join_with_where_clause/6.0.0_1594233291874 ksqldb-functional-tests/src/test/resources/historicalplans/joins-_table_table_join_with_where_clause/6.1.0_1594164287151
The topology has changed due to the Apache Kafka change:
old topology
new topology:
Note how the
KSTREAM-SOURCE
nodes have state stores now.