[GitHub] [flink] flinkbot commented on issue #10130: [FLINK-14642] [types] Add support for copying null values to the TupleSeriali…

flinkbot commented on issue #10130: [FLINK-14642] [types] Add support for copying null values to the TupleSeriali… URL: https://github.com/apache/flink/pull/10130#issuecomment-551424774 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] jiasheng55 opened a new pull request #10130: [FLINK-14642] [types] Add support for copying null values to the TupleSeriali…

jiasheng55 opened a new pull request #10130: [FLINK-14642] [types] Add support for copying null values to the TupleSeriali… URL: https://github.com/apache/flink/pull/10130 …zer and CaseClassSerializer ## What is the purpose of the change This PR makes the `copy` method of the

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344022126 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344021494 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344021592 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#issuecomment-545714180 ## CI report: * 52a10e0283f21047ac18d6668b71cfa4f6fc21a9 : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344021232 ## File path:

[GitHub] [flink] zjffdu commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

zjffdu commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-551420856 No problem, thanks for the fix. @godfreyhe

[GitHub] [flink] flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-551413525 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts`

flinkbot edited a comment on issue #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts` URL: https://github.com/apache/flink/pull/10128#issuecomment-551413601 ## CI report: * 409604f05255e81a4dd943042c5b18c18ac16a49 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#issuecomment-551369912 ## CI report: * 102bce9b12cb5853f0fe2b53ae4120434813d7c2 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements

flinkbot edited a comment on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements URL: https://github.com/apache/flink/pull/10127#issuecomment-551413577 ## CI report: * 02df4747bebc7f7601bce39dea46ea285c46 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts`

flinkbot edited a comment on issue #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts` URL: https://github.com/apache/flink/pull/10129#issuecomment-551413624 ## CI report: * 72f509341e6a5743c88f7fe960da86ba170990eb : PENDING

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344019865 ## File path:

[GitHub] [flink] godfreyhe commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

godfreyhe commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-551420055 @zjffdu sorry for late update

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344018872 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#issuecomment-549322411 ## CI report: * 4807c59ae20273d5b4611395ca5467217d7d0ca3 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969910#comment-16969910 ] Victor Wong commented on FLINK-14653: - [~mxm], if

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344015484 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344015308 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#issuecomment-545714180 ## CI report: * 52a10e0283f21047ac18d6668b71cfa4f6fc21a9 : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344014732 ## File path:

[GitHub] [flink] flinkbot commented on issue #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts`

flinkbot commented on issue #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts` URL: https://github.com/apache/flink/pull/10129#issuecomment-551413624 ## CI report: * 72f509341e6a5743c88f7fe960da86ba170990eb : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot commented on issue #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts`

flinkbot commented on issue #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts` URL: https://github.com/apache/flink/pull/10128#issuecomment-551413601 ## CI report: * 409604f05255e81a4dd943042c5b18c18ac16a49 : UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344013614 ## File path:

[GitHub] [flink] flinkbot commented on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

flinkbot commented on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-551413525 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#issuecomment-551369912 ## CI report: * 102bce9b12cb5853f0fe2b53ae4120434813d7c2 : CANCELED

[GitHub] [flink] flinkbot commented on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements

flinkbot commented on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements URL: https://github.com/apache/flink/pull/10127#issuecomment-551413577 ## CI report: * 02df4747bebc7f7601bce39dea46ea285c46 : UNKNOWN Bot

[jira] [Updated] (FLINK-14669) All hadoop-2.4.1 related nightly end-to-end tests failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14669: -- Description: As titled, all hadoop 2.4.1 tests failed in build

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r344013007 ## File path:

[GitHub] [flink] guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#discussion_r344012889 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#issuecomment-549322411 ## CI report: * 4807c59ae20273d5b4611395ca5467217d7d0ca3 : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344011851 ## File path:

[jira] [Created] (FLINK-14669) All hadoop-2.4.1 related nightly end-to-end tests failed on travis

