리뷰 Google Cloud에서 ML API용으로 데이터 준비하기: 챌린지 실습개

​task 1 fails. "Error message from worker: org.apache.beam.sdk.util.UserCodeException: java.lang.RuntimeException: Failed to serialize json to table row: \"a228717b-46eb-4107-a4d2-f0e321ef3ff3\",false,\"Pacheco\",\"Farley\",\"ISOTRONIC\",\"pachecofarley@isotronic.com\",\"+1 (915) 512-3040\",\"794 Dekoven Court, Coalmont, Rhode Island, 4358\",\"Ullamco amet sint minim anim pariatur consequat nostrud pariatur excepteur voluptate tempor Lorem eu. Pariatur ut ullamco ad duis nostrud excepteur est velit eu deserunt voluptate. Laboris voluptate eu officia exercitation commodo eiusmod dolore ea cillum sint consequat culpa id dolore.\",\"2014-07-04T09:46:22 -08:00\",-20.301872,-110.658406\n\torg.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:39)\n\torg.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.processElementForParDo(FnApiDoFnRunner.java:803)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:348)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:275)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1792)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.access$3000(FnApiDoFnRunner.java:143)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$NonWindowObservingProcessBundleContext.output(FnApiDoFnRunner.java:2514)\n\tcom.google.cloud.teleport.templates.common.JavascriptTextTransformer$TransformTextViaJavascript$1.processElement(JavascriptTextTransformer.java:357)\n\tcom.google.cloud.teleport.templates.common.JavascriptTextTransformer$TransformTextViaJavascript$1$DoFnInvoker.invokeProcessElement(Unknown Source)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.processElementForParDo(FnApiDoFnRunner.java:803)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:348)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:275)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1792)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.access$3000(FnApiDoFnRunner.java:143)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$WindowObservingProcessBundleContext.outputWithTimestamp(FnApiDoFnRunner.java:2218)\n\torg.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn.processElement(Read.java:321)\n\torg.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn$DoFnInvoker.invokeProcessElement(Unknown Source)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1100)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.access$1500(FnApiDoFnRunner.java:143)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:659)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:654)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:348)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:275)\n\torg.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:213)\n\torg.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.multiplexElements(BeamFnDataInboundObserver.java:158)\n\torg.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:537)\n\torg.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)\n\torg.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)\n\tjava.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tjava.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\torg.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)\n\tjava.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tjava.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tjava.base/java.lang.Thread.run(Thread.java:829)\nCaused by: java.lang.RuntimeException: Failed to serialize json to table row: \"a228717b-46eb-4107-a4d2-f0e321ef3ff3\",false,\"Pacheco\",\"Farley\",\"ISOTRONIC\",\"pachecofarley@isotronic.com\",\"+1 (915) 512-3040\",\"794 Dekoven Court, Coalmont, Rhode Island, 4358\",\"Ullamco amet sint minim anim pariatur consequat nostrud pariatur excepteur voluptate tempor Lorem eu. Pariatur ut ullamco ad duis nostrud excepteur est velit eu deserunt voluptate. Laboris voluptate eu officia exercitation commodo eiusmod dolore ea cillum sint consequat culpa id dolore.\",\"2014-07-04T09:46:22 -08:00\",-20.301872,-110.658406\n\tcom.google.cloud.teleport.templates.common.BigQueryConverters.convertJsonToTableRow(BigQueryConverters.java:352)\n\tcom.google.cloud.teleport.templates.common.BigQueryConverters$JsonToTableRow$1.apply(BigQueryConverters.java:131)\n\tcom.google.cloud.teleport.templates.common.BigQueryConverters$JsonToTableRow$1.apply(BigQueryConverters.java:128)\n\torg.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151)\nCaused by: com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot construct instance of `com.google.api.services.bigquery.model.TableRow` (although at least one Creator exists): no String-argument constructor/factory method to deserialize from String value ('a228717b-46eb-4107-a4d2-f0e321ef3ff3')\n at [Source: (String)\"\"a228717b-46eb-4107-a4d2-f0e321ef3ff3\",false,\"Pacheco\",\"Farley\",\"ISOTRONIC\",\"pachecofarley@isotronic.com\",\"+1 (915) 512-3040\",\"794 Dekoven Court, Coalmont, Rhode Island, 4358\",\"Ullamco amet sint minim anim pariatur consequat nostrud pariatur excepteur voluptate tempor Lorem eu. Pariatur ut ullamco ad duis nostrud excepteur est velit eu deserunt voluptate. Laboris voluptate eu officia exercitation commodo eiusmod dolore ea cillum sint consequat culpa id dolore.\",\"2014-07-04T09:46:22 -08:00\",-20.3\"[truncated 17 chars]; line: 1, column: 1]\n\tcom.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:63)\n\tcom.fasterxml.jackson.databind.DeserializationContext.reportInputMismatch(DeserializationContext.java:1733)\n\tcom.fasterxml.jackson.databind.DeserializationContext.handleMissingInstantiator(DeserializationContext.java:1358)\n\tcom.fasterxml.jackson.databind.deser.std.StdDeserializer._deserializeFromString(StdDeserializer.java:311)\n\tcom.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:454)\n\tcom.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:32)\n\tcom.fasterxml.jackson.databind.deser.DefaultDeserializationContext.readRootValue(DefaultDeserializationContext.java:323)\n\tcom.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4730)\n\tcom.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3677)\n\tcom.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3645)\n\torg.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder.decode(TableRowJsonCoder.java:59)\n\tcom.google.cloud.teleport.templates.common.BigQueryConverters.convertJsonToTableRow(BigQueryConverters.java:349)\n\tcom.google.cloud.teleport.templates.common.BigQueryConverters$JsonToTableRow$1.apply(BigQueryConverters.java:131)\n\tcom.google.cloud.teleport.templates.common.BigQueryConverters$JsonToTableRow$1.apply(BigQueryConverters.java:128)\n\torg.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151)\n\torg.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.processElementForParDo(FnApiDoFnRunner.java:803)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:348)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:275)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1792)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.access$3000(FnApiDoFnRunner.java:143)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$NonWindowObservingProcessBundleContext.output(FnApiDoFnRunner.java:2514)\n\tcom.google.cloud.teleport.templates.common.JavascriptTextTransformer$TransformTextViaJavascript$1.processElement(JavascriptTextTransformer.java:357)\n\tcom.google.cloud.teleport.templates.common.JavascriptTextTransformer$TransformTextViaJavascript$1$DoFnInvoker.invokeProcessElement(Unknown Source)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.processElementForParDo(FnApiDoFnRunner.java:803)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:348)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:275)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1792)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.access$3000(FnApiDoFnRunner.java:143)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$WindowObservingProcessBundleContext.outputWithTimestamp(FnApiDoFnRunner.java:2218)\n\torg.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn.processElement(Read.java:321)\n\torg.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn$DoFnInvoker.invokeProcessElement(Unknown Source)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingSizedElementAndRestriction(FnApiDoFnRunner.java:1100)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner.access$1500(FnApiDoFnRunner.java:143)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:659)\n\torg.apache.beam.fn.harness.FnApiDoFnRunner$4.accept(FnApiDoFnRunner.java:654)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:348)\n\torg.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:275)\n\torg.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:213)\n\torg.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.multiplexElements(BeamFnDataInboundObserver.java:158)\n\torg.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:537)\n\torg.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)\n\torg.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)\n\tjava.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tjava.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\torg.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)\n\tjava.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tjava.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tjava.base/java.lang.Thread.run(Thread.java:829)\n",

Jaan M. · 2년 초과 전에 리뷰됨

Jesus M. · 2년 초과 전에 리뷰됨

2116 y. · 2년 초과 전에 리뷰됨

Lucas M. · 2년 초과 전에 리뷰됨

Renan S. · 2년 초과 전에 리뷰됨

amine A. · 2년 초과 전에 리뷰됨

Malipeddi meghana M. · 2년 초과 전에 리뷰됨

Eugene Y. · 2년 초과 전에 리뷰됨

Parthiban S. · 2년 초과 전에 리뷰됨

Nikitha J. · 2년 초과 전에 리뷰됨

Nishant D. · 2년 초과 전에 리뷰됨

Props G. · 2년 초과 전에 리뷰됨

Gergely U. · 2년 초과 전에 리뷰됨

Chanda S. · 2년 초과 전에 리뷰됨

M C. · 2년 초과 전에 리뷰됨

JOSUE I. · 2년 초과 전에 리뷰됨

Carlos T. · 2년 초과 전에 리뷰됨

Rafael L. · 2년 초과 전에 리뷰됨

Juan José H. · 2년 초과 전에 리뷰됨

Juan José H. · 2년 초과 전에 리뷰됨

Oscar Damián V. · 2년 초과 전에 리뷰됨

Alexandre S. · 2년 초과 전에 리뷰됨

Brenda O. · 2년 초과 전에 리뷰됨

Víctor Antonio M. · 2년 초과 전에 리뷰됨