Skip to main content

Search Bar Functionalities by Screen

1. Tracer Screen​

Record​

  • Data (STRING): The main payload of the record.
  • Type (STRING): Input/output.
  • Trace_ID (STRING): Unique trace identifier.
  • Event_time (TIME): Event timestamp.
  • Log_time (TIME): Log timestamp.
  • Key (STRING): The key associated with the record (if any).
  • Is_ignored (BOOLEAN): Indicates if the record is ignored.
  • Related_operator (STRING): The operator's name from the job graph, accessible for searching.
  • OperatorId (STRING): Unique identifier for the operator.
  • OperatorProcessId (NUMBER): ID representing the operator process.
  • IsWindow (BOOLEAN): Indicates if the record enters a window-type operator.

State​

  • Name (STRING): Name of the state.
  • Type (STRING): Type of the state.
  • Data (JSON): State-related data.
  • Related_operator (STRING): The operator that belongs to this state.

Operator​

  • Name (STRING): The operator name.
  • Operator_ID (STRING): Unique identifier of the operator.
  • Type (STRING): Type of the operator (e.g., source, sink, map, reduce).
  • State_Size (NUMBER): Displays the overall state size if it manages multiple states.
  • Records_In (NUMBER): Number of records entering the operator.
  • Records_Out (NUMBER): Number of records exiting the operator.
  • SubTaskId (NUMBER): The sub-task ID (0 up to the level of parallelism).
  • Parallelism (NUMBER): Number of parallel instances of the operator.
  • MaxParallelism (NUMBER): Maximum parallelism level for the operator (important for state partitioning and scaling).

2. Job Performance Screen​

  • Only Time Filter:
    • Time-based filtering (TIME) using the BETWEEN operator.
    • Includes a brush feature for interactive time range selection.

3. State Investigation Screen​

Record (RecordIn)​

  • Data (STRING): The main record content.
  • Trace_ID (STRING): Unique trace identifier.
  • Event_time (TIME): Event timestamp.
  • Log_time (TIME): Log timestamp.
  • Key (STRING): The key associated with the record (if any).

StateBefore​

  • Name (STRING): Name of the state before processing.
  • Type (STRING): Type of the state (e.g., string, number).
  • Value (JSON): Value of the state before processing.

StateAfter​

  • Name (STRING): Name of the state after processing.
  • Type (STRING): Type of the state.
  • Value (JSON): Value of the state after processing.

4. Lineage Screen​

Record​

  • Data (STRING): The main record content.
  • Trace_ID (STRING): Unique trace identifier.
  • Event_time (TIME): Event timestamp.
  • Log_time (TIME): Log timestamp.
  • Key (STRING): The key associated with the record (if any).

5. Logs Screen​

Log​

  • Timestamp (TIME): Log entry timestamp.
  • Level (STRING): Log severity level (e.g., ERROR, INFO).
  • Cluster (STRING): The cluster in which the log was generated.
  • Job_ID (STRING): Associated Flink job ID (if relevant).
  • Component (STRING): The JobManager or TaskManager ID.
  • Content (STRING): Full log content, including the stack trace.

6. State Insights Screen​

  • Only Time Filter:
    • Time-based filtering (TIME) using the BETWEEN operator.
    • Includes a brush feature for interactive time selection.

7. Jobs Screen​

Job​

  • ID (STRING): Unique job identifier.
  • Label (STRING): Custom label for the job.
  • Name (STRING): Job name.
  • Type (STRING): Job type (e.g., batch, streaming).
  • RunStart (TIME): Start time of the job.
  • Duration (NUMBER): Total duration of the job.
  • NumOfRecords (NUMBER): Total number of records processed by the job.