[GitHub] [flink] flinkbot edited a comment on pull request #15258: [FLINK-21236][core] Remove HeapMemorySegment

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15258: URL: https://github.com/apache/flink/pull/15258#issuecomment-801634358 ## CI report: * 3247381e73d0828fb1129edcc0cf78eeeb5590db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15223: [hotfix][javadocs] Expand JavaDoc for AccumulatorHelper

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15223: URL: https://github.com/apache/flink/pull/15223#issuecomment-799779491 ## CI report: * f12a1ac3afc264fe3b4b2cd81e6a9b01dae8bef2 Azure:

[GitHub] [flink] jiamo commented on a change in pull request #15157: [FLINK-21661][kinesis] Fix fetch interval for polling consumer

2021-03-17 Thread GitBox
jiamo commented on a change in pull request #15157: URL: https://github.com/apache/flink/pull/15157#discussion_r596571560 ## File path:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

2021-03-17 Thread GitBox
KarmaGYZ commented on a change in pull request #15249: URL: https://github.com/apache/flink/pull/15249#discussion_r596505083 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java ## @@ -636,6 +637,15 @@

[GitHub] [flink] KarmaGYZ commented on a change in pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

2021-03-17 Thread GitBox
KarmaGYZ commented on a change in pull request #15249: URL: https://github.com/apache/flink/pull/15249#discussion_r596505083 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java ## @@ -636,6 +637,15 @@

[GitHub] [flink] flinkbot commented on pull request #15258: [FLINK-21236][core] Remove HeapMemorySegment

2021-03-17 Thread GitBox
flinkbot commented on pull request #15258: URL: https://github.com/apache/flink/pull/15258#issuecomment-801634358 ## CI report: * 3247381e73d0828fb1129edcc0cf78eeeb5590db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 8a320ad9b0780b4b18c23c68314ffd2b750f259c UNKNOWN * caa06f04efd36b7d1325bbb21c075580f26c0d1a Azure:

[GitHub] [flink] flinkbot commented on pull request #15258: [FLINK-21236][core] Remove HeapMemorySegment

2021-03-17 Thread GitBox
flinkbot commented on pull request #15258: URL: https://github.com/apache/flink/pull/15258#issuecomment-801624163 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-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21236: --- Labels: pull-request-available (was: ) > Don't explicitly use HeapMemorySegment in raw

[GitHub] [flink] xintongsong opened a new pull request #15258: [FLINK-21236][core] Remove HeapMemorySegment

2021-03-17 Thread GitBox
xintongsong opened a new pull request #15258: URL: https://github.com/apache/flink/pull/15258 ## 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] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread GitBox
zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r596548222 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java ## @@ -344,6 +344,13 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15257: URL: https://github.com/apache/flink/pull/15257#issuecomment-801601825 ## CI report: * c75184bb0b59c6bd548ba481d96525991a2bac07 UNKNOWN * e98801c410ec95737e91892661e393752f5e4468 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15231: URL: https://github.com/apache/flink/pull/15231#issuecomment-800077062 ## CI report: * 6284c51302491e962e3e00ae535d5828f2797d59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 8a320ad9b0780b4b18c23c68314ffd2b750f259c UNKNOWN * caa06f04efd36b7d1325bbb21c075580f26c0d1a Azure:

[GitHub] [flink] lirui-apache commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-03-17 Thread GitBox
lirui-apache commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-801610111 @tillrohrmann Would you mind also have a look at the PR? This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #15256: [FLINK-21851][table-runtime] Refactor BinaryRowDataKeySelector in testing

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15256: URL: https://github.com/apache/flink/pull/15256#issuecomment-801601761 ## CI report: * 31a064e494baca38cf8185fe7d84c2b3579cf28f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15257: URL: https://github.com/apache/flink/pull/15257#issuecomment-801601825 ## CI report: * c75184bb0b59c6bd548ba481d96525991a2bac07 UNKNOWN * e98801c410ec95737e91892661e393752f5e4468 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15249: URL: https://github.com/apache/flink/pull/15249#issuecomment-800824909 ## CI report: * 2aea1ede2fcf41ea68f92dad2efb3936d284269c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15231: URL: https://github.com/apache/flink/pull/15231#issuecomment-800077062 ## CI report: * 6284c51302491e962e3e00ae535d5828f2797d59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15088: URL: https://github.com/apache/flink/pull/15088#issuecomment-791143147 ## CI report: * 8b6a26906b09777c9c5cb1e8ae6507c30963f304 Azure:

