Add the getName() method in order to obtain the applied label to the Trident stream. #2792
Conversation
This file contains 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
|
The changes look good to me. Please raise an issue at https://issues.apache.org/jira and rename this PR and the commit message to contain the issue number. |
* [STORM-3895] Add JDK-17 build * [STORM-3895] Add command line options in maven test for JDK17 or higher - to allow reflection on java.base * [STORM-3895] Allow reflection in external/storm-casandra when running test under JDK17 * [STORM-3895] Move introspection arguments to individual poms and make specific overrides based on JDK. * [STORM-3895] Increase memory to avoid jdk8 test failures.
Signed-off-by: Julien Nioche <[email protected]>
Missing dependency prevents Storm from being built, fixes apache#3940
…, and allow introspection as needed. (apache#3558)
Signed-off-by: Julien Nioche <[email protected]>
Synchronize access to map in Multi*Metric; fixes STORM-3944
* [STORM-3884] Update calcite to 1.16.0
…ed (apache#3526) * [STORM-3900] Update cassandra version. * [STORM-3900] determine cassandra.version.noPatch string from cassandra.version for use in CVE suppression file url * [STORM-3900] Add cassandra.version.noPatch property and remove derivation from cassandra.verision * [STORM-3901] Upgrade Kryo from version 4 to 5 and remove reflectasm-shaded dependency. * [STORM-3901] Update licenses * [STORM-3901] Further changes to DEPENDENCY-LICENSES * [STORM-3901] Update LICENSE-binary * [STORM-3900] Update cassandra version. * [STORM-3900] determine cassandra.version.noPatch string from cassandra.version for use in CVE suppression file url * [STORM-3900] Add cassandra.version.noPatch property and remove derivation from cassandra.verision * [STORM-3901] Upgrade Kryo from version 4 to 5 and remove reflectasm-shaded dependency. * [STORM-3901] Update licenses * [STORM-3901] Further changes to DEPENDENCY-LICENSES * [STORM-3901] Update licenses * [STORM-3901] Further changes to DEPENDENCY-LICENSES * STORM-3901 - "kyro-shade" does not exist in Kyro 5.4.0 * STORM-3884 - Fix license files * STORM-3901 - Fix license files --------- Co-authored-by: Richard Zowalla <[email protected]>
[STORM-3925] Allow user resources (in WorkerTopologyContext) to be set by Worker Hooks
[STORM-3992]Print stack trace upon Exception when getting heartbeat timeout
* STORM-3995 - commons-text 1.11.0
…brocksdbjni-win64.dll
STORM-3998 - Guava 32.1.3-jre STORM-3997 - Netty 4.1.100
STORM-3994 - LocalCluster init fails on Windows because of missing librocksdbjni-win64.dll
STORM-4001 - log4j2 2.21.1
Upgrade Jedis Library to 5.x --------- Co-authored-by: Richard Zowalla <[email protected]>
* Avoid NPE in the Values Constructor * Fix Values Constructor as per review comments * remove unwanted condition * Addressing code review comments * Fix checkstyle * Fix JUnit 4 -> JUnit 5 --------- Co-authored-by: Kishor Patil <[email protected]> Co-authored-by: Richard Zowalla <[email protected]>
|
Fixed with c158dee |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
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.
Being able to get the applied label of a Trident stream could be useful in case of complex Trident topology design. The getter returns the
Stringcorresponding to the_nameattribute of theStreamobject.