Improve examples in the blog of PyFlink
diff --git a/_posts/2020-04-09-pyflink-udf-support-flink.md b/_posts/2020-04-09-pyflink-udf-support-flink.md
index 1c655e1..40134f8 100644
--- a/_posts/2020-04-09-pyflink-udf-support-flink.md
+++ b/_posts/2020-04-09-pyflink-udf-support-flink.md
@@ -166,7 +166,7 @@
@udf(input_types=[DataTypes.BIGINT(), DataTypes.BIGINT()], result_type=DataTypes.BIGINT())
def add(i, j):
from mpmath import fadd # add third-party dependency
- return int(fadd(1, 2))
+ return int(fadd(i, j))
```
To make it available on the worker node that does not contain the dependency, you can specify the dependencies with the following commands and API:
diff --git a/content/2020/04/09/pyflink-udf-support-flink.html b/content/2020/04/09/pyflink-udf-support-flink.html
index 294ff28..61a976f 100644
--- a/content/2020/04/09/pyflink-udf-support-flink.html
+++ b/content/2020/04/09/pyflink-udf-support-flink.html
@@ -347,7 +347,7 @@
<div class="highlight"><pre><code class="language-python"><span class="nd">@udf</span><span class="p">(</span><span class="n">input_types</span><span class="o">=</span><span class="p">[</span><span class="n">DataTypes</span><span class="o">.</span><span class="n">BIGINT</span><span class="p">(),</span> <span class="n">DataTypes</span><span class="o">.</span><span class="n">BIGINT</span><span class="p">()],</span> <span class="n">result_type</span><span class="o">=</span><span class="n">DataTypes</span><span class="o">.</span><span class="n">BIGINT</span><span class="p">())</span>
<span class="k">def</span> <span class="nf">add</span><span class="p">(</span><span class="n">i</span><span class="p">,</span> <span class="n">j</span><span class="p">):</span>
<span class="kn">from</span> <span class="nn">mpmath</span> <span class="kn">import</span> <span class="n">fadd</span> <span class="c"># add third-party dependency</span>
- <span class="k">return</span> <span class="nb">int</span><span class="p">(</span><span class="n">fadd</span><span class="p">(</span><span class="mi">1</span><span class="p">,</span> <span class="mi">2</span><span class="p">))</span></code></pre></div>
+ <span class="k">return</span> <span class="nb">int</span><span class="p">(</span><span class="n">fadd</span><span class="p">(</span><span class="n">i</span><span class="p">,</span> <span class="n">j</span><span class="p">))</span></code></pre></div>
<p>To make it available on the worker node that does not contain the dependency, you can specify the dependencies with the following commands and API:</p>