[jira] [Assigned] (FLINK-21837) Support StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporalJoin json ser/de

2021-03-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21837: -- Assignee: Terry Wang > Support

[jira] [Assigned] (FLINK-21816) Support StreamExecMatch json ser/de

2021-03-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21816: -- Assignee: Wenlong Lyu > Support StreamExecMatch json ser/de >

[jira] [Assigned] (FLINK-21815) Support StreamExecUnion json ser/de

2021-03-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21815: -- Assignee: Wenlong Lyu > Support StreamExecUnion json ser/de >

[jira] [Assigned] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de

2021-03-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21805: -- Assignee: Wenlong Lyu > Support StreamExecRank and StreamExecSortLimit and StreamExecLimit

[jira] [Assigned] (FLINK-21813) Support StreamExecOverAggregate json ser/de

2021-03-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21813: -- Assignee: Wenlong Lyu > Support StreamExecOverAggregate json ser/de >

[jira] [Assigned] (FLINK-21811) Support StreamExecJoin json serialization/deserialization

2021-03-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21811: -- Assignee: Terry Wang > Support StreamExecJoin json serialization/deserialization >

[GitHub] [flink] godfreyhe commented on a change in pull request #15220: [FLINK-21744][table-planner-blink]Support StreamExecDeduplicate json serialization/deserialization

2021-03-17 Thread GitBox
godfreyhe commented on a change in pull request #15220: URL: https://github.com/apache/flink/pull/15220#discussion_r596535593 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/DeduplicationJsonPlanITCase.java

[GitHub] [flink] flinkbot commented on pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread GitBox
flinkbot commented on pull request #15257: URL: https://github.com/apache/flink/pull/15257#issuecomment-801601825 ## CI report: * c75184bb0b59c6bd548ba481d96525991a2bac07 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15256: [FLINK-21851][table-runtime] Refactor BinaryRowDataKeySelector in testing

2021-03-17 Thread GitBox
flinkbot commented on pull request #15256: URL: https://github.com/apache/flink/pull/15256#issuecomment-801601761 ## CI report: * 31a064e494baca38cf8185fe7d84c2b3579cf28f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15249: URL: https://github.com/apache/flink/pull/15249#issuecomment-800824909 ## CI report: * 2aea1ede2fcf41ea68f92dad2efb3936d284269c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 8a320ad9b0780b4b18c23c68314ffd2b750f259c UNKNOWN * caa06f04efd36b7d1325bbb21c075580f26c0d1a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15088: URL: https://github.com/apache/flink/pull/15088#issuecomment-791143147 ## CI report: * 8b6a26906b09777c9c5cb1e8ae6507c30963f304 Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #15215: [FLINK-21785][table-planner-blink] Support json ser/de for StreamExecCorrelate

2021-03-17 Thread GitBox
godfreyhe commented on a change in pull request #15215: URL: https://github.com/apache/flink/pull/15215#discussion_r596530326 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecCorrelate.java ## @@

[jira] [Comment Edited] (FLINK-21728) DegreesWithExceptionITCase crash

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303822#comment-17303822 ] Guowei Ma edited comment on FLINK-21728 at 3/18/21, 3:46 AM: -

[jira] [Closed] (FLINK-21777) Replace the 4M data writing cache of sort-merge shuffle with writev system call

2021-03-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-21777. --- Resolution: Fixed done via 61bc9429d6afde18711bcc726f077ade5e3b44a8 > Replace the 4M data writing cache of

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303840#comment-17303840 ] Guowei Ma commented on FLINK-21214: ---

[GitHub] [flink] zhuzhurk merged pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

2021-03-17 Thread GitBox
zhuzhurk merged pull request #15192: URL: https://github.com/apache/flink/pull/15192 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

[jira] [Commented] (FLINK-21833) TemporalRowTimeJoinOperator State Leak Although configure idle.state.retention.time

2021-03-17 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303838#comment-17303838 ] lynn1.zhang commented on FLINK-21833: - Please take a look at this. We depend on this in our

[jira] [Comment Edited] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303834#comment-17303834 ] Guowei Ma edited comment on FLINK-20329 at 3/18/21, 3:41 AM: - also hang

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303836#comment-17303836 ] Guowei Ma commented on FLINK-20329: ---

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303834#comment-17303834 ] Guowei Ma commented on FLINK-20329: ---

