You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2018/08/14 06:58:24 UTC

[incubator-pulsar] branch master updated: If --customSerdeInputs is specified, please update the right variable (#2369)

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

sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 4810a26  If --customSerdeInputs is specified, please update the right variable (#2369)
4810a26 is described below

commit 4810a26e370f3a253fe98222d486433a91f04cd1
Author: Sanjeev Kulkarni <sa...@gmail.com>
AuthorDate: Mon Aug 13 23:58:22 2018 -0700

    If --customSerdeInputs is specified, please update the right variable (#2369)
    
    ### Motivation
    
    When we made the switch to get away from camel-case arguments for functions, we moved the camel case arguments as deprecated, so users can still use them but they are hidden. But that change missed to take --customSerdeInputs into account. This fixes that ommision
    
    ### Modifications
    
    Describe the modifications you've done.
    
    ### Result
    
    After your change, what will change.
---
 .../src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java          | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
index dd1ef3d..5f52313 100644
--- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
+++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
@@ -317,6 +317,7 @@ public class CmdFunctions extends CmdBase {
             if (!StringUtils.isBlank(DEPRECATED_topicsPattern)) topicsPattern = DEPRECATED_topicsPattern;
             if (!StringUtils.isBlank(DEPRECATED_logTopic)) logTopic = DEPRECATED_logTopic;
             if (!StringUtils.isBlank(DEPRECATED_outputSerdeClassName)) outputSerdeClassName = DEPRECATED_outputSerdeClassName;
+            if (!StringUtils.isBlank(DEPRECATED_customSerdeInputString)) customSerdeInputString = DEPRECATED_customSerdeInputString;
             if (!StringUtils.isBlank(DEPRECATED_fnConfigFile)) fnConfigFile = DEPRECATED_fnConfigFile;
             if (DEPRECATED_processingGuarantees != FunctionConfig.ProcessingGuarantees.ATLEAST_ONCE) processingGuarantees = DEPRECATED_processingGuarantees;
             if (!StringUtils.isBlank(DEPRECATED_userConfigString)) userConfigString = DEPRECATED_userConfigString;