Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22369

RocksDB state backend might occur ClassNotFoundException when deserializing on TM side

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Fixed
    • 1.13.0
    • 1.13.0
    • None

    Description

      FLINK-19467 introduced new EmbeddedRocksDBStateBackend and added new interface EmbeddedRocksDBStateBackend#setLogger to ensures users of the legacy RocksDBStateBackend see consistent logging.

      However, this change introduce another non transient logger and it would be deserialized on TM side first. If the client has different log4j implementation from TM side, we might meet ClassNotFoundException:

      Attachments

        Issue Links

          is caused by

          Sub-task - The sub-task of the issue FLINK-19467 Implement HashMapStateBackend and EmbeddedRocksDBStateBackend

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #15688

          Activity

            People

              sjwiesman Seth Wiesman
              yunta Yun Tang
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: