2023-07-17 15:00:16
org.apache.flink.runtime.taskmanager.AsynchronousException: Caught exception while processing timer.
  at org.apache.flink.streaming.runtime.tasks.StreamTask$StreamTaskAsyncExceptionHandler.handleAsyncException(StreamTask.java:1568)
  at org.apache.flink.streaming.runtime.tasks.StreamTask.handleAsyncException(StreamTask.java:1543)
  at org.apache.flink.streaming.runtime.tasks.StreamTask.invokeProcessingTimeCallback(StreamTask.java:1683)
  at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$null$22(StreamTask.java:1672)
  at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
  at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
  at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398)
  at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:367)
  at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:352)
  at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229)
  at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:831)
  at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:780)
  at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
  at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914)
  at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
  at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
  at java.lang.Thread.run(Thread.java:750)
Caused by: TimerException{java.lang.RuntimeException: Error while waiting for BeamPythonFunctionRunner flush}
  ... 15 more
Caused by: java.lang.RuntimeException: Error while waiting for BeamPythonFunctionRunner flush
  at org.apache.flink.streaming.api.operators.python.process.AbstractExternalPythonFunctionOperator.invokeFinishBundle(AbstractExternalPythonFunctionOperator.java:107)
  at org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.checkInvokeFinishBundleByTime(AbstractPythonFunctionOperator.java:300)
  at org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.lambda$open$0(AbstractPythonFunctionOperator.java:118)
  at org.apache.flink.streaming.runtime.tasks.StreamTask.invokeProcessingTimeCallback(StreamTask.java:1681)
  ... 14 more
