[GitHub] [flink] flinkbot edited a comment on issue #11866: [BP-1.10] Revert "[FLINK-14499][metric] MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull"

flinkbot edited a comment on issue #11866: URL: https://github.com/apache/flink/pull/11866#issuecomment-617839879 ## CI report: * 466d630eb61dbdee1d4846149e0c537f7e5a5cf7 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161461323) Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #11865: Revert "[FLINK-14499][metric] MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull"

flinkbot edited a comment on issue #11865: URL: https://github.com/apache/flink/pull/11865#issuecomment-617839769 ## CI report: * 7a81c3644e88e09b2a88c1737c495a83f8fbde6c Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161461284) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11853: [FLINK-15006][table-planner] Add option to shuffle-by-partition when dynamic inserting

flinkbot edited a comment on issue #11853: URL: https://github.com/apache/flink/pull/11853#issuecomment-617586421 ## CI report: * 4f5f680443fa38139add93a9a597e5d1103e0bb1 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161379418) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien…

flinkbot edited a comment on issue #11788: URL: https://github.com/apache/flink/pull/11788#issuecomment-615123775 ## CI report: * a2354619207490d70e713c1a09d58ece827c4e3f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161403442) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11838: [FLINK-16965] Convert Graphite reporter to plugin

flinkbot edited a comment on issue #11838: URL: https://github.com/apache/flink/pull/11838#issuecomment-616983944 ## CI report: * f443c1371fa827b46d2f7f9bbc3929ce91563367 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161403526) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161468937) Azure:

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089782#comment-17089782 ] Robert Metzger commented on FLINK-17274: Another case

[GitHub] [flink] kl0u commented on issue #11801: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

kl0u commented on issue #11801: URL: https://github.com/apache/flink/pull/11801#issuecomment-617901566 Merged This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16662. -- Resolution: Fixed Merged on master with 19d9cee49bce02dd0cf232cfba003936b3b2f68e and on

[jira] [Updated] (FLINK-17309) TPC-DS fail to run data generator

[ https://issues.apache.org/jira/browse/FLINK-17309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17309: --- Labels: pull-request-available test-stability (was: test-stability) > TPC-DS fail to run

[GitHub] [flink] leonardBang opened a new pull request #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

leonardBang opened a new pull request #11867: URL: https://github.com/apache/flink/pull/11867 ## What is the purpose of the change * This pull request fix TPC-DS e2e test stability issue on Azure pipeline **Especially, this PR shoule merge until Azure pipeline stable

[GitHub] [flink] flinkbot commented on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot commented on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617850422 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 use this comment to track the progress

[GitHub] [flink] hequn8128 commented on a change in pull request #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

hequn8128 commented on a change in pull request #11859: URL: https://github.com/apache/flink/pull/11859#discussion_r413039206 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonStatelessFunctionFlatMap.java ## @@ -169,6

[GitHub] [flink] flinkbot commented on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot commented on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11860: [FLINK-17311][python] Add executable permissions to the script in the wheel package

flinkbot edited a comment on issue #11860: URL: https://github.com/apache/flink/pull/11860#issuecomment-617666482 ## CI report: * 667a38ef128f9dc3fc6497e319eb17acd78df8fe Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161403627) Azure:

[GitHub] [flink] kl0u commented on issue #11798: [RELEASE-1.10][Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

kl0u commented on issue #11798: URL: https://github.com/apache/flink/pull/11798#issuecomment-617902073 Merged This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] bowenli86 commented on a change in pull request #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

bowenli86 commented on a change in pull request #11766: URL: https://github.com/apache/flink/pull/11766#discussion_r413155292 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row/converter/PostgresRowConverter.java ## @@ -28,4

[GitHub] [flink] bowenli86 commented on a change in pull request #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

bowenli86 commented on a change in pull request #11766: URL: https://github.com/apache/flink/pull/11766#discussion_r413155292 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row/converter/PostgresRowConverter.java ## @@ -28,4

[jira] [Closed] (FLINK-17319) Fix broken link to walkthrough guide

[ https://issues.apache.org/jira/browse/FLINK-17319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-17319. Fix Version/s: statefun-2.1.0 Resolution: Fixed Fixed at 

[GitHub] [flink] flinkbot edited a comment on issue #11862: [FLINK-17251] [table] supports INSERT statement in TableEnvironment#executeSql and Table#executeInsert api

flinkbot edited a comment on issue #11862: URL: https://github.com/apache/flink/pull/11862#issuecomment-617678740 ## CI report: * d81663c0607b6fdc6095e928c508381ce2ef9505 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161407561) Azure:

[jira] [Commented] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090151#comment-17090151 ] Hequn Cheng commented on FLINK-16766: - Resolved in 1.11.0 via

[GitHub] [flink] flinkbot edited a comment on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

flinkbot edited a comment on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-617596227 ## CI report: * 77720a95c9fb8163487dbec5bc82681f1e7f9fde Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161400024) Azure:

[jira] [Commented] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090210#comment-17090210 ] Zhu Zhu commented on FLINK-17330: - cc [~gjy] [~trohrmann] Sorry this case was neglected. What do you

[jira] [Created] (FLINK-17333) add doc for "create ddl"

Bowen Li created FLINK-17333: Summary: add doc for "create ddl" Key: FLINK-17333 URL: https://issues.apache.org/jira/browse/FLINK-17333 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on issue #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

flinkbot commented on issue #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618179221 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 use this comment to track the progress

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * f4560ce97f1b94b5d3ffa9c280879f227fc4211a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

flinkbot edited a comment on issue #11675: URL: https://github.com/apache/flink/pull/11675#issuecomment-6 ## CI report: * c56b29525d8e13e8d756c415f0c3ca82c11a781f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161452547) Azure:

[GitHub] [flink] godfreyhe commented on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

godfreyhe commented on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-618133036 hi @kl0u `CollectionEnvironment` is used in flink-table-planner for testing, e.g. `org.apache.flink.table.runtime.batch.sql.TableEnvironmentITCase#testInsertIntoMemoryTable` and

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * f4560ce97f1b94b5d3ffa9c280879f227fc4211a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161468937) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

flinkbot edited a comment on issue #11859: URL: https://github.com/apache/flink/pull/11859#issuecomment-617655293 ## CI report: * 6bfb3f29fa88ad7314ccd9bd3a9eb0568d63c9c9 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161400110) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

flinkbot edited a comment on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-617596227 ## CI report: * 77720a95c9fb8163487dbec5bc82681f1e7f9fde Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161400024) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][FLINK-15901][table] Support partition for temporary table and HiveCatalog

flinkbot edited a comment on issue #10059: URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 91c3f6c3986386cd4f5c914029b807ecd979e50c Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161448300) Azure:

[jira] [Closed] (FLINK-17323) ChannelStateReader rejects requests about unkown channels (Unaligned checkpoints)

[ https://issues.apache.org/jira/browse/FLINK-17323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17323. Resolution: Fixed Merged in master: 07667d29181be2cd4281d36c8cdfbd9a6c4e704a > ChannelStateReader

[jira] [Resolved] (FLINK-17138) LocalExecutorITCase.testParameterizedTypes failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-17138. -- Resolution: Fixed master: 27d1a48cc5c1ef7baf506d7c0db4d01ebdca6b70 Feel free to re-open if

[jira] [Created] (FLINK-17334) Flink does not support UDFs with primitive return types

xin.ruan created FLINK-17334: Summary: Flink does not support UDFs with primitive return types Key: FLINK-17334 URL: https://issues.apache.org/jira/browse/FLINK-17334 Project: Flink Issue Type:

[jira] [Created] (FLINK-17335) JDBCUpsertTableSink Upsert mysql exception No value specified for parameter 1

yutao created FLINK-17335: - Summary: JDBCUpsertTableSink Upsert mysql exception No value specified for parameter 1 Key: FLINK-17335 URL: https://issues.apache.org/jira/browse/FLINK-17335 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][FLINK-15901][table] Support partition for temporary table and HiveCatalog

flinkbot edited a comment on issue #10059: URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 5f91592c6f010dbb52511c54568c5d3c82082433 UNKNOWN * 13dab75e74ed139bb8802dcf2de0ef87464f046b Travis:

[jira] [Comment Edited] (FLINK-17328) Expose network metric for job vertex in rest api

[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090203#comment-17090203 ] lining edited comment on FLINK-17328 at 4/23/20, 3:40 AM: -- [Gary

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * b0730cb05f9d77f9d34ab7221020931ef5d2532d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11787: [FLINK-16746] Deprecate legacy heap memory option for JM and expose the new ones in docs

flinkbot edited a comment on issue #11787: URL: https://github.com/apache/flink/pull/11787#issuecomment-615109268 ## CI report: * e6af843926fcb8941215164f18a9c43019bab76c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161452671) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11864: [FLINK-17301] Set BIND_HOST to localhost in TaskManagerRunnerStartupTest

flinkbot edited a comment on issue #11864: URL: https://github.com/apache/flink/pull/11864#issuecomment-617827070 ## CI report: * e0907be73cf672f719d282a4e80a99a1e4cb7e13 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161456797) Azure:

[jira] [Closed] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16766. --- Resolution: Resolved > Support create StreamTableEnvironment without passing >

[jira] [Updated] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16766: Fix Version/s: (was: 1.9.4) (was: 1.10.1) > Support create

[jira] [Created] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

Yangze Guo created FLINK-17331: -- Summary: Add NettyMessageContent interface for all the class which could be write to NettyMessage Key: FLINK-17331 URL: https://issues.apache.org/jira/browse/FLINK-17331

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][FLINK-15901][table] Support partition for temporary table and HiveCatalog

flinkbot edited a comment on issue #10059: URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 5f91592c6f010dbb52511c54568c5d3c82082433 UNKNOWN * 13dab75e74ed139bb8802dcf2de0ef87464f046b Travis:

[GitHub] [flink] flinkbot commented on issue #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

flinkbot commented on issue #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618175194 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 use this comment to track the progress

[jira] [Assigned] (FLINK-17289) Translate tutorials/etl.md to chinese

[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17289: Assignee: Li Ying > Translate tutorials/etl.md to chinese >

[GitHub] [flink] flinkbot commented on issue #11872: [FLINK-17227][metrics]Remove Datadog shade-plugin relocations

flinkbot commented on issue #11872: URL: https://github.com/apache/flink/pull/11872#issuecomment-618182391 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 use this comment to track the progress

[jira] [Commented] (FLINK-17289) Translate tutorials/etl.md to chinese

[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090254#comment-17090254 ] Jingsong Lee commented on FLINK-17289: -- [~lyee] Assigned. > Translate tutorials/etl.md to chinese

[GitHub] [flink] flinkbot commented on issue #11871: [FLINK-17333][doc] add doc for 'create catalog' ddl

flinkbot commented on issue #11871: URL: https://github.com/apache/flink/pull/11871#issuecomment-618182406 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 use this comment to track the progress

[GitHub] [flink] flinkbot edited a comment on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

flinkbot edited a comment on issue #11766: URL: https://github.com/apache/flink/pull/11766#issuecomment-614431072 ## CI report: * 3d58ff0f0f2f4caac54b5bc38dac153ae4f4ecf2 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160495187) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11863: [FLINK-17048][mesos] Add memory related JVM args to Mesos JM startup scripts

flinkbot edited a comment on issue #11863: URL: https://github.com/apache/flink/pull/11863#issuecomment-617687609 ## CI report: * d559c7119084b47c163dd4e1523b3f9487d88e82 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161452814) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11853: [FLINK-15006][table-planner] Add option to shuffle-by-partition when dynamic inserting

flinkbot edited a comment on issue #11853: URL: https://github.com/apache/flink/pull/11853#issuecomment-617586421 ## CI report: * 99b58fba1e22bdbba0896f0aba181eafc6a28e7f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161461206) Azure:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11838: [FLINK-16965] Convert Graphite reporter to plugin

KarmaGYZ commented on a change in pull request #11838: URL: https://github.com/apache/flink/pull/11838#discussion_r413450999 ## File path: flink-metrics/flink-metrics-graphite/pom.xml ## @@ -65,31 +65,4 @@ under the License. ${dropwizard.version}

[jira] [Updated] (FLINK-14815) Expose network metric for sub task in rest api

[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14815: --- Description: * SubTask **  pool usage: outPoolUsage, inputExclusiveBuffersUsage, 

[jira] [Commented] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per operator in SQL

[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090202#comment-17090202 ] Jiahui Jiang commented on FLINK-17173: -- [~danny0405] I just saw your [design

[jira] [Created] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis

Yu Li created FLINK-17329: - Summary: Quickstarts Scala nightly e2e test failed on travis Key: FLINK-17329 URL: https://issues.apache.org/jira/browse/FLINK-17329 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Created] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

Zhu Zhu created FLINK-17330: --- Summary: Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges Key: FLINK-17330 URL: https://issues.apache.org/jira/browse/FLINK-17330 Project:

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Created] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

Canbin Zheng created FLINK-17332: Summary: Fix restart policy not equals to Never for native task manager pods Key: FLINK-17332 URL: https://issues.apache.org/jira/browse/FLINK-17332 Project: Flink

[jira] [Updated] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

[ https://issues.apache.org/jira/browse/FLINK-17332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17332: - Description: Currently, we do not explicitly set the {{RestartPolicy}} for the task manager

[GitHub] [flink] flinkbot commented on issue #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

flinkbot commented on issue #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618183162 ## CI report: * c4c6356dfbd46e26171b6128482eecab13fe7d96 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot edited a comment on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * d467bd31393f9dc171b6625f9053360b73bfd64d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161487842) Azure:

[GitHub] [flink] flinkbot commented on issue #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

flinkbot commented on issue #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618183108 ## CI report: * 28223e277ee06677a7c973300e3e1c85902874fd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

flinkbot edited a comment on issue #11859: URL: https://github.com/apache/flink/pull/11859#issuecomment-617655293 ## CI report: * d7d37b26b6dc41871ee56900f8e9b6ed16b3fcf6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161549162) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

flinkbot edited a comment on issue #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618183162 ## CI report: * c4c6356dfbd46e26171b6128482eecab13fe7d96 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161563127) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * b0730cb05f9d77f9d34ab7221020931ef5d2532d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

flinkbot edited a comment on issue #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618183108 ## CI report: * 28223e277ee06677a7c973300e3e1c85902874fd Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161563117) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot edited a comment on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * d467bd31393f9dc171b6625f9053360b73bfd64d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161487842) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

flinkbot edited a comment on issue #11766: URL: https://github.com/apache/flink/pull/11766#issuecomment-614431072 ## CI report: * 3d58ff0f0f2f4caac54b5bc38dac153ae4f4ecf2 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160495187) Azure:

[GitHub] [flink] flinkbot commented on issue #11871: [FLINK-17333][doc] add doc for 'create catalog' ddl

flinkbot commented on issue #11871: URL: https://github.com/apache/flink/pull/11871#issuecomment-618188399 ## CI report: * ac40522a46f3f22f747e1196d45d91543cc6a87a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

flinkbot edited a comment on issue #11859: URL: https://github.com/apache/flink/pull/11859#issuecomment-617655293 ## CI report: * d7d37b26b6dc41871ee56900f8e9b6ed16b3fcf6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161549162) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 9c3d9347f989a84184f598190271f5e0b4703ba0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161547778) Azure:

[GitHub] [flink] flinkbot commented on issue #11872: [FLINK-17227][metrics]Remove Datadog shade-plugin relocations

flinkbot commented on issue #11872: URL: https://github.com/apache/flink/pull/11872#issuecomment-618188449 ## CI report: * 6ee34138baa74abb4b7c1f71ea98e360340a2b8c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161468937) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11865: Revert "[FLINK-14499][metric] MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull"

flinkbot edited a comment on issue #11865: URL: https://github.com/apache/flink/pull/11865#issuecomment-617839769 ## CI report: * 7a81c3644e88e09b2a88c1737c495a83f8fbde6c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161461284) Azure:

[GitHub] [flink] docete commented on issue #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

docete commented on issue #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-618122640 @wuchong pls have a look This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * f4560ce97f1b94b5d3ffa9c280879f227fc4211a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

flinkbot edited a comment on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-617596227 ## CI report: * 77720a95c9fb8163487dbec5bc82681f1e7f9fde Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161400024) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161468937) Azure:

[jira] [Commented] (FLINK-17328) Expose network metric for job vertex in rest api

[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090203#comment-17090203 ] lining commented on FLINK-17328: [~gary] could you assign it to me? > Expose network metric for job

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 9c3d9347f989a84184f598190271f5e0b4703ba0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161547778) Azure:

[GitHub] [flink] hehuiyuan opened a new pull request #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

hehuiyuan opened a new pull request #11870: URL: https://github.com/apache/flink/pull/11870  This method `generateOneInputStreamOperator` when

[jira] [Updated] (FLINK-17117) There are an useless cast operation for sql on blink when generate code

[ https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17117: --- Labels: pull-request-available (was: ) > There are an useless cast operation for sql on

[jira] [Comment Edited] (FLINK-17289) Translate tutorials/etl.md to chinese

[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090188#comment-17090188 ] Li Ying edited comment on FLINK-17289 at 4/23/20, 5:11 AM: --- Hi David, I'd like

[jira] [Commented] (FLINK-17285) Add Chinese translation to Python Table API Documentations

[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090060#comment-17090060 ] Zixuan Rao commented on FLINK-17285: May I request assignee (myself: [~billrao], GitHub username:

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot edited a comment on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * d467bd31393f9dc171b6625f9053360b73bfd64d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161487842) Azure:

[GitHub] [flink] leonardBang commented on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

leonardBang commented on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-618130592 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] KarmaGYZ commented on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

KarmaGYZ commented on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-618130733 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] KarmaGYZ commented on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

KarmaGYZ commented on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-618130670 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] wuchong commented on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

wuchong commented on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-618137477 Hi @kl0u , we refactored `BatchTableEnviroment` to use `executor` to submit the Pipline. That's why we need an executor for `CollectionEnvironment` because tests are using

[jira] [Commented] (FLINK-17289) Translate tutorials/etl.md to chinese

[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090188#comment-17090188 ] Li Ying commented on FLINK-17289: - Hi David, I'd like to do the translation. Could you please assigh

[jira] [Updated] (FLINK-17328) Expose network metric for job vertex in rest api

[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-17328: --- Description: JobVertexDetailsHandler * pool usage: outPoolUsageAvg, inputExclusiveBuffersUsageAvg, 

[GitHub] [flink] wuchong commented on a change in pull request #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

wuchong commented on a change in pull request #11804: URL: https://github.com/apache/flink/pull/11804#discussion_r413482942 ## File path: docs/dev/table/catalogs.md ## @@ -37,6 +41,97 @@ Or permanent metadata, like that in a Hive Metastore. Catalogs provide a unified The

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Updated] (FLINK-17111) Support SHOW VIEWS in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17111: --- Labels: pull-request-available (was: ) > Support SHOW VIEWS in Flink SQL >

[GitHub] [flink] docete opened a new pull request #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

docete opened a new pull request #11869: URL: https://github.com/apache/flink/pull/11869 ## What is the purpose of the change FLINK-17106 introduces create/drop view in Flink SQL. But we can't list views from TableEnvironment or SQL. This PR supports SHOW VIEWS in Flink SQL. BTW:

  1   2   3   4   5   6   >