clear query| facets| time Search criteria: .   Results from 1 to 10 from 299 (0.0s).
Loading phrases to help you
refine your search...
Set flink-conf parameters dynamicly - Flink - [mail # user]
...Hi Vasily Melnik,If you use yarn mode, you could try to use the option "-yD " during submitting the job [1] to change the configuration dynamically.[1] https://ci.apache.org/projects/flink/f...
   Author: Dian Fu , 2019-09-19, 15:10
[FLINK-14019] Python environment and dependency management - Flink - [issue]
...A Python user-defined functions may depend on third party dependencies. We should provide a proper way to handle it: Provide a way to let users specifying the dependencies Provide a way to l...
http://issues.apache.org/jira/browse/FLINK-14019    Author: Dian Fu , 2019-09-19, 12:51
In yarn-cluster model, mapState not support transfer value - Flink - [mail # user]
...Hi Shengjk1,You should call "mapState.put(key,objectList);" manually after calling "objectList.add(stringObjectTuple2.f1);" to write it to the state backend. This is because objectList is ju...
   Author: Dian Fu , 2019-09-19, 12:08
MapState not support  transfer  value - Flink - [mail # user]
...Hi Shengjk1,You should call "mapState.put(key,objectList);" manually after calling "objectList.add(stringObjectTuple2.f1);" to write it to the state backend. This is because objectList is ju...
   Author: Dian Fu , 2019-09-19, 12:02
[FLINK-14014] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution - Flink - [issue]
...PythonScalarFunctionRunner is responsible for Python ScalarFunction execution and it only handles the Python ScalarFunction execution and nothing else. So its logic should be very simple, fo...
http://issues.apache.org/jira/browse/FLINK-14014    Author: Dian Fu , 2019-09-18, 15:14
[FLINK-14017] Support to start up Python worker in process mode - Flink - [issue]
...We employ Apache Beam's portability frameowork for the Python UDF execution. However, there is only a golang implementation for the boot script to start up SDK harness in Beam. It’s used by ...
http://issues.apache.org/jira/browse/FLINK-14017    Author: Dian Fu , 2019-09-18, 15:11
[FLINK-14015] Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution - Flink - [issue]
...PythonScalarFunctionOperator is a standalone StreamOperator and it doesn’t need to how the Python ScalarFunctions are executed which is the responsibility of PythonScalarFunctionRunner: It i...
http://issues.apache.org/jira/browse/FLINK-14015    Author: Dian Fu , 2019-09-18, 13:50
How exactly does Idle-state retention policy work? - Flink - [mail # user]
...Hi Srikanth,As you side, the idle-state retention time configuration only works for "group aggregate" and "over aggregate".Regarding to your question:> If it happens to be that the 'ip' a...
   Author: Dian Fu , 2019-09-18, 05:53
Difference between data stream window function and cep within - Flink - [mail # user]
...Hi Joshua,There is no tumbling/sliding window underlying the cep within implementation. The difference between datastream window and cep within is that:1) Regarding to datastream window, the...
   Author: Dian Fu , 2019-09-18, 01:42
[FLINK-13999] Correct the documentation of MATCH_RECOGNIZE - Flink - [issue]
...Regarding to the following example] in the doc:SELECT *FROM Ticker    MATCH_RECOGNIZE (        PARTITION BY symbol        ORDER BY rowtime&n...
http://issues.apache.org/jira/browse/FLINK-13999    Author: Dian Fu , 2019-09-16, 09:41