code: def _find_flink_source_root():
      """
      Find the flink source root directory.
      """
      try:
          return os.path.abspath(
              os.path.dirname(os.path.abspath(__file__)) + "/../../"
          )
      except Exception:
          pass
      logging.error(
          "Could not find valid flink source root directory in current environment."
      )
      sys.exit(-1)
  
imports: import glob
  import logging
  import os
  import sys
label_desc: Use image node_id 4 for calling a global function with example usage: _find_flink_source_root() and returns: os