See <https://ci-beam.apache.org/job/beam_PostCommit_Python36/4442/display/redirect?page=changes>
Changes: [noreply] Only stage the single (fat) jar when auto-starting expansion service. [noreply] Disable samza counters (#15659) ------------------------------------------ [...truncated 31.28 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' > Task :sdks:python:test-suites:dataflow:py36:postCommitIT [gw3] [32mPASSED[0m apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/io/gcp/bigquery_io_read_it_test.py::BigqueryIOReadIT::test_bigquery_read_1M_python > Task :sdks:python:test-suites:portable:py36:postCommitPy36IT 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.user = debezium' > Task :sdks:python:test-suites:portable:py36:postCommitPy36IT 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: beam.parent.instance = 1444750574' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM 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 05, 2021 6:26:38 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: database.port = 39256' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 05, 2021 6:26:38 PM 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)]" java.lang.OutOfMemoryError: GC overhead limit exceeded 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]
