[samza] branch master updated: SAMZA-2676: Pass parameter into subset, not format (#1523)

[cameronlee]

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

cameronlee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 041075c  SAMZA-2676: Pass parameter into subset, not format (#1523)
041075c is described below

commit 041075cd5d83e20952970c2be17e3e3911d9ccd8
Author: Jon Bringhurst <j...@bringhurst.org>
AuthorDate: Tue Aug 31 11:17:18 2021 -0700

    SAMZA-2676: Pass parameter into subset, not format (#1523)
    
    There is an unused parameter on this format string. Removing it should
    preserve the existing behavior.
---
 samza-core/src/main/java/org/apache/samza/config/StreamConfig.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/samza-core/src/main/java/org/apache/samza/config/StreamConfig.java 
b/samza-core/src/main/java/org/apache/samza/config/StreamConfig.java
index 950cf10..9f774b8 100644
--- a/samza-core/src/main/java/org/apache/samza/config/StreamConfig.java
+++ b/samza-core/src/main/java/org/apache/samza/config/StreamConfig.java
@@ -278,7 +278,7 @@ public class StreamConfig extends MapConfig {
    * Returns a list of all SystemStreams that have a serde defined from the 
config file.
    */
   public Set<SystemStream> getSerdeStreams(String systemName) {
-    Config subConf = subset(String.format("systems.%s.streams.", systemName, 
true));
+    Config subConf = subset(String.format("systems.%s.streams.", systemName), 
true);
     Set<SystemStream> legacySystemStreams = subConf.keySet().stream()
       .filter(k -> k.endsWith(MSG_SERDE) || k.endsWith(KEY_SERDE))
       .map(k -> {