Caused by: java.lang.RuntimeException: Failed to close remote bundle
  at org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.finishBundle(BeamPythonFunctionRunner.java:403)
  at org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.flush(BeamPythonFunctionRunner.java:387)
  at org.apache.flink.streaming.api.operators.python.process.AbstractExternalPythonFunctionOperator.lambda$invokeFinishBundle$0(AbstractExternalPythonFunctionOperator.java:86)
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  ... 1 more
Caused by: java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error received from SDK harness for instruction 2: Traceback (most recent call last):
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/work_flow/wfutils/flink_importlib.py", line 147, in import_class_lib
    module = import_module(package)
  File "/usr/local/lib/python3.8/importlib/__init__.py", line 127, in import_module
    return _bootstrap._gcd_import(name[level:], package, level)
  File "<frozen importlib._bootstrap>", line 1014, in _gcd_import
  File "<frozen importlib._bootstrap>", line 991, in _find_and_load
  File "<frozen importlib._bootstrap>", line 975, in _find_and_load_unlocked
  File "<frozen importlib._bootstrap>", line 671, in _load_unlocked
  File "<frozen importlib._bootstrap_external>", line 848, in exec_module
  File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/other/vibrate14/__init__.py", line 1, in <module>
    from .adapter import Vibrate14
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/other/vibrate14/adapter.py", line 5, in <module>
    from algorithm.sclib.vibrate.vibrate import Vibrate
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/sclib/vibrate/vibrate.py", line 13, in <module>
    from .time_domain_features import TimeDomainFeatures
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/sclib/vibrate/time_domain_features.py", line 11, in <module>
    import numba as nb
  File "/usr/local/lib/python3.8/site-packages/numba/__init__.py", line 88, in <module>
    from numba.core.decorators import (cfunc, generated_jit, jit, njit, stencil,
  File "/usr/local/lib/python3.8/site-packages/numba/core/decorators.py", line 12, in <module>
    from numba.stencils.stencil import stencil
  File "/usr/local/lib/python3.8/site-packages/numba/stencils/stencil.py", line 11, in <module>
    from numba.core import types, typing, utils, ir, config, ir_utils, registry
  File "/usr/local/lib/python3.8/site-packages/numba/core/registry.py", line 5, in <module>
    from numba.core import utils, typing, dispatcher, cpu
  File "/usr/local/lib/python3.8/site-packages/numba/core/dispatcher.py", line 13, in <module>
    from numba.core import (
  File "/usr/local/lib/python3.8/site-packages/numba/core/compiler.py", line 6, in <module>
    from numba.core import (utils, errors, typing, interpreter, bytecode, postproc,
  File "/usr/local/lib/python3.8/site-packages/numba/core/callconv.py", line 13, in <module>
    from numba.core.base import PYOBJECT, GENERIC_POINTER
  File "/usr/local/lib/python3.8/site-packages/numba/core/base.py", line 20, in <module>
    from numba.cpython import builtins
  File "/usr/local/lib/python3.8/site-packages/numba/cpython/builtins.py", line 536, in <module>
    from numba.core.typing.builtins import IndexValue, IndexValueType
  File "/usr/local/lib/python3.8/site-packages/numba/core/typing/builtins.py", line 22, in <module>
    @infer_global(print)
  File "/usr/local/lib/python3.8/site-packages/numba/core/typing/templates.py", line 1271, in register_global
    if getattr(mod, val.__name__) is not val:
AttributeError: module 'pyflink.fn_execution.beam.beam_sdk_worker_main' has no attribute 'print'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 267, in _execute
    response = task()
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 340, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 580, in do_instruction
    return getattr(self, request_type)(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 611, in process_bundle
    bundle_processor = self.bundle_processor_cache.get(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 441, in get
    processor = bundle_processor.BundleProcessor(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 863, in __init__
    self.ops = self.create_execution_tree(self.process_bundle_descriptor)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 916, in create_execution_tree
    return collections.OrderedDict([(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 919, in <listcomp>
    get_operation(transform_id))) for transform_id in sorted(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 806, in wrapper
    result = cache[args] = func(*args)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 898, in get_operation
    transform_consumers = {
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 899, in <dictcomp>
    tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 899, in <listcomp>
    tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 806, in wrapper
    result = cache[args] = func(*args)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 903, in get_operation
    return transform_factory.create_operation(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1198, in create_operation
    return creator(self, transform_id, transform_proto, payload, consumers)
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/beam/beam_operations.py", line 136, in create_data_stream_keyed_process_function
    return _create_user_defined_function_operation(
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/beam/beam_operations.py", line 206, in _create_user_defined_function_operation
    return beam_operation_cls(
  File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 249, in pyflink.fn_execution.beam.beam_operations_fast.StatefulFunctionOperation.__init__
  File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 132, in pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.__init__
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/datastream/process/operations.py", line 127, in open
    self.open_func()
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/datastream/process/operations.py", line 296, in open_func
    process_function.open(runtime_context)
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/work_flow/workflow/functions/operator_functions.py", line 1064, in open
    class_instance = import_class_lib(plugin_fun[:plugin_fun.find('.')], plugin_fun[plugin_fun.find('.')+1:], "function")
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/work_flow/wfutils/flink_importlib.py", line 155, in import_class_lib
    raise Exception(f'模块: {package}.{val_name} 导入失败, {exce}')
Exception: 模块: algorithm.other.vibrate14.function 导入失败, module 'pyflink.fn_execution.beam.beam_sdk_worker_main' has no attribute 'print'

  at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
  at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
  at org.apache.beam.sdk.util.MoreFutures.get(MoreFutures.java:60)
  at org.apache.beam.runners.fnexecution.control.SdkHarnessClient$BundleProcessor$ActiveBundle.close(SdkHarnessClient.java:504)
  at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory$1.close(DefaultJobBundleFactory.java:555)
  at org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.finishBundle(BeamPythonFunctionRunner.java:401)
  ... 7 more
Caused by: java.lang.RuntimeException: Error received from SDK harness for instruction 2: Traceback (most recent call last):
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/work_flow/wfutils/flink_importlib.py", line 147, in import_class_lib
    module = import_module(package)
  File "/usr/local/lib/python3.8/importlib/__init__.py", line 127, in import_module
    return _bootstrap._gcd_import(name[level:], package, level)
  File "<frozen importlib._bootstrap>", line 1014, in _gcd_import
  File "<frozen importlib._bootstrap>", line 991, in _find_and_load
  File "<frozen importlib._bootstrap>", line 975, in _find_and_load_unlocked
  File "<frozen importlib._bootstrap>", line 671, in _load_unlocked
  File "<frozen importlib._bootstrap_external>", line 848, in exec_module
  File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/other/vibrate14/__init__.py", line 1, in <module>
    from .adapter import Vibrate14
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/other/vibrate14/adapter.py", line 5, in <module>
    from algorithm.sclib.vibrate.vibrate import Vibrate
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/sclib/vibrate/vibrate.py", line 13, in <module>
    from .time_domain_features import TimeDomainFeatures
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/algorithm/sclib/vibrate/time_domain_features.py", line 11, in <module>
    import numba as nb
  File "/usr/local/lib/python3.8/site-packages/numba/__init__.py", line 88, in <module>
    from numba.core.decorators import (cfunc, generated_jit, jit, njit, stencil,
  File "/usr/local/lib/python3.8/site-packages/numba/core/decorators.py", line 12, in <module>
    from numba.stencils.stencil import stencil
  File "/usr/local/lib/python3.8/site-packages/numba/stencils/stencil.py", line 11, in <module>
    from numba.core import types, typing, utils, ir, config, ir_utils, registry
  File "/usr/local/lib/python3.8/site-packages/numba/core/registry.py", line 5, in <module>
    from numba.core import utils, typing, dispatcher, cpu
  File "/usr/local/lib/python3.8/site-packages/numba/core/dispatcher.py", line 13, in <module>
    from numba.core import (
  File "/usr/local/lib/python3.8/site-packages/numba/core/compiler.py", line 6, in <module>
    from numba.core import (utils, errors, typing, interpreter, bytecode, postproc,
  File "/usr/local/lib/python3.8/site-packages/numba/core/callconv.py", line 13, in <module>
    from numba.core.base import PYOBJECT, GENERIC_POINTER
  File "/usr/local/lib/python3.8/site-packages/numba/core/base.py", line 20, in <module>
    from numba.cpython import builtins
  File "/usr/local/lib/python3.8/site-packages/numba/cpython/builtins.py", line 536, in <module>
    from numba.core.typing.builtins import IndexValue, IndexValueType
  File "/usr/local/lib/python3.8/site-packages/numba/core/typing/builtins.py", line 22, in <module>
    @infer_global(print)
  File "/usr/local/lib/python3.8/site-packages/numba/core/typing/templates.py", line 1271, in register_global
    if getattr(mod, val.__name__) is not val:
AttributeError: module 'pyflink.fn_execution.beam.beam_sdk_worker_main' has no attribute 'print'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 267, in _execute
    response = task()
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 340, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 580, in do_instruction
    return getattr(self, request_type)(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 611, in process_bundle
    bundle_processor = self.bundle_processor_cache.get(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py", line 441, in get
    processor = bundle_processor.BundleProcessor(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 863, in __init__
    self.ops = self.create_execution_tree(self.process_bundle_descriptor)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 916, in create_execution_tree
    return collections.OrderedDict([(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 919, in <listcomp>
    get_operation(transform_id))) for transform_id in sorted(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 806, in wrapper
    result = cache[args] = func(*args)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 898, in get_operation
    transform_consumers = {
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 899, in <dictcomp>
    tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 899, in <listcomp>
    tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 806, in wrapper
    result = cache[args] = func(*args)
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 903, in get_operation
    return transform_factory.create_operation(
  File "/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1198, in create_operation
    return creator(self, transform_id, transform_proto, payload, consumers)
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/beam/beam_operations.py", line 136, in create_data_stream_keyed_process_function
    return _create_user_defined_function_operation(
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/beam/beam_operations.py", line 206, in _create_user_defined_function_operation
    return beam_operation_cls(
  File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 249, in pyflink.fn_execution.beam.beam_operations_fast.StatefulFunctionOperation.__init__
  File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 132, in pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.__init__
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/datastream/process/operations.py", line 127, in open
    self.open_func()
  File "/usr/local/lib/python3.8/site-packages/pyflink/fn_execution/datastream/process/operations.py", line 296, in open_func
    process_function.open(runtime_context)
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/work_flow/workflow/functions/operator_functions.py", line 1064, in open
    class_instance = import_class_lib(plugin_fun[:plugin_fun.find('.')], plugin_fun[plugin_fun.find('.')+1:], "function")
  File "/tmp/python-dist-1930ab4c-92be-4ed5-8076-64b35731e0ef/python-files/63370/63370/work_flow/wfutils/flink_importlib.py", line 155, in import_class_lib
    raise Exception(f'模块: {package}.{val_name} 导入失败, {exce}')
Exception: 模块: algorithm.other.vibrate14.function 导入失败, module 'pyflink.fn_execution.beam.beam_sdk_worker_main' has no attribute 'print'

  at org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:180)
  at org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:160)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onMessage(ServerCalls.java:262)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.ForwardingServerCallListener.onMessage(ForwardingServerCallListener.java:33)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.Contexts$ContextualizedServerCallListener.onMessage(Contexts.java:76)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:318)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:301)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:834)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
  at org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
  ... 3 more