From what I can see, the setup method in SQLSink should conform schema and key names. This doesn't seem to happen, so I have thrown in a lot of superfluous conforms everywhere. Figure out why the setup conform doesn't seem to conform, fix it, and clean out the mess.
From what I can see, the setup method in SQLSink should conform schema and key names. This doesn't seem to happen, so I have thrown in a lot of superfluous conforms everywhere. Figure out why the setup conform doesn't seem to conform, fix it, and clean out the mess.