[GitHub] [flink] flinkbot commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread GitBox
flinkbot commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics URL: https://github.com/apache/flink/pull/9684#issuecomment-531713590 ## CI report: * c378433c3a478702087ba46f397acd27bc23fa13 : UNKNOWN -

[GitHub] [flink] flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914 ## CI report: * 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE [Build](https://travis-ci.com/flink-ci/flink/buil

[GitHub] [flink] flinkbot edited a comment on issue #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese

2019-09-16 Thread GitBox
flinkbot edited a comment on issue #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese URL: https://github.com/apache/flink/pull/9677#issuecomment-531181543 ## CI report: * 016d4bd7b25c6b0e2eeab6a995706f8f5c6fb816 : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324588222 ## File path: f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324574290 ## File path: f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324562782 ## File path: f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324565978 ## File path: f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324566426 ## File path: f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324581086 ## File path: f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324569499 ## File path: f

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324554848 ## File path: f

[GitHub] [flink] flinkbot commented on issue #9687: [hotfix][docs] Fix some typos in Hive docs

2019-09-16 Thread GitBox
flinkbot commented on issue #9687: [hotfix][docs] Fix some typos in Hive docs URL: https://github.com/apache/flink/pull/9687#issuecomment-531712666 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[GitHub] [flink] hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunct

2019-09-16 Thread GitBox
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r324572045 ## File path: f

[GitHub] [flink] yangjf2019 opened a new pull request #9687: [hotfix][docs] Fix some typos in Hive docs

2019-09-16 Thread GitBox
yangjf2019 opened a new pull request #9687: [hotfix][docs] Fix some typos in Hive docs URL: https://github.com/apache/flink/pull/9687 ## What is the purpose of the change * Fix some typos in Hive docs. ## Brief change log *I modified the "docs/dev/table/hive/ind

[jira] [Resolved] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

2019-09-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14065. --- Resolution: Done Done via 67030031e712c732c864d91321afa3cd2cb466de > Log metric name when t

[GitHub] [flink] tillrohrmann closed pull request #9680: [FLINK-14065] Log metric name when the metric fails on registration/unregistration

2019-09-16 Thread GitBox
tillrohrmann closed pull request #9680: [FLINK-14065] Log metric name when the metric fails on registration/unregistration URL: https://github.com/apache/flink/pull/9680 This is an automated message from the Apache Git Servi

[jira] [Updated] (FLINK-13461) Distinguish between temporary tables and persisted tables

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13461: - Priority: Major (was: Blocker) > Distinguish between temporary tables and persisted tab

[jira] [Commented] (FLINK-13461) Distinguish between temporary tables and persisted tables

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930380#comment-16930380 ] Aljoscha Krettek commented on FLINK-13461: -- I moved this from "Blocker" to "Maj

[GitHub] [flink] flinkbot commented on issue #9686: [FLINK-14069] [core] Enable TimeUtils for all time units labels supported by scala Duration

2019-09-16 Thread GitBox
flinkbot commented on issue #9686: [FLINK-14069] [core] Enable TimeUtils for all time units labels supported by scala Duration URL: https://github.com/apache/flink/pull/9686#issuecomment-531709298 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-14077) get java.util.ConcurrentModificationException when push metrics to PushGateway

2019-09-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930379#comment-16930379 ] Till Rohrmann commented on FLINK-14077: --- [~zhangjun] please close this issue once

[jira] [Updated] (FLINK-14069) Enable TimeUtils to parse all time units labels supported by scala Duration

2019-09-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14069: --- Labels: pull-request-available (was: ) > Enable TimeUtils to parse all time units labels su

[GitHub] [flink] flinkbot edited a comment on issue #9583: [hotfix][configuration] Remove usages of deprecated options TASK_MANAGER_HEAP_MEMORY_MB and JOB_MANAGER_HEAP_MEMORY_MB

2019-09-16 Thread GitBox
flinkbot edited a comment on issue #9583: [hotfix][configuration] Remove usages of deprecated options TASK_MANAGER_HEAP_MEMORY_MB and JOB_MANAGER_HEAP_MEMORY_MB URL: https://github.com/apache/flink/pull/9583#issuecomment-526715510 ## CI report: * 6e904b5c61931e1cc84215ac297d1

[jira] [Commented] (FLINK-14068) Use Java's Duration instead of Flink's Time

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930378#comment-16930378 ] Aljoscha Krettek commented on FLINK-14068: -- I moved this from "Blocker" to "Maj

[jira] [Updated] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2019-09-16 Thread luojiangyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luojiangyu updated FLINK-14087: --- Description: There is the condition the RecordWriter sharing the ChannelSelector instance. When two