Yu Li created FLINK-14669: - Summary: All hadoop-2.4.1 related nightly end-to-end tests failed on travis Key: FLINK-14669 URL: https://issues.apache.org/jira/browse/FLINK-14669 Project: Flink Issue

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344011455 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[jira] [Commented] (FLINK-14374) Enable RegionFailoverITCase to pass with scheduler NG

[ https://issues.apache.org/jira/browse/FLINK-14374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969885#comment-16969885 ] Yun Tang commented on FLINK-14374: -- [~gjy], adding {{FailingRestartStrategy}} is to verify FLINK-13452.

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344010610 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344010528 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344009866 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344009531 ## File path:

[GitHub] [flink] flinkbot commented on issue #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts`

flinkbot commented on issue #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts` URL: https://github.com/apache/flink/pull/10129#issuecomment-551408678 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] zhuzhurk opened a new pull request #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts`

zhuzhurk opened a new pull request #10129: [FLINK-14642][runtime] Deprecate metric `fullRestarts` URL: https://github.com/apache/flink/pull/10129 ## What is the purpose of the change FLINK-14164 introduces a metric 'numberOfRestarts' that counts all kinds of restarts. The

[jira] [Updated] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14642: --- Labels: pull-request-available (was: ) > Flink TupleSerializer and CaseClassSerializer

[GitHub] [flink] flinkbot commented on issue #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts`

flinkbot commented on issue #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts` URL: https://github.com/apache/flink/pull/10128#issuecomment-551407824 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-14641) Fix description of metric `fullRestarts`

[ https://issues.apache.org/jira/browse/FLINK-14641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14641: --- Labels: pull-request-available (was: ) > Fix description of metric `fullRestarts` >

[GitHub] [flink] zhuzhurk opened a new pull request #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts`

zhuzhurk opened a new pull request #10128: [FLINK-14641][docs] Fix description of metric `fullRestarts` URL: https://github.com/apache/flink/pull/10128 ## What is the purpose of the change The metric `fullRestarts` counts both full restarts and fine grained restarts since

[jira] [Commented] (FLINK-14666) support multiple catalog in flink table sql

[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969879#comment-16969879 ] Kurt Young commented on FLINK-14666: Can you check on the latest master? Previous, all temporary

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344006383 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344006278 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements

flinkbot commented on issue #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements URL: https://github.com/apache/flink/pull/10127#issuecomment-551405829 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-14641) Fix description of metric `fullRestarts`

[ https://issues.apache.org/jira/browse/FLINK-14641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969877#comment-16969877 ] Zhu Zhu commented on FLINK-14641: - [~chesnay] not pretty sure whether we can apply this fix to 1.9.2

[jira] [Updated] (FLINK-14654) Fix the arguments number mismatching with placeholders in log statements

[ https://issues.apache.org/jira/browse/FLINK-14654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14654: --- Labels: pull-request-available (was: ) > Fix the arguments number mismatching with

[GitHub] [flink] flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#issuecomment-549322411 ## CI report: * 4807c59ae20273d5b4611395ca5467217d7d0ca3 : FAILURE

[GitHub] [flink] Myasuka opened a new pull request #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements

Myasuka opened a new pull request #10127: [FLINK-14654] Fix the arguments number mismatching with placeholders in log statements URL: https://github.com/apache/flink/pull/10127 ## What is the purpose of the change As official Flink [java code

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344005130 ## File path:

[jira] [Closed] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

[ https://issues.apache.org/jira/browse/FLINK-14668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangwei closed FLINK-14668. Resolution: Fixed > LocalExecutor#getOrCreateExecutionContext not working as expected >

[jira] [Commented] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

[ https://issues.apache.org/jira/browse/FLINK-14668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969876#comment-16969876 ] zhangwei commented on FLINK-14668: -- I read it wrong. I'm sorry >

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344004540 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344004177 ## File path:

[GitHub] [flink] flinkbot commented on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

flinkbot commented on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-551403753 Thanks a lot for your contribution to the Apache

[jira] [Updated] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 updated FLINK-14667: --- Description: [root@mj flink-1.9.1]# ./bin/flink run -m yarn-cluster

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344004012 ## File path:

[jira] [Updated] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

[ https://issues.apache.org/jira/browse/FLINK-14668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangwei updated FLINK-14668: - Description: ExecutionContext 

[jira] [Updated] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

[ https://issues.apache.org/jira/browse/FLINK-14590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14590: --- Labels: pull-request-available (was: ) > Unify the working directory of Java process and

[GitHub] [flink] WeiZhong94 opened a new pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

WeiZhong94 opened a new pull request #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126 ## What is the purpose of the change *This pull request

[jira] [Created] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

zhangwei created FLINK-14668: Summary: LocalExecutor#getOrCreateExecutionContext not working as expected Key: FLINK-14668 URL: https://issues.apache.org/jira/browse/FLINK-14668 Project: Flink

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344003590 ## File path:

[jira] [Comment Edited] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969870#comment-16969870 ] chun11 edited comment on FLINK-14667 at 11/8/19 6:24 AM: - 1. flink

[GitHub] [flink] klion26 commented on issue #10111: [FLINK-13969] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

klion26 commented on issue #10111: [FLINK-13969] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis URL: https://github.com/apache/flink/pull/10111#issuecomment-551402058 @tillrohrmann thanks for the review and merging.

[GitHub] [flink] JingsongLi edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

JingsongLi edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#issuecomment-551388324 @KurtYoung @lirui-apache Hope you can take a look.

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344001601 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344001624 ## File path:

[jira] [Comment Edited] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969870#comment-16969870 ] chun11 edited comment on FLINK-14667 at 11/8/19 6:15 AM: - 1. flink

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344000979 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : FAILURE

[jira] [Commented] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969870#comment-16969870 ] chun11 commented on FLINK-14667: The Kafka011TableSourceSinkFactory is packaged in the fat jar . 

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344000581 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r343999496 ## File path:

[jira] [Updated] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 updated FLINK-14667: --- Description: [root@mj flink-1.9.1]# ./bin/flink run -m yarn-cluster

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r343999496 ## File path:

[jira] [Created] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

chun11 created FLINK-14667: -- Summary: flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka Key: FLINK-14667 URL:

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343993759 ## File path:

[jira] [Comment Edited] (FLINK-14666) support multiple catalog in flink table sql

[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969842#comment-16969842 ] yuemeng edited comment on FLINK-14666 at 11/8/19 5:27 AM: -- [~ykt836][~jark] can

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343993020 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#issuecomment-551369912 ## CI report: * 102bce9b12cb5853f0fe2b53ae4120434813d7c2 : CANCELED

[GitHub] [flink] xintongsong commented on issue #10124: [FLINK-14637] Introduce framework off heap memory config

xintongsong commented on issue #10124: [FLINK-14637] Introduce framework off heap memory config URL: https://github.com/apache/flink/pull/10124#issuecomment-551389358 @azagrebin, please help review this PR. Travis passed: https://travis-ci.org/xintongsong/flink/builds/609050197

[GitHub] [flink] flinkbot edited a comment on issue #10125: [FLINK-14666] support multiple catalog in flink table sql

flinkbot edited a comment on issue #10125: [FLINK-14666] support multiple catalog in flink table sql URL: https://github.com/apache/flink/pull/10125#issuecomment-551384456 ## CI report: * 0837b423c8da72c27b32e72030274b16122749a7 : FAILURE

[jira] [Commented] (FLINK-14666) support multiple catalog in flink table sql

[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969842#comment-16969842 ] yuemeng commented on FLINK-14666: - [~ykt836][~jark] can you check this issue, thanks > support multiple

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : FAILURE

[GitHub] [flink] hzyuemeng1 closed pull request #10125: [FLINK-14666] support multiple catalog in flink table sql

hzyuemeng1 closed pull request #10125: [FLINK-14666] support multiple catalog in flink table sql URL: https://github.com/apache/flink/pull/10125 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] JingsongLi commented on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

JingsongLi commented on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#issuecomment-551388324 @KurtYoung Hope you can take a look. This is an automated

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r343990958 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r343990718 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r343990575 ## File path:

  1   2   3   4   5   6   7   >