eline.py",
>> line 74, in run
>> p.run().wait_until_finish()
>> File
>> "/home/jaehyeon/projects/general-demos/venv/lib/python3.10/site-packages/apache_beam/runners/portability/portable_runner.py",
>> line 576, in wait_until_finish
>> raise self._
ait_until_finish
> raise self._runtime_exception
> RuntimeError: Pipeline
> BeamApp-jaehyeon-0314203421-dfc96365_ba750d30-ff27-439d-a6ad-ce835f88fdf7
> failed in state FAILED: java.lang.ClassCastException: class
> java.lang.String cannot be cast to class [B (java.lang.String and [B
lang.ClassCastException: class
java.lang.String cannot be cast to class [B (java.lang.String and [B are in
module java.base of loader 'bootstrap')
Can you please inform me how to fix it? Below shows the pipeline code.
Cheers,
Jaehyeon
import os
import datetime
import argparse
import loggi