[GitHub] [flink] zhuzhurk opened a new pull request #9686: [FLINK-14069] [core] Enable TimeUtils for all time units labels supported by scala Duration

2019-09-16 Thread GitBox
zhuzhurk opened a new pull request #9686: [FLINK-14069] [core] Enable TimeUtils for all time units labels supported by scala Duration URL: https://github.com/apache/flink/pull/9686 ## What is the purpose of the change *Currently we are using scala Duration to parse duration configs.

[jira] [Updated] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13417: - Priority: Major (was: Blocker) > Bump Zookeeper to 3.5.5 > --- > >

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930377#comment-16930377 ] Aljoscha Krettek commented on FLINK-13417: -- I moved this from "Blocker" to "Maj

[jira] [Updated] (FLINK-14068) Use Java's Duration instead of Flink's Time

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14068: - Priority: Major (was: Blocker) > Use Java's Duration instead of Flink's Time >

[GitHub] [flink] tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-16 Thread GitBox
tillrohrmann commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324585687 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerFa

[jira] [Commented] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2019-09-16 Thread luojiangyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930376#comment-16930376 ] luojiangyu commented on FLINK-14087: [~zjwang] > throws java.lang.ArrayIndexOutOfBo

[GitHub] [flink] flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914 ## CI report: * 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE [Build](https://travis-ci.com/flink-ci/flink/buil

[jira] [Updated] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2019-09-16 Thread luojiangyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luojiangyu updated FLINK-14087: --- Description: There is the condition the RecordWriter sharing the ChannelSelector instance. When two

[GitHub] [flink] TisonKun commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
TisonKun commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531708070 Hi @wangxiyuan I revoke my change request above. After taking a look at the corresponding issue I know the root cause of this pull req

[GitHub] [flink] TisonKun commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
TisonKun commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531708289 @flinkbot run travis This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on issue #9685: [hotfix][runtime] Change return type for methods Execution#processFail(...)

2019-09-16 Thread GitBox
flinkbot commented on issue #9685: [hotfix][runtime] Change return type for methods Execution#processFail(...) URL: https://github.com/apache/flink/pull/9685#issuecomment-531707655 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Commented] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930374#comment-16930374 ] Aljoscha Krettek commented on FLINK-13999: -- I quickly talked to [~dawidwys] abo

[GitHub] [flink] flinkbot commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread GitBox
flinkbot commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics URL: https://github.com/apache/flink/pull/9684#issuecomment-531707663 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help t

[jira] [Updated] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2019-09-16 Thread luojiangyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luojiangyu updated FLINK-14087: --- Description: There is the condition the RecordWriter sharing the ChannelSelector instance. When two

[GitHub] [flink] GJL opened a new pull request #9685: [hotfix][runtime] Change return type for methods Execution#processFail(...)

2019-09-16 Thread GitBox
GJL opened a new pull request #9685: [hotfix][runtime] Change return type for methods Execution#processFail(...) URL: https://github.com/apache/flink/pull/9685 ## What is the purpose of the change *Change return types of above methods to void.* ## Brief change log

[jira] [Updated] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2019-09-16 Thread luojiangyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luojiangyu updated FLINK-14087: --- Attachment: (was: image-2019-09-16-17-17-55-097.png) > throws java.lang.ArrayIndexOutOfBoundsExc

[jira] [Updated] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13992: --- Labels: pull-request-available (was: ) > Refactor Optional parameter in InputGateWithMetric

[GitHub] [flink] TisonKun opened a new pull request #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread GitBox
TisonKun opened a new pull request #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics URL: https://github.com/apache/flink/pull/9684 ## What is the purpose of the change As consensus from community code style discussion, in `InputGat

[jira] [Created] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2019-09-16 Thread luojiangyu (Jira)
luojiangyu created FLINK-14087: -- Summary: throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner. Key: FLINK-14087 URL: https://issues.apache.org/jira/browse/FLINK-14087

[GitHub] [flink] TisonKun commented on issue #9583: [hotfix][configuration] Remove usages of deprecated options TASK_MANAGER_HEAP_MEMORY_MB and JOB_MANAGER_HEAP_MEMORY_MB

2019-09-16 Thread GitBox
TisonKun commented on issue #9583: [hotfix][configuration] Remove usages of deprecated options TASK_MANAGER_HEAP_MEMORY_MB and JOB_MANAGER_HEAP_MEMORY_MB URL: https://github.com/apache/flink/pull/9583#issuecomment-531706119 @flinkbot run travis -

[jira] [Closed] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

2019-09-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6949. Resolution: Duplicate > Add ability to ship custom resource files to YARN cluster > ---

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930357#comment-16930357 ] Aljoscha Krettek commented on FLINK-13025: -- [~yanghua] I'll help you get this i

