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

[sijie]

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 <sanjee...@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;