flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5480) User-provided hashes for operators
Date Wed, 18 Jan 2017 14:07:26 GMT

    [ https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15828125#comment-15828125
] 

ASF GitHub Bot commented on FLINK-5480:
---------------------------------------

Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/3117#discussion_r96640105
  
    --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphUserHashHasher.java
---
    @@ -18,27 +18,29 @@
     
     package org.apache.flink.streaming.api.graph;
     
    -import org.apache.flink.streaming.api.operators.ChainingStrategy;
    -import org.apache.flink.streaming.api.operators.StreamOperator;
    -import org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner;
     import org.apache.flink.util.StringUtils;
     
     import java.util.HashMap;
     import java.util.Map;
     
     /**
    - * StreamGraphHasher that works with user provided hashes.
    + * StreamGraphHasher that works with user provided hashes. This us useful in case we
want to set (alternative) hashes
    --- End diff --
    
    This us useful -> This is useful


> 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)

Mime
View raw message