[jira] [Commented] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

2019-09-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930358#comment-16930358 ] Till Rohrmann commented on FLINK-6949: -- Great to hear, then I'll close this issue.

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930355#comment-16930355 ] TisonKun commented on FLINK-13992: -- Thanks for your clarification [~azagrebin]! Now I u

[GitHub] [flink] flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

2019-09-16 Thread GitBox
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778 ## CI report: * ba87beba470b132b99ed606411ffc43847a72d8f : PENDING [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

2019-09-16 Thread GitBox
flinkbot edited a comment on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils URL: https://github.com/apache/flink/pull/9682#issuecomment-531697742 ## CI report: * 1513bd9a28bd35cc176554c957a61329fb0cabf4 : PENDING

[GitHub] [flink] wangxiyuan commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
wangxiyuan commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531702209 @TisonKun, hi, thanks for your comment. I don't know what scope is better, since this pr changed many modules. any suggestion? Than

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324557279 ## File path: flink-dist/src/main/flink-bin/bin/pyflink-udf-runner.sh ## @@ -0,

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324575806 ## File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324568387 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324573030 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324559723 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324570969 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324565952 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324574654 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324576320 ## File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324570432 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[GitHub] [flink] dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

2019-09-16 Thread GitBox
dianfu commented on a change in pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#discussion_r324573350 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,352 @@ +#

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930349#comment-16930349 ] Andrey Zagrebin commented on FLINK-13992: - True, IDE detection can be useful. I

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

2019-09-16 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930345#comment-16930345 ] liupengcheng commented on FLINK-14037: -- I enabled `-verbose:class` and this followi

[GitHub] [flink] flinkbot commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

2019-09-16 Thread GitBox
flinkbot commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778 ## CI report: * ba87beba470b132b99ed606411ffc43847a72d8f : UNKNOWN ---

[GitHub] [flink] flinkbot commented on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

2019-09-16 Thread GitBox
flinkbot commented on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils URL: https://github.com/apache/flink/pull/9682#issuecomment-531697742 ## CI report: * 1513bd9a28bd35cc176554c957a61329fb0cabf4 : UNKNOWN -

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

2019-09-16 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930343#comment-16930343 ] liupengcheng commented on FLINK-14037: -- [~zhuzh] Yes, the version of the libs you m

[GitHub] [flink] flinkbot commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

2019-09-16 Thread GitBox
flinkbot commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-531694429 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communi

[jira] [Updated] (FLINK-14081) Support precision of TimeType

2019-09-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14081: - Description: Now blink/flink planner only support TimeType with precision zero. We need support

[GitHub] [flink] flinkbot commented on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

2019-09-16 Thread GitBox
flinkbot commented on issue #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils URL: https://github.com/apache/flink/pull/9682#issuecomment-531693859 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[jira] [Updated] (FLINK-14037) Deserializing the input/output formats failed: unread block data

2019-09-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14037: --- Labels: pull-request-available (was: ) > Deserializing the input/output formats failed: unr

[GitHub] [flink] liupc opened a new pull request #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

2019-09-16 Thread GitBox
liupc opened a new pull request #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683 ## What is the purpose of the change When user include flink-shaded-hadoop-2 classes into user jar, and use a cus

[GitHub] [flink] TisonKun opened a new pull request #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

2019-09-16 Thread GitBox
TisonKun opened a new pull request #9682: [FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils URL: https://github.com/apache/flink/pull/9682 ## What is the purpose of the change StandaloneUtils is a poor utility that can be just repla

[jira] [Updated] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

2019-09-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14041: --- Labels: pull-request-available (was: ) > Refactor LeaderRetrievalServiceHostnameResolutionT

[jira] [Assigned] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

2019-09-16 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14041: Assignee: TisonKun > Refactor LeaderRetrievalServiceHostnameResolutionTest and remove > Standalo

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930336#comment-16930336 ] TisonKun commented on FLINK-13992: -- Thank [~azagrebin] for your updates. Now it works a

[GitHub] [flink] catkint commented on issue #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese

2019-09-16 Thread GitBox
catkint commented on issue #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese URL: https://github.com/apache/flink/pull/9677#issuecomment-531689682 I will modify it asap. thx. This is an automated mes

[GitHub] [flink] flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914 ## CI report: * 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE [Build](https://travis-ci.com/flink-ci/flink/buil

[GitHub] [flink] TisonKun commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storag

2019-09-16 Thread GitBox
TisonKun commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage URL: https://github.com/apache/flink/pull/9598#discussion_r324559191 ## File path: flink-tests/po

[GitHub] [flink] TisonKun commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storag

2019-09-16 Thread GitBox
TisonKun commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage URL: https://github.com/apache/flink/pull/9598#discussion_r324558621 ## File path: flink-runtime

