See <https://ci-beam.apache.org/job/beam_PostCommit_Python38/1766/display/redirect?page=changes>
Changes: [noreply] Merge pull request #15614 from [BEAM-12953] [Playground] Create protobuf [noreply] [BEAM-11831] Parially Revert "[BEAM-11805] Replace user-agent for [kawaigin] [BEAM-10708] Enable submit beam_sql built jobs to Dataflow ------------------------------------------ [...truncated 37.39 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.hostname = localhost' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.password = ********' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1242728333' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.server.name = dbserver1' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.history = org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: include.schema.changes = false' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.include.list = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 48509' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"SEVERE: -------- Error on consumer: Couldn't obtain encoding for database inventory. with stacktrace: [io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:469), io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:76), io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:133), org.apache.beam.io.debezium.KafkaSourceConsumerFn.process(KafkaSourceConsumerFn.java:161), org.apache.beam.io.debezium.KafkaSourceConsumerFn$DoFnInvoker.invokeProcessElement(Unknown Source), org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1065), org.apache.beam.fn.harness.FnApiDoFnRunner.access$1000(FnApiDoFnRunner.java:144), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:645), org.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:640), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:266), org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:218), org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:221), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:43), org.apache.beam.sdk.fn.data.DecodingFnDataReceiver.accept(DecodingFnDataReceiver.java:25), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient$ConsumerAndData.accept(QueueingBeamFnDataClient.java:316), org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.drainAndBlock(QueueingBeamFnDataClient.java:219), org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:351), org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151), org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]" INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Stopping down connector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Starting PostgresConnectorTask with configuration:' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: connector.class = io.debezium.connector.postgresql.PostgresConnector' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.dbname = inventory' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 06, 2021 12:41:34 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
