Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FLINK-11838] please ignore this PR #18275

Commits on Jan 5, 2022

  1. [FLINK-11838][project] Add flink-gs-fs-hadoop project

    Add new project for GS file system and recoverable writer. This includes FileSystemFactory SPI wireup, but with no recoverable writer (yet).
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    b48888f View commit details
    Browse the repository at this point in the history
  2. [FLINK-11838][flink-gs-fs-hadoop] Add BlobStorage abstraction

    Add interfaces to abstract away direct access to the Google Storage API, both to simplify that access and to make it mockable.
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    93a20ea View commit details
    Browse the repository at this point in the history
  3. [FLINK-11838][flink-gs-fs-hadoop] Implement BlobStorage for Google St…

    …orage
    
    Add GSBlobStorage, an implementation of BlobStorage against the Google Storage API.
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    96bc484 View commit details
    Browse the repository at this point in the history
  4. [FLINK-11838][flink-gs-fs-hadoop] Add utility functions

    Add some utility functions used by the recoverable writer. Includes unit tests.
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    5375da2 View commit details
    Browse the repository at this point in the history
  5. [FLINK-11838][flink-gs-fs-hadoop] Implement BlobStorage for unit testing

    Add MockBlobStorage, an implementation of BlobStorage against an in-memory store.
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    a2cdead View commit details
    Browse the repository at this point in the history
  6. [FLINK-11838][flink-gs-fs-hadoop] Implement recoverable writer

    Implements RecoverableWriter against the BlobStorage abstraction and wires up HadoopFileSystem.createRecoverableWriter for GS. Includes unit tests.
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    a485175 View commit details
    Browse the repository at this point in the history
  7. Configuration menu
    Copy the full SHA
    805592f View commit details
    Browse the repository at this point in the history
  8. [FLINK-11838][flink-gs-fs-hadoop] Improve blob storage abstraction

    Rename BlobStorage and GSBlobStorage to GSBlobStorage and GSBlobStorageImpl
    Rename BlobStorage.write to BlobStorage#writeBlob
    Remove ability to specify blob content type
    Introduce GSBlobIdentifier abstraction
    Remove BlobId normalization (no longer needed)
    Move nested interfaces/classes to bottom
    Add count<=32 precondition for GSBlobStorageImpl#compose
    Other code improvements
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    644dac2 View commit details
    Browse the repository at this point in the history
  9. [FLINK-11838][flink-gs-fs-hadoop] Improve/simplify config and modify …

    …base classes for new scheme/project
    
    Remove unnecessary config options
    Better handle optional config options
    Change WRITER_CHUNK_SIZE to use .memoryType() instead of .intType() and add check that value is multiple of 256KB
    Make HadoopFileSystem and FileSystem aware of gs: scheme and flink-gs-fs-hadoop project
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    192e970 View commit details
    Browse the repository at this point in the history
  10. [FLINK-11838][flink-gs-fs-hadoop] Implement recoverable writer improv…

    …ements
    
    Refactor utilities
    Validate gs scheme in parseUri
    Remove GSRecoverableWriteState, replace with immutable GSResumeRecoverable and private state in GSRecoverableFsDataOutputStream
    Fix commit, commitAfterRecovery, cleanupRecoverableState, and requiresCleanupOfRecoverableState to implement proper commit and cleanup algorithms
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    32412b0 View commit details
    Browse the repository at this point in the history
  11. [FLINK-11838][flink-gs-fs-hadoop] Exclude javax.annotation-api artifact

    Exclude javax.annotation-api artifact because of its GPLv2 license, which cannot be included in Flink artifacts. Everything seems to build and run fine without it.
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    758431f View commit details
    Browse the repository at this point in the history
  12. [FLINK-11838][flink-gs-fs-hadoop] Various improvements based on revie…

    …w feedback
    
    Remove unnecessary throw clauses
    Inline call to preconditions.checkNotNull
    Use unmodifiable list for component object ids in GSResumeRecoverable
    Overload GSBlobStorage#writeBlob to allow setting chunk size, remove setChunkSize on GSBlobStorage#WriteChannel
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    3a558bb View commit details
    Browse the repository at this point in the history
  13. Configuration menu
    Copy the full SHA
    d309ba7 View commit details
    Browse the repository at this point in the history
  14. Configuration menu
    Copy the full SHA
    d8efdfb View commit details
    Browse the repository at this point in the history
  15. [FLINK-11838][flink-gs-fs-hadoop] Improve commit/compose code, includ…

    …ing separating commit vs. resume recoverables
    
    Separate commit vs. resume recoverables
    Refactor utility functions
    Add javadoc comments
    galenwarren committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    3743db5 View commit details
    Browse the repository at this point in the history
  16. Configuration menu
    Copy the full SHA
    30a5736 View commit details
    Browse the repository at this point in the history
  17. Configuration menu
    Copy the full SHA
    9c54fb5 View commit details
    Browse the repository at this point in the history
  18. Configuration menu
    Copy the full SHA
    297f806 View commit details
    Browse the repository at this point in the history
  19. Configuration menu
    Copy the full SHA
    8849631 View commit details
    Browse the repository at this point in the history
  20. Configuration menu
    Copy the full SHA
    c573fb0 View commit details
    Browse the repository at this point in the history
  21. Configuration menu
    Copy the full SHA
    cacaf63 View commit details
    Browse the repository at this point in the history
  22. Configuration menu
    Copy the full SHA
    146ff33 View commit details
    Browse the repository at this point in the history
  23. Configuration menu
    Copy the full SHA
    2ffcee4 View commit details
    Browse the repository at this point in the history
  24. Configuration menu
    Copy the full SHA
    cce1d94 View commit details
    Browse the repository at this point in the history
  25. Configuration menu
    Copy the full SHA
    69476a2 View commit details
    Browse the repository at this point in the history
  26. Configuration menu
    Copy the full SHA
    f060fe7 View commit details
    Browse the repository at this point in the history
  27. show download logs

    rmetzger committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    a659f92 View commit details
    Browse the repository at this point in the history
  28. Configuration menu
    Copy the full SHA
    2bab05b View commit details
    Browse the repository at this point in the history
  29. Configuration menu
    Copy the full SHA
    5596d54 View commit details
    Browse the repository at this point in the history

Commits on Jan 6, 2022

  1. pin grpc version everywhere

    rmetzger committed Jan 6, 2022
    Configuration menu
    Copy the full SHA
    6e568b8 View commit details
    Browse the repository at this point in the history
  2. fix typo

    rmetzger committed Jan 6, 2022
    Configuration menu
    Copy the full SHA
    c760512 View commit details
    Browse the repository at this point in the history