[jira] [Comment Edited] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930325#comment-16930325 ] Andrey Zagrebin edited comment on FLINK-13992 at 9/16/19 8:34 AM:

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-16 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930325#comment-16930325 ] Andrey Zagrebin commented on FLINK-13992: - [~Tison], please, try again to assign

[GitHub] [flink] wangyang0918 commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability st

2019-09-16 Thread GitBox
wangyang0918 commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage URL: https://github.com/apache/flink/pull/9598#discussion_r324551994 ## File path: flink-test

[GitHub] [flink] xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese

2019-09-16 Thread GitBox
xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese URL: https://github.com/apache/flink/pull/9677#discussion_r324549631 ## File path: docs/dev/connectors/streamfile_sink.zh.md ## @@ -28,80 +28,69 @@

[GitHub] [flink] xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese

2019-09-16 Thread GitBox
xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese URL: https://github.com/apache/flink/pull/9677#discussion_r324540876 ## File path: docs/dev/connectors/streamfile_sink.zh.md ## @@ -28,80 +28,69 @@

[GitHub] [flink] xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese

2019-09-16 Thread GitBox
xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese URL: https://github.com/apache/flink/pull/9677#discussion_r324547289 ## File path: docs/dev/connectors/streamfile_sink.zh.md ## @@ -28,80 +28,69 @@

[GitHub] [flink] xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese

2019-09-16 Thread GitBox
xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese URL: https://github.com/apache/flink/pull/9677#discussion_r324544533 ## File path: docs/dev/connectors/streamfile_sink.zh.md ## @@ -28,80 +28,69 @@

[GitHub] [flink] xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese

2019-09-16 Thread GitBox
xintongsong commented on a change in pull request #9677: [FLINK-13979] [docs-zh] Translate new streamfilesink docs to chinese URL: https://github.com/apache/flink/pull/9677#discussion_r324548381 ## File path: docs/dev/connectors/streamfile_sink.zh.md ## @@ -28,80 +28,69 @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability st

2019-09-16 Thread GitBox
wangyang0918 commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage URL: https://github.com/apache/flink/pull/9598#discussion_r324554365 ## File path: flink-run

[GitHub] [flink] flinkbot commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
flinkbot commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914 ## CI report: * 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : UNKNOWN

[GitHub] [flink] wangyang0918 commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability st

2019-09-16 Thread GitBox
wangyang0918 commented on a change in pull request #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage URL: https://github.com/apache/flink/pull/9598#discussion_r324551994 ## File path: flink-test

[jira] [Created] (FLINK-14086) PrometheusReporterEndToEndITCase doesn't support ARM arch

2019-09-16 Thread wangxiyuan (Jira)
wangxiyuan created FLINK-14086: -- Summary: PrometheusReporterEndToEndITCase doesn't support ARM arch Key: FLINK-14086 URL: https://issues.apache.org/jira/browse/FLINK-14086 Project: Flink Issue T

[jira] [Commented] (FLINK-13838) Support -yta(--yarnshipArchives) arguments in flink run command line

2019-09-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930308#comment-16930308 ] Yang Wang commented on FLINK-13838: --- [~Zentol] Yes, it is supported by all hadoop vers

[GitHub] [flink] flinkbot commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
flinkbot commented on issue #9681: [FLINK-13450][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681#issuecomment-531678149 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request

[GitHub] [flink] wangxiyuan opened a new pull request #9681: [FLINK-13448][test] Use StrictMath instead of Math

2019-09-16 Thread GitBox
wangxiyuan opened a new pull request #9681: [FLINK-13448][test] Use StrictMath instead of Math URL: https://github.com/apache/flink/pull/9681 ## What is the purpose of the change `math.log` and `math.pow` can actually return slightly different results across platforms becaus

[jira] [Updated] (FLINK-13448) Support ARM architecture

2019-09-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13448: --- Labels: pull-request-available (was: ) > Support ARM architecture > ---

[jira] [Commented] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

2019-09-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930302#comment-16930302 ] Yang Wang commented on FLINK-14033: --- Seems that UserArtifacts is not added to yarn dis

[jira] [Commented] (FLINK-13979) Translate new streamfilesink docs to chinese

2019-09-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930288#comment-16930288 ] Xintong Song commented on FLINK-13979: -- I'm taking a look at the PR. Will get back

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-16 Thread GitBox
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324535361 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[jira] [Updated] (FLINK-14085) schema changes after using "create view" command via flink-table-sql-client

2019-09-16 Thread Junling (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junling updated FLINK-14085: Description: Assume there are two tables in the running environment of the flink sql client. One is abc12

<    1   2   3   4   >