[
https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823980#comment-15823980
]
ASF GitHub Bot commented on FLINK-5480:
---------------------------------------
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3117#discussion_r96228294
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
---
@@ -272,12 +273,20 @@ public void setStateKeySerializer(TypeSerializer<?>
stateKeySerializer) {
this.stateKeySerializer = stateKeySerializer;
}
- public String getTransformationId() {
- return transformationId;
+ public String getTransformationUID() {
+ return transformationUID;
}
- void setTransformationId(String transformationId) {
- this.transformationId = transformationId;
+ void setTransformationUID(String transformationId) {
+ this.transformationUID = transformationId;
+ }
+
+ public String getUserHash() {
+ return userHash;
+ }
+
+ public void setUserHash(String userHash) {
+ this.userHash = userHash;
--- End diff --
Since this is executed on the client before submitting the job it might be
helpful to do some early sanity checking here. The expected String is a hex
representation of a JobVertexID
> User-provided hashes for operators
> ----------------------------------
>
> Key: FLINK-5480
> URL: https://issues.apache.org/jira/browse/FLINK-5480
> Project: Flink
> Issue Type: Improvement
> Components: DataStream API
> Affects Versions: 1.2.0
> Reporter: Stefan Richter
> Assignee: Stefan Richter
>
> We could allow users to provided (alternative) hashes for operators in a
> StreamGraph. This can make migration between Flink versions easier, in case
> the automatically produced hashes between versions are incompatible. For
> example, users could just copy the old hashes from the web ui to their job.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
