Thanks for an awesome tutorial. I am running into the following, when executing the creation of the Downstream table. Please see below.
Statement:CREATE TABLE research_ave_boost AS SELECT research, SUM(admit_chance)/COUNT(admit_chance) as ave_chance FROM research_boost WITH (KAFKA_TOPIC='research_ave_boost', VALUE_FORMAT='delimited', KEY='research') GROUP BY research; Caused by: line 1:140: mismatched input 'WITH' expecting ';' Caused by: org.antlr.v4.runtime.InputMismatchException