[FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil #3819
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
- Move new 'Types' class to 'common' scope, not 'java api'. - Make the method names the same in Scala and Java
…tingSettings Cleanup to consistently use - checkpoint for the overall fault tolerance mechanism and procedure - snapshot for an operators state snapshot that is part of a checkpoint
…r is single use. This reduces the public API of the StreamingJobGraphGenerator to a static createJobGraph() method, which internally instantiates a generator, creates the job, and drops the generator.
This more intuitivce name clarifies the role of the class. This also marks the class as PublicEvolving, as it is not actually used as an internal class.
…ed before run This closes apache#3738.
Properly reset the "pipeline breaker" upon closing. This closes apache#3747
This closes apache#3749
…stically Sorts files read from Flink's lib directory and places the distribution JAR to the end of the CLASSPATH. This closes apache#3632
… correctly This closes apache#3600
…k && ListViaRangeSpeedMiniBenchmark This closes apache#3652
…s between entries This closes apache#3706
…de#getValueAsText This closes apache#3679
This will be re-added when we have a coherent plan for Docker support and after the official Docker images are available. This closes apache#3658
…a the web UI This closes apache#3657
… start/stop scripts This way, if all slaves refer to "localhost", we do not require ssh at all. This closes apache#3298
…link-examples. This closes apache#2460.
…e set. This closes apache#3739.
…owed aggregates. This closes apache#3863.
…lds in SQL. This closes apache#3879.
…Right joins. This closes apache#3673.
…e if previous serializer is unavailable This closes apache#3882.
…Writable hooks This commit makes the method hooks for defining compatibile serialization versions of VersionedIOReadableWritables more restricted. Functionally everything remains the same, but with lesser space for error-prone user implementations. It also allows for a better error message to indicate version mismatch. This closes apache#3883.
…defined Previously, if a serializer determines that state migration needs to be performed but could not provide a fallback convert deserializer, it would use CompatibilityResult.requiresMigration(null). This commit makes this option more explicit by having a CompatibilityResult.requiresMigration() option that takes no parameters. This improves how the user perceives the API without having to rely on the Javadoc that it is allowed to have no fallback convert deserializer. Consequently, when using CompatibilityResult.requiresMigration(TypeDeserializer), the provided argument cannot be null. This closes apache#3886.
…treamTableSink interface.
…shared state in incremental checkpoints
… in RocksDBKeyedStateBackend
…ons of (un)/registerSharedStates
Author
|
Use https://github.com/apache/flink/pull/3904 instead |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
20 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
…tUtil
Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the How To Contribute guide.
In addition to going through the list, please provide a meaningful description of your changes.
General
Documentation
Tests & Build
mvn clean verifyhas been executed successfully locally or a Travis build has passed