[GitHub] [flink] fsk119 commented on pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

2021-03-17 Thread GitBox
fsk119 commented on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-801594781 Thanks for @wuchong detailed guidance. =-= Cheers! This is an automated message from the Apache Git

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303831#comment-17303831 ] Guowei Ma commented on FLINK-21103: ---

[jira] [Created] (FLINK-21853) Running HA per-job cluster (rocks, non-incremental) end-to-end test could not finished in 900 seconds

2021-03-17 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21853: - Summary: Running HA per-job cluster (rocks, non-incremental) end-to-end test could not finished in 900 seconds Key: FLINK-21853 URL: https://issues.apache.org/jira/browse/FLINK-21853

[GitHub] [flink] godfreyhe commented on a change in pull request #15239: [FLINK-21811][blink-table-planner]Support StreamExecJoin json serialization/deserialization

2021-03-17 Thread GitBox
godfreyhe commented on a change in pull request #15239: URL: https://github.com/apache/flink/pull/15239#discussion_r596525054 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/JoinJsonPlanITCase.java ## @@

[jira] [Closed] (FLINK-21462) Use configuration to store the option and value in Sql client

2021-03-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21462. --- Resolution: Fixed Fixed in master: 956c0716fdbf20bf53305fe4d023fa2bea412595 > Use configuration to store

[GitHub] [flink] flinkbot commented on pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread GitBox
flinkbot commented on pull request #15257: URL: https://github.com/apache/flink/pull/15257#issuecomment-801591946 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] wuchong merged pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

2021-03-17 Thread GitBox
wuchong merged pull request #15197: URL: https://github.com/apache/flink/pull/15197 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 to

[jira] [Updated] (FLINK-21852) Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21852: --- Labels: pull-request-available (was: ) > Introduce SupportsAnyNull to BinaryRowData >

[GitHub] [flink] JingsongLi opened a new pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread GitBox
JingsongLi opened a new pull request #15257: URL: https://github.com/apache/flink/pull/15257 ## What is the purpose of the change Introduce SupportsAnyNull to BinaryRowData. We should avoid force casting to implementation. It is better to rely on interface. ##

[jira] [Assigned] (FLINK-21852) Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-21852: Assignee: Jingsong Lee > Introduce SupportsAnyNull to BinaryRowData >

[jira] [Created] (FLINK-21852) Introduce SupportsAnyNull to BinaryRowData

2021-03-17 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-21852: Summary: Introduce SupportsAnyNull to BinaryRowData Key: FLINK-21852 URL: https://issues.apache.org/jira/browse/FLINK-21852 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #15233: [FLINK-21815][table-planner-blink] Support json ser/de for StreamExecUnion

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15233: URL: https://github.com/apache/flink/pull/15233#issuecomment-800090052 ## CI report: * 92c071d079f4a414b93c9d8e03ea66413ad6917e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15215: [FLINK-21785][table-planner-blink] Support json ser/de for StreamExecCorrelate

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * c3b5b06adcfc08bbe4708038cbe4f13d2f2b7824 Azure:

[GitHub] [flink] flinkbot commented on pull request #15256: [FLINK-21851][table-runtime] Refactor BinaryRowDataKeySelector in testing

2021-03-17 Thread GitBox
flinkbot commented on pull request #15256: URL: https://github.com/apache/flink/pull/15256#issuecomment-801586692 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] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * ba939dc9bb21ef182fb7aedd954d5219a61adc8f Azure:

[jira] [Updated] (FLINK-21851) Refactor BinaryRowDataKeySelector in testing

2021-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21851: --- Labels: pull-request-available (was: ) > Refactor BinaryRowDataKeySelector in testing >

[GitHub] [flink] JingsongLi opened a new pull request #15256: [FLINK-21851][table-runtime] Refactor BinaryRowDataKeySelector in testing

2021-03-17 Thread GitBox
JingsongLi opened a new pull request #15256: URL: https://github.com/apache/flink/pull/15256 ## What is the purpose of the change Refactor BinaryRowDataKeySelector in testing. We can introduce a HandwrittenSelectorUtil to replace BinaryRowDataKeySelector newInstance for reduce

[GitHub] [flink] KarmaGYZ commented on pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

2021-03-17 Thread GitBox
KarmaGYZ commented on pull request #15249: URL: https://github.com/apache/flink/pull/15249#issuecomment-801585649 Thanks for the comments @zentol . PR updated. This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21148: -- Affects Version/s: 1.11.3 > YARNSessionFIFOSecuredITCase cannot connect to BlobServer >

