You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@streampipes.apache.org by ri...@apache.org on 2021/08/10 19:32:26 UTC

[incubator-streampipes] branch dev updated (1648454 -> 91b7ff6)

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.


    from 1648454  Merge pull request #47 from zhangjun0x01/flink-1.13
     new 59ee2c9  flink 1.13 rest port config
     new 353a064  Keep kafka consumer group for Pipeline action and sepas
     new 0013a17  Avoid special characters in kafka consumer group id of processor
     new 91b7ff6  Merge pull request #48 from yangdh1225/dev

The 5887 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../java/org/apache/streampipes/commons/MD5.java   | 62 ++++++++++++++++++++++
 .../java/org/apache/streampipes/commons/Utils.java | 13 +++++
 .../manager/execution/http/PipelineExecutor.java   |  4 +-
 streampipes-wrapper-flink/pom.xml                  |  6 +++
 .../streampipes/wrapper/flink/FlinkRuntime.java    |  2 +
 5 files changed, 86 insertions(+), 1 deletion(-)
 create mode 100644 streampipes-commons/src/main/java/org/apache/streampipes/commons/MD5.java