[GitHub] [flink] flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing

flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing URL: https://github.com/apache/flink/pull/7013#issuecomment-532533051 ## CI report: * c81a918723a3204483b152909c3fc93f16a23ce0 : FAILURE

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

hequn8128 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_r325490458 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,155

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

hequn8128 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_r325477942 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,155

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

hequn8128 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_r325502497 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,155

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

hequn8128 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_r325509399 ## File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py

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

hequn8128 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_r325446663 ## File path: flink-dist/src/main/flink-bin/bin/pyflink-udf-runner.sh ## @@

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

hequn8128 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_r325510604 ## File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py

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

hequn8128 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_r325491976 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,155

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

hequn8128 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_r325504848 ## File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py

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

hequn8128 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_r325232945 ## File path: flink-dist/src/main/flink-bin/bin/pyflink-udf-runner.sh ## @@

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

hequn8128 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_r325501314 ## File path: flink-python/pyflink/fn_execution/boot.py ## @@ -0,0 +1,155

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

flinkbot edited a comment on issue #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#issuecomment-529525552 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing

flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing URL: https://github.com/apache/flink/pull/7013#issuecomment-532533051 ## CI report: * c81a918723a3204483b152909c3fc93f16a23ce0 : FAILURE

[jira] [Created] (FLINK-14114) Shift down ClusterClient#timeout to RestClusterClient

TisonKun created FLINK-14114: Summary: Shift down ClusterClient#timeout to RestClusterClient Key: FLINK-14114 URL: https://issues.apache.org/jira/browse/FLINK-14114 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14070) Use TimeUtils to parse duration configs

[ https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932133#comment-16932133 ] TisonKun commented on FLINK-14070: -- Hi [~zhuzh] did you start working on this thread? I'd like to

[jira] [Commented] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932102#comment-16932102 ] vinoyang commented on FLINK-13987: -- I have linked it to this issue a week ago, please see FLINK-11782.

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932103#comment-16932103 ] Jiayi Liao commented on FLINK-5601: --- [~aljoscha] Any new idea for this issue? Theoratically, watermark

[GitHub] [flink] tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#discussion_r325500227 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#discussion_r325500646 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#discussion_r325500814 ## File path:

[jira] [Resolved] (FLINK-13949) Delete deduplicating JobVertexDetailsInfo.VertexTaskDetail

[ https://issues.apache.org/jira/browse/FLINK-13949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13949. --- Fix Version/s: 1.10.0 Resolution: Done Done via

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r325475374 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r325472245 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r325473963 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java

[GitHub] [flink] tillrohrmann closed pull request #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa…

tillrohrmann closed pull request #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa… URL: https://github.com/apache/flink/pull/9699 This is an automated message from the Apache Git Service. To

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r325466726 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java

[GitHub] [flink] flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing

flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing URL: https://github.com/apache/flink/pull/7013#issuecomment-532533051 ## CI report: * c81a918723a3204483b152909c3fc93f16a23ce0 : FAILURE

[GitHub] [flink] tillrohrmann commented on issue #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa…

tillrohrmann commented on issue #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa… URL: https://github.com/apache/flink/pull/9699#issuecomment-532537561 Thanks a lot. Merging this PR now. This is

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

[ https://issues.apache.org/jira/browse/FLINK-14069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14069. --- Resolution: Done Done via d3137b29c3837d34ab734b1182c15b32572e41ba

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

tillrohrmann closed 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 This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[jira] [Commented] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932096#comment-16932096 ] Danny Chan commented on FLINK-11936: [~walterddr], since CALCITE-3008 has not been resolved yet, we

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

flinkbot edited a comment on issue #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#issuecomment-529525552 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing

flinkbot commented on issue #7013: [FLINK-5601][Checkpointing] Watermark checkpointing URL: https://github.com/apache/flink/pull/7013#issuecomment-532533051 ## CI report: * c81a918723a3204483b152909c3fc93f16a23ce0 : UNKNOWN

<    1   2   3   4