Class CheckpointStatistics.FailedCheckpointStatistics

    • Constructor Detail

      • FailedCheckpointStatistics

        public FailedCheckpointStatistics​(long id,
                                          CheckpointStatsStatus status,
                                          boolean savepoint,
                                          String savepointFormat,
                                          long triggerTimestamp,
                                          long latestAckTimestamp,
                                          long checkpointedSize,
                                          long stateSize,
                                          long duration,
                                          long alignmentBuffered,
                                          long processedData,
                                          long persistedData,
                                          int numSubtasks,
                                          int numAckSubtasks,
                                          org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType,
                                          Map<JobVertexID,​TaskCheckpointStatistics> checkpointingStatisticsPerTask,
                                          long failureTimestamp,
                                          @Nullable
                                          String failureMessage)