2022-06-02 18:05:47 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.28-alpha 2022-06-02 18:05:48 INFO i.a.w.p.KubeProcessFactory(create):112 - Attempting to start pod = ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl 2022-06-02 18:05:48 INFO i.a.w.p.KubeProcessFactory(create):115 - ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl stdoutLocalPort = 9030 2022-06-02 18:05:48 INFO i.a.w.p.KubeProcessFactory(create):118 - ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl stderrLocalPort = 9031 2022-06-02 18:05:48 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server... 2022-06-02 18:05:48 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server... 2022-06-02 18:05:48 INFO i.a.w.p.KubePodProcess():480 - Creating pod... 2022-06-02 18:05:48 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files... 2022-06-02 18:05:48 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present.. 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready.. 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess():485 - Copying files... 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: source_config.json 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/5b391d2f-e9f4-4b11-aeaa-431dd88d99c9/source_config.json airbyte/ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl:/config/source_config.json -c init 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/2e980428-ee1b-497e-aba5-00bdf105acb1/FINISHED_UPLOADING airbyte/ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl:/config/FINISHED_UPLOADING -c init 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process 2022-06-02 18:05:50 INFO i.a.w.p.KubePodProcess():488 - Waiting until pod is ready... 2022-06-02 18:05:51 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout... 2022-06-02 18:05:51 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr... 2022-06-02 18:05:52 INFO i.a.w.p.KubePodProcess():502 - Reading pod IP... 2022-06-02 18:05:52 INFO i.a.w.p.KubePodProcess():504 - Pod IP: 10.5.212.60 2022-06-02 18:05:52 INFO i.a.w.p.KubePodProcess():511 - Using null stdin output stream... 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-02 18:05:53 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-02 18:05:53 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.destination.kinesis.KinesisDestination 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-02 18:05:53 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: CHECK 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-02 18:05:53 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-02 18:05:53 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-02 18:05:53 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-02 18:05:53 ERROR i.a.i.d.k.KinesisDestination(check):48 - Error while trying to connect to Kinesis: 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - java.lang.NullPointerException: Cannot invoke "com.fasterxml.jackson.databind.JsonNode.asText()" because the return value of "com.fasterxml.jackson.databind.JsonNode.get(String)" is null 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.kinesis.KinesisConfig.(KinesisConfig.java:44) ~[io.airbyte.airbyte-integrations.connectors-destination-kinesis-0.35.27-alpha.jar:?] 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.kinesis.KinesisDestination.check(KinesisDestination.java:41) [io.airbyte.airbyte-integrations.connectors-destination-kinesis-0.35.27-alpha.jar:?] 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:122) [io.airbyte.airbyte-integrations.bases-base-java-0.35.27-alpha.jar:?] 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:89) [io.airbyte.airbyte-integrations.bases-base-java-0.35.27-alpha.jar:?] 2022-06-02 18:05:53 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.kinesis.KinesisDestination.main(KinesisDestination.java:27) [io.airbyte.airbyte-integrations.connectors-destination-kinesis-0.35.27-alpha.jar:?] 2022-06-02 18:06:23 INFO i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl is 0 2022-06-02 18:06:23 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl 2022-06-02 18:06:23 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl 2022-06-02 18:06:23 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod ation-kinesis-sync-87dd0929-17ce-4dcd-baf0-34d24a7c7e02-0-xqohl 2022-06-02 18:06:23 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...