[jira] [Commented] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303827#comment-17303827 ] Guowei Ma commented on FLINK-21148: ---

[GitHub] [flink] flinkbot edited a comment on pull request #13924: [FLINK-19938][network] Implement shuffle data read scheduling for sort-merge blocking shuffle

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #13924: URL: https://github.com/apache/flink/pull/13924#issuecomment-721619690 ## CI report: * 2608b37bd27058d9768c8bffb8a9a5ddea2e7ba0 Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

2021-03-17 Thread GitBox
godfreyhe commented on a change in pull request #15231: URL: https://github.com/apache/flink/pull/15231#discussion_r596514471 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/SortSpecSerdeTest.java ## @@

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303825#comment-17303825 ] Guowei Ma commented on FLINK-20495: ---

[jira] [Assigned] (FLINK-21849) 'SHOW MODULES' tests for CliClientITCase lack the default module test case

2021-03-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21849: --- Assignee: Jane Chan > 'SHOW MODULES' tests for CliClientITCase lack the default module test case >

[jira] [Assigned] (FLINK-21847) Introduce DESC grammar in sql parser

2021-03-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21847: --- Assignee: jinfeng > Introduce DESC grammar in sql parser > >

[jira] [Commented] (FLINK-21745) JobMasterTest.testReconnectionAfterDisconnect hangs on azure

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303824#comment-17303824 ] Guowei Ma commented on FLINK-21745: ---

[jira] [Commented] (FLINK-21847) Introduce DESC grammar in sql parser

2021-03-17 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303823#comment-17303823 ] jinfeng commented on FLINK-21847: - [~fsk119]  Can you assign this to me ?   > Introduce DESC grammar in

[jira] [Commented] (FLINK-21728) DegreesWithExceptionITCase crash

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303822#comment-17303822 ] Guowei Ma commented on FLINK-21728: ---

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

2021-03-17 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303821#comment-17303821 ] Guowei Ma commented on FLINK-21103: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15233: [FLINK-21815][table-planner-blink] Support json ser/de for StreamExecUnion

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15233: URL: https://github.com/apache/flink/pull/15233#issuecomment-800090052 ## CI report: * 92c071d079f4a414b93c9d8e03ea66413ad6917e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 8a320ad9b0780b4b18c23c68314ffd2b750f259c UNKNOWN * caa06f04efd36b7d1325bbb21c075580f26c0d1a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15215: [FLINK-21785][table-planner-blink] Support json ser/de for StreamExecCorrelate

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * c3b5b06adcfc08bbe4708038cbe4f13d2f2b7824 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * ba939dc9bb21ef182fb7aedd954d5219a61adc8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13924: [FLINK-19938][network] Implement shuffle data read scheduling for sort-merge blocking shuffle

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #13924: URL: https://github.com/apache/flink/pull/13924#issuecomment-721619690 ## CI report: * 2608b37bd27058d9768c8bffb8a9a5ddea2e7ba0 Azure:

[jira] [Created] (FLINK-21851) Refactor BinaryRowDataKeySelector in testing

2021-03-17 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-21851: Summary: Refactor BinaryRowDataKeySelector in testing Key: FLINK-21851 URL: https://issues.apache.org/jira/browse/FLINK-21851 Project: Flink Issue Type:

[GitHub] [flink] lirui-apache commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread GitBox
lirui-apache commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r596516402 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java ## @@ -344,6 +344,13 @@

[jira] [Commented] (FLINK-20557) Support "STATEMENT SET" in SQL CLI

2021-03-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303815#comment-17303815 ] Shengkai Fang commented on FLINK-20557: --- [~nicholasjiang] I have some code before.  You can take

[GitHub] [flink] wenlong88 commented on pull request #15233: [FLINK-21815][table-planner-blink] Support json ser/de for StreamExecUnion

2021-03-17 Thread GitBox
wenlong88 commented on pull request #15233: URL: https://github.com/apache/flink/pull/15233#issuecomment-801573588 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-21850) Improve document and config description of sort-merge blocking shuffle

2021-03-17 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21850: --- Summary: Improve document and config description of sort-merge blocking shuffle Key: FLINK-21850 URL: https://issues.apache.org/jira/browse/FLINK-21850 Project: Flink

[jira] [Comment Edited] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303808#comment-17303808 ] Junfan Zhang edited comment on FLINK-21700 at 3/18/21, 2:36 AM: Sorry

[jira] [Comment Edited] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303808#comment-17303808 ] Junfan Zhang edited comment on FLINK-21700 at 3/18/21, 2:35 AM: Sorry

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread GitBox
zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r596510119 ## File path: docs/layouts/shortcodes/generated/yarn_config_configuration.html ## @@ -140,6 +140,12 @@ ListString A

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread GitBox
zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r596509990 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1079,15 +1080,24 @@ private ApplicationReport

[GitHub] [flink] lirui-apache commented on a change in pull request #15244: [FLINK-21829][Hive Connect]Fix to create HiveCatalog with custom hadoopconfdir first

2021-03-17 Thread GitBox
lirui-apache commented on a change in pull request #15244: URL: https://github.com/apache/flink/pull/15244#discussion_r596509049 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -224,7 +225,11 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15223: [hotfix][javadocs] Expand JavaDoc for AccumulatorHelper

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15223: URL: https://github.com/apache/flink/pull/15223#issuecomment-799779491 ## CI report: * f12a1ac3afc264fe3b4b2cd81e6a9b01dae8bef2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 9c364516ba15d5d72e9b51ffc190bd039e49bd15 Azure:

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread GitBox
zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r596508460 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ## @@ -197,21 +197,28 @@ private static LocalResource registerLocalResource(

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread GitBox
zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r596507902 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ## @@ -197,21 +197,28 @@ private static LocalResource registerLocalResource(

[jira] [Commented] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-17 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303808#comment-17303808 ] Junfan Zhang commented on FLINK-21700: -- Sorry to reply delay. [~fly_in_gis] According to your

[GitHub] [flink] zuston commented on pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

2021-03-17 Thread GitBox
zuston commented on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-801567451 Any update on it? @wangyang0918 This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-21848) table api -----window opening for event time。NullPointer

2021-03-17 Thread HunterHunter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303807#comment-17303807 ] HunterHunter commented on FLINK-21848: -- When i do keyby to datastream, i cannot trigger window

[GitHub] [flink] KarmaGYZ commented on a change in pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

2021-03-17 Thread GitBox
KarmaGYZ commented on a change in pull request #15249: URL: https://github.com/apache/flink/pull/15249#discussion_r596505083 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java ## @@ -636,6 +637,15 @@

[jira] [Created] (FLINK-21849) 'SHOW MODULES' tests for CliClientITCase lack the default module test case

2021-03-17 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-21849: -- Summary: 'SHOW MODULES' tests for CliClientITCase lack the default module test case Key: FLINK-21849 URL: https://issues.apache.org/jira/browse/FLINK-21849

[GitHub] [flink] flinkbot edited a comment on pull request #15223: [hotfix][javadocs] Expand JavaDoc for AccumulatorHelper

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15223: URL: https://github.com/apache/flink/pull/15223#issuecomment-799779491 ## CI report: * f12a1ac3afc264fe3b4b2cd81e6a9b01dae8bef2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

2021-03-17 Thread GitBox
flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 9c364516ba15d5d72e9b51ffc190bd039e49bd15 Azure:

[jira] [Commented] (FLINK-21848) table api -----window opening for event time。NullPointer

2021-03-17 Thread wangbin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303803#comment-17303803 ] wangbin commented on FLINK-21848: - i know  .   Need such: baseStream =

[GitHub] [flink] hehuiyuan commented on pull request #15244: [FLINK-21829][Hive Connect]Fix to create HiveCatalog with custom hadoopconfdir first

2021-03-17 Thread GitBox
hehuiyuan commented on pull request #15244: URL: https://github.com/apache/flink/pull/15244#issuecomment-801562077 Hi @SteNicholas @lirui-apache is this OK? This is an automated message from the Apache Git Service. To

[jira] [Comment Edited] (FLINK-21841) Can not find kafka-connect with sql-kafka-connector

2021-03-17 Thread JieFang.He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303802#comment-17303802 ] JieFang.He edited comment on FLINK-21841 at 3/18/21, 2:09 AM: -- I use the

[jira] [Commented] (FLINK-21841) Can not find kafka-connect with sql-kafka-connector

2021-03-17 Thread JieFang.He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303802#comment-17303802 ] JieFang.He commented on FLINK-21841: I use the maven plug “maven-assembly-plugin” to package the

  1   2   3   4   5   >