[GitHub] [flink] flinkbot commented on pull request #13272: [FLINK-18695][network] Netty fakes heap buffer allocationn with direct buffers

2020-08-27 Thread GitBox
flinkbot commented on pull request #13272: URL: https://github.com/apache/flink/pull/13272#issuecomment-682341723 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

[GitHub] [flink] klion26 commented on a change in pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-08-27 Thread GitBox
klion26 commented on a change in pull request #13225: URL: https://github.com/apache/flink/pull/13225#discussion_r478844519 ## File path: docs/dev/user_defined_functions.zh.md ## @@ -147,95 +153,77 @@ data.map (new RichMapFunction[String, Int] { -Rich functions provide,

[jira] [Updated] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18695: --- Labels: pull-request-available (was: ) > Allow NettyBufferPool to allocate heap buffers >

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * 3d854c62355f9049062a7ae6a908dcceecd9c213 Azure:

[GitHub] [flink] gaoyunhaii opened a new pull request #13272: [FLINK-18695][network] Netty fakes heap buffer allocationn with direct buffers

2020-08-27 Thread GitBox
gaoyunhaii opened a new pull request #13272: URL: https://github.com/apache/flink/pull/13272 ## What is the purpose of the change This PR modifies the `NettyBufferPool` to also allocate direct buffers for the heap buffer request. This enables us not to change the memory footprint

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * 3d854c62355f9049062a7ae6a908dcceecd9c213 Azure:

[GitHub] [flink] liming30 commented on a change in pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

2020-08-27 Thread GitBox
liming30 commented on a change in pull request #13109: URL: https://github.com/apache/flink/pull/13109#discussion_r478836972 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/DirectedOutputsCollector.java ## @@ -0,0 +1,67 @@

[GitHub] [flink] liming30 commented on a change in pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

2020-08-27 Thread GitBox
liming30 commented on a change in pull request #13109: URL: https://github.com/apache/flink/pull/13109#discussion_r478431177 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/SelectedOutputsCollectorImpl.java ## @@ -0,0 +1,61

[GitHub] [flink] dianfu commented on pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

2020-08-27 Thread GitBox
dianfu commented on pull request #13193: URL: https://github.com/apache/flink/pull/13193#issuecomment-682331400 @hequn8128 Thanks for the update. LGTM. @sjwiesman @morsapaes could you take a further look at of the latest PR? Thanks a lot!

[GitHub] [flink] flinkbot edited a comment on pull request #13271: [FLINK-19043][docs-zh] Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13271: URL: https://github.com/apache/flink/pull/13271#issuecomment-682323547 ## CI report: * dcfea8ba4f522e9cd1a87022eadb10438902f22c Azure:

[GitHub] [flink] flinkbot commented on pull request #13271: [FLINK-19043][docs-zh] Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese

2020-08-27 Thread GitBox
flinkbot commented on pull request #13271: URL: https://github.com/apache/flink/pull/13271#issuecomment-682323547 ## CI report: * dcfea8ba4f522e9cd1a87022eadb10438902f22c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-19063) Support join late event from dimension table side in temporal table join

2020-08-27 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186253#comment-17186253 ] Paul Lin commented on FLINK-19063: -- WRT event-time temporal table join, as an initial and naive

[GitHub] [flink] RocMarshal commented on a change in pull request #13271: [FLINK-19043][docs-zh] Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese

2020-08-27 Thread GitBox
RocMarshal commented on a change in pull request #13271: URL: https://github.com/apache/flink/pull/13271#discussion_r478825509 ## File path: docs/monitoring/logging.zh.md ## @@ -100,15 +106,13 @@ import org.slf4j.Logger Logger LOG = LoggerFactory.getLogger(Foobar.class) {%

[GitHub] [flink] flinkbot commented on pull request #13271: [FLINK-19043][docs-zh] Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese

2020-08-27 Thread GitBox
flinkbot commented on pull request #13271: URL: https://github.com/apache/flink/pull/13271#issuecomment-682319220 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

[jira] [Updated] (FLINK-19043) Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese

2020-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19043: --- Labels: Documentation Translation pull-request-available translation-zh (was:

[GitHub] [flink] RocMarshal opened a new pull request #13271: [FLINK-19043][docs-zh] Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese

2020-08-27 Thread GitBox
RocMarshal opened a new pull request #13271: URL: https://github.com/apache/flink/pull/13271 ## What is the purpose of the change *Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese* ## Brief change log *Translate the 'Logging' page of

[GitHub] [flink] flinkbot edited a comment on pull request #13270: [hotfix] [javadocs] fix typo in TaskManagerServices

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13270: URL: https://github.com/apache/flink/pull/13270#issuecomment-682310308 ## CI report: * 04b974f56351d188b12bfe7c22a2fb8cb6e8f68e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 4eae231a2cd3edbb2ba34f7bef983f64a4c4fefa Azure:

[jira] [Closed] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

2020-08-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18900. Resolution: Fixed > HiveCatalog should error out when listing partitions with an invalid spec >

[jira] [Commented] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

2020-08-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186237#comment-17186237 ] Jingsong Lee commented on FLINK-18900: -- Revert interface modification for 1.11: 

[GitHub] [flink] JingsongLi merged pull request #13269: [FLINK-18900][table] Revert the modification of Catalog.listPartitions

2020-08-27 Thread GitBox
JingsongLi merged pull request #13269: URL: https://github.com/apache/flink/pull/13269 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot commented on pull request #13270: [hotfix] [javadocs] fix typo in TaskManagerServices

2020-08-27 Thread GitBox
flinkbot commented on pull request #13270: URL: https://github.com/apache/flink/pull/13270#issuecomment-682310308 ## CI report: * 04b974f56351d188b12bfe7c22a2fb8cb6e8f68e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 4eae231a2cd3edbb2ba34f7bef983f64a4c4fefa Azure:

[jira] [Updated] (FLINK-19081) Deprecate TemporalTableFunction and Table#createTemporalTableFunction()

2020-08-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19081: --- Summary: Deprecate TemporalTableFunction and Table#createTemporalTableFunction() (was: Deprecate

[jira] [Created] (FLINK-19082) Add docs for temporal table and temporal table join

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19082: -- Summary: Add docs for temporal table and temporal table join Key: FLINK-19082 URL: https://issues.apache.org/jira/browse/FLINK-19082 Project: Flink Issue Type:

[jira] [Created] (FLINK-19081) Deprecate TemporalTableFunction and Table$createTemporalTableFunction()

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19081: -- Summary: Deprecate TemporalTableFunction and Table$createTemporalTableFunction() Key: FLINK-19081 URL: https://issues.apache.org/jira/browse/FLINK-19081 Project: Flink

[jira] [Created] (FLINK-19080) Materialize timeindicator data type in the right input of temporal join

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19080: -- Summary: Materialize timeindicator data type in the right input of temporal join Key: FLINK-19080 URL: https://issues.apache.org/jira/browse/FLINK-19080 Project: Flink

[jira] [Created] (FLINK-19079) Support row time deduplicate operator

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19079: -- Summary: Support row time deduplicate operator Key: FLINK-19079 URL: https://issues.apache.org/jira/browse/FLINK-19079 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19077) Improve process time temporal join operator

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19077: -- Summary: Improve process time temporal join operator Key: FLINK-19077 URL: https://issues.apache.org/jira/browse/FLINK-19077 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19078) Import rowtime join temporal operator

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19078: -- Summary: Import rowtime join temporal operator Key: FLINK-19078 URL: https://issues.apache.org/jira/browse/FLINK-19078 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19076) Import rule to deal Temporal Join condition

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19076: -- Summary: Import rule to deal Temporal Join condition Key: FLINK-19076 URL: https://issues.apache.org/jira/browse/FLINK-19076 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19075) Infer changelog trait for temporal join node

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19075: -- Summary: Infer changelog trait for temporal join node Key: FLINK-19075 URL: https://issues.apache.org/jira/browse/FLINK-19075 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19073) Improve streamExecTemporalJoinRule

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19073: -- Summary: Improve streamExecTemporalJoinRule Key: FLINK-19073 URL: https://issues.apache.org/jira/browse/FLINK-19073 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19074) Materialize timeindicator in the right input of temporal join

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19074: -- Summary: Materialize timeindicator in the right input of temporal join Key: FLINK-19074 URL: https://issues.apache.org/jira/browse/FLINK-19074 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #13270: [hotfix] [javadocs] fix typo in TaskManagerServices

2020-08-27 Thread GitBox
flinkbot commented on pull request #13270: URL: https://github.com/apache/flink/pull/13270#issuecomment-682306916 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

[jira] [Created] (FLINK-19072) Import Temporal Table join rule

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19072: -- Summary: Import Temporal Table join rule Key: FLINK-19072 URL: https://issues.apache.org/jira/browse/FLINK-19072 Project: Flink Issue Type: Sub-task

[GitHub] [flink] sdlcwangsong opened a new pull request #13270: [hotfix] [javadocs] fix typo in TaskManagerServices

2020-08-27 Thread GitBox
sdlcwangsong opened a new pull request #13270: URL: https://github.com/apache/flink/pull/13270 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink] flinkbot edited a comment on pull request #13263: [FLINK-17273][runtime] ActiveResourceManager closes task manager connection on worker terminated.

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13263: URL: https://github.com/apache/flink/pull/13263#issuecomment-681892463 ## CI report: * 990aa0f33e2fa93d40ea011082fedc6eeb37be44 Azure:

[jira] [Created] (FLINK-19070) Hive connector should throw a meaningful exception if user reads/writes ACID tables

2020-08-27 Thread Rui Li (Jira)
Rui Li created FLINK-19070: -- Summary: Hive connector should throw a meaningful exception if user reads/writes ACID tables Key: FLINK-19070 URL: https://issues.apache.org/jira/browse/FLINK-19070 Project:

[jira] [Comment Edited] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-08-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186232#comment-17186232 ] Nicholas Jiang edited comment on FLINK-19064 at 8/28/20, 3:22 AM: --

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-08-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186232#comment-17186232 ] Nicholas Jiang commented on FLINK-19064: [~ZhuShang] Please pay attention to the defintion of

[jira] [Created] (FLINK-19071) Some Hive window functions are not supported

2020-08-27 Thread Rui Li (Jira)
Rui Li created FLINK-19071: -- Summary: Some Hive window functions are not supported Key: FLINK-19071 URL: https://issues.apache.org/jira/browse/FLINK-19071 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

2020-08-27 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186231#comment-17186231 ] Kenneth William Krugler commented on FLINK-19069: - I'd recently posted about a related

[GitHub] [flink] flinkbot edited a comment on pull request #13263: [FLINK-17273][runtime] ActiveResourceManager closes task manager connection on worker terminated.

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13263: URL: https://github.com/apache/flink/pull/13263#issuecomment-681892463 ## CI report: * 990aa0f33e2fa93d40ea011082fedc6eeb37be44 Azure:

[jira] [Updated] (FLINK-16824) FLIP-132 Temporal Table DDL and Temporal Table Join

2020-08-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16824: --- Summary: FLIP-132 Temporal Table DDL and Temporal Table Join (was: Creating Temporal Table

[jira] [Updated] (FLINK-19063) Support join late event from dimension table side in temporal table join

2020-08-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19063: --- Description: To join late event from dimension table side in temporal table join is a common user

[jira] [Comment Edited] (FLINK-19005) used metaspace grow on every execution

2020-08-27 Thread ShenDa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186221#comment-17186221 ] ShenDa edited comment on FLINK-19005 at 8/28/20, 2:57 AM: -- [~chesnay] Thanks

[GitHub] [flink] xintongsong commented on pull request #13263: [FLINK-17273][runtime] ActiveResourceManager closes task manager connection on worker terminated.

2020-08-27 Thread GitBox
xintongsong commented on pull request #13263: URL: https://github.com/apache/flink/pull/13263#issuecomment-682296119 Thanks for the review, @tillrohrmann This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-08-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186224#comment-17186224 ] Nicholas Jiang commented on FLINK-19064: [~jark] I guess the meaning of [~ZhuShang] is that the

[jira] [Comment Edited] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-08-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186224#comment-17186224 ] Nicholas Jiang edited comment on FLINK-19064 at 8/28/20, 2:51 AM: --

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

2020-08-27 Thread ShenDa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186221#comment-17186221 ] ShenDa commented on FLINK-19005: [~chesnay] Thanks for your detailed instruction. But I still think

[jira] [Updated] (FLINK-19005) used metaspace grow on every execution

2020-08-27 Thread ShenDa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ShenDa updated FLINK-19005: --- Attachment: modified-jdbc-inputformat.png > used metaspace grow on every execution >

[jira] [Created] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

2020-08-27 Thread Jiayi Liao (Jira)
Jiayi Liao created FLINK-19069: -- Summary: finalizeOnMaster takes too much time and client timeouts Key: FLINK-19069 URL: https://issues.apache.org/jira/browse/FLINK-19069 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #13269: [FLINK-18900][table] Revert the modification of Catalog.listPartitions

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13269: URL: https://github.com/apache/flink/pull/13269#issuecomment-682288332 ## CI report: * c967e9837780e4ac82c668845bc35d1a38c47ee8 Azure:

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-08-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186215#comment-17186215 ] Jark Wu commented on FLINK-19064: - Hi [~ZhuShang], why the connection should be created in

[jira] [Assigned] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-08-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19064: --- Assignee: Nicholas Jiang > HBaseRowDataInputFormat is leaking resources >

[jira] [Updated] (FLINK-19005) used metaspace grow on every execution

2020-08-27 Thread ShenDa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ShenDa updated FLINK-19005: --- Attachment: origin-jdbc-inputformat.png > used metaspace grow on every execution >

[jira] [Created] (FLINK-19068) Filter verbose pod events for KubernetesResourceManagerDriver

2020-08-27 Thread Xintong Song (Jira)
Xintong Song created FLINK-19068: Summary: Filter verbose pod events for KubernetesResourceManagerDriver Key: FLINK-19068 URL: https://issues.apache.org/jira/browse/FLINK-19068 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #13269: [FLINK-18900][table] Revert the modification of Catalog.listPartitions

2020-08-27 Thread GitBox
flinkbot commented on pull request #13269: URL: https://github.com/apache/flink/pull/13269#issuecomment-682288332 ## CI report: * c967e9837780e4ac82c668845bc35d1a38c47ee8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13268: [FLINK-18988][hotfix][doc] Fix Flink Kafka Connector Dependency Error

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13268: URL: https://github.com/apache/flink/pull/13268#issuecomment-682283788 ## CI report: * 5357812df45c42860e95630891367a410f6bc34b Azure:

[jira] [Commented] (FLINK-15719) Exceptions when using scala types directly with the State Process API

2020-08-27 Thread Ying Z (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186212#comment-17186212 ] Ying Z commented on FLINK-15719: I pull a request here, [https://github.com/apache/flink/pull/13266]

[jira] [Closed] (FLINK-19060) Checkpoint not triggered when use broadcast stream

2020-08-27 Thread henvealf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] henvealf closed FLINK-19060. Resolution: Not A Bug > Checkpoint not triggered when use broadcast stream >

[GitHub] [flink] flinkbot commented on pull request #13269: [FLINK-18900][table] Revert the modification of Catalog.listPartitions

2020-08-27 Thread GitBox
flinkbot commented on pull request #13269: URL: https://github.com/apache/flink/pull/13269#issuecomment-682286516 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

[GitHub] [flink] JingsongLi opened a new pull request #13269: [FLINK-18900][table] Revert the modification of Catalog.listPartitions

2020-08-27 Thread GitBox
JingsongLi opened a new pull request #13269: URL: https://github.com/apache/flink/pull/13269 Revert the modification of Catalog.listPartitions for version Compatibility. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

2020-08-27 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186205#comment-17186205 ] Rui Li commented on FLINK-18900: Perhaps we can revert the change in 1.11, given that 1.11 doesn't

[jira] [Comment Edited] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

2020-08-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186204#comment-17186204 ] Jingsong Lee edited comment on FLINK-18900 at 8/28/20, 2:08 AM: We

[jira] [Commented] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

2020-08-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186204#comment-17186204 ] Jingsong Lee commented on FLINK-18900: -- We should not modify method throws exception for

[jira] [Reopened] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

2020-08-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-18900: -- > HiveCatalog should error out when listing partitions with an invalid spec >

[GitHub] [flink] flinkbot commented on pull request #13268: [FLINK-18988][hotfix][doc] Fix Flink Kafka Connector Dependency Error

2020-08-27 Thread GitBox
flinkbot commented on pull request #13268: URL: https://github.com/apache/flink/pull/13268#issuecomment-682283788 ## CI report: * 5357812df45c42860e95630891367a410f6bc34b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-19067) FileNotFoundException when run flink examples on standby JobManager

2020-08-27 Thread JieFang.He (Jira)
JieFang.He created FLINK-19067: -- Summary: FileNotFoundException when run flink examples on standby JobManager Key: FLINK-19067 URL: https://issues.apache.org/jira/browse/FLINK-19067 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #13268: [FLINK-18988][hotfix][doc] Fix Flink Kafka Connector Dependency Error

2020-08-27 Thread GitBox
flinkbot commented on pull request #13268: URL: https://github.com/apache/flink/pull/13268#issuecomment-682280167 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

[jira] [Updated] (FLINK-18988) Continuous query with LATERAL and LIMIT produces wrong result

2020-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18988: --- Labels: pull-request-available (was: ) > Continuous query with LATERAL and LIMIT produces

[GitHub] [flink] Fin-chan opened a new pull request #13268: [FLINK-18988][hotfix][doc] Fix Flink Kafka Connector Dependency Error

2020-08-27 Thread GitBox
Fin-chan opened a new pull request #13268: URL: https://github.com/apache/flink/pull/13268 ## What is the purpose of the change Fix Flink Kafka Connector Dependency Error in Doc ## Brief change log example:flink-connector-kafka-011{{ site.scala_version_suffix }} change to

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

2020-08-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186198#comment-17186198 ] Dian Fu commented on FLINK-17274: -

[jira] [Updated] (FLINK-19066) InnerJoinITCase.testBigForSpill failed with "java.lang.ClassCastException: org.apache.flink.table.runtime.util.ResettableExternalBuffer$BufferIterator cannot be cast to

2020-08-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19066: Labels: test-stability (was: ) > InnerJoinITCase.testBigForSpill failed with

[jira] [Created] (FLINK-19066) InnerJoinITCase.testBigForSpill failed with "java.lang.ClassCastException: org.apache.flink.table.runtime.util.ResettableExternalBuffer$BufferIterator cannot be cast to

2020-08-27 Thread Dian Fu (Jira)
Dian Fu created FLINK-19066: --- Summary: InnerJoinITCase.testBigForSpill failed with "java.lang.ClassCastException: org.apache.flink.table.runtime.util.ResettableExternalBuffer$BufferIterator cannot be cast to

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-08-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186197#comment-17186197 ] Nicholas Jiang commented on FLINK-19064: [~jark] Yes of course. Could you assign this to me? >

[GitHub] [flink] flinkbot edited a comment on pull request #13267: [FLINK-19012][task] Check AsyncCheckpointRunnable status before throwing an exception

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13267: URL: https://github.com/apache/flink/pull/13267#issuecomment-682125254 ## CI report: * 9d1f76cbf475a5ea187dc84bd0c54a936c7a87c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * 18f88af3b438b13e9a240efd2b4979f841d2b978 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13265: [FLINK-19055] Wait less time for all memory GC in tests (MemoryManager#verifyEmpty)

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13265: URL: https://github.com/apache/flink/pull/13265#issuecomment-682059106 ## CI report: * af69156ea6dbc7513cb7dde023cdf8cc454bec31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13234: URL: https://github.com/apache/flink/pull/13234#issuecomment-679243226 ## CI report: * e5a866429bf22eb6aeeb26733e5ab1d705780e66 UNKNOWN * 2382ecb7dcb679dddbc39f44717ed1c4c7c061cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13267: [FLINK-19012][task] Check AsyncCheckpointRunnable status before throwing an exception

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13267: URL: https://github.com/apache/flink/pull/13267#issuecomment-682125254 ## CI report: * 9d1f76cbf475a5ea187dc84bd0c54a936c7a87c6 Azure:

[GitHub] [flink] flinkbot commented on pull request #13267: [FLINK-19012][task] Check AsyncCheckpointRunnable status before throwing an exception

2020-08-27 Thread GitBox
flinkbot commented on pull request #13267: URL: https://github.com/apache/flink/pull/13267#issuecomment-682125254 ## CI report: * 9d1f76cbf475a5ea187dc84bd0c54a936c7a87c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Reopened] (FLINK-16789) Retrieve JMXRMI information via REST API or WebUI

2020-08-27 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reopened FLINK-16789: --- > Retrieve JMXRMI information via REST API or WebUI > -

[jira] [Updated] (FLINK-16789) Retrieve JMXRMI information via REST API or WebUI

2020-08-27 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16789: -- Summary: Retrieve JMXRMI information via REST API or WebUI (was: Support JMX RMI random port assign

[jira] [Commented] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

2020-08-27 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186045#comment-17186045 ] Rong Rong commented on FLINK-16789: --- oops. yes you are right [~chesnay]. the closed PR doesn't contain

[GitHub] [flink] flinkbot edited a comment on pull request #13266: [FLINK-15719] fix mistake of reading state in scala lang.

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13266: URL: https://github.com/apache/flink/pull/13266#issuecomment-682067939 ## CI report: * e3bd4b8fcc871f1d0b6f6154515dee6268e70fd1 Azure:

[GitHub] [flink] flinkbot commented on pull request #13267: [FLINK-19012][task] Check AsyncCheckpointRunnable status before throwing an exception

2020-08-27 Thread GitBox
flinkbot commented on pull request #13267: URL: https://github.com/apache/flink/pull/13267#issuecomment-682120413 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

[jira] [Updated] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument."

2020-08-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19012: --- Labels: pull-request-available test-stability (was: test-stability) > E2E test fails with

[GitHub] [flink] rkhachatryan opened a new pull request #13267: [FLINK-19012] Check AsyncCheckpointRunnable status before throwing an exception

2020-08-27 Thread GitBox
rkhachatryan opened a new pull request #13267: URL: https://github.com/apache/flink/pull/13267 ## What is the purpose of the change Currently, `AsyncCheckpointRunnable` throws an exception if `SubtaskCheckpointCoordinatorImpl` is closed. However, it should also check its own

[jira] [Commented] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument."

2020-08-27 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186036#comment-17186036 ] Roman Khachatryan commented on FLINK-19012: --- I think the problem is that

[jira] [Comment Edited] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

2020-08-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186024#comment-17186024 ] Chesnay Schepler edited comment on FLINK-16789 at 8/27/20, 6:12 PM:

[jira] [Commented] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

2020-08-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186024#comment-17186024 ] Chesnay Schepler commented on FLINK-16789: -- [~rongr] What about the port retrieval? Random port

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * bce753ff7f4da2cffa295bd4007517af4c5697d8 Azure:

[jira] [Closed] (FLINK-19009) wrong way to calculate the "downtime" metric

2020-08-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-19009. - Release Note: The down time metric is now calculated as described in the documentation.

[GitHub] [flink] tillrohrmann closed pull request #13242: [FLINK-19009][metrics] Fixed the downtime metric issue and updated the comment

2020-08-27 Thread GitBox
tillrohrmann closed pull request #13242: URL: https://github.com/apache/flink/pull/13242 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Commented] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

2020-08-27 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186002#comment-17186002 ] Rong Rong commented on FLINK-16789: --- After discussion in

[jira] [Closed] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

2020-08-27 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-16789. - Resolution: Won't Fix > Support JMX RMI random port assign & retrieval via JMXConnectorServer >

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

2020-08-27 Thread GitBox
flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * bce753ff7f4da2cffa295bd4007517af4c5697d8 Azure:

[jira] [Assigned] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument."

2020-08-27 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-19012: - Assignee: Roman Khachatryan > E2E test fails with "Cannot register Closeable,

  1   2   3   >