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

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

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

2021-03-17 Thread GitBox
godfreyhe commented on pull request #15233: URL: https://github.com/apache/flink/pull/15233#issuecomment-801681317 The failed test has nothing to do with this change, I will merge it This is an automated message from the Apac

[GitHub] [flink] rmetzger commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

2021-03-17 Thread GitBox
rmetzger commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r596594429 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elas

[GitHub] [flink] flinkbot commented on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-21854) WebUI show incorrect value

2021-03-17 Thread junbiao chen (Jira)
junbiao chen created FLINK-21854: Summary: WebUI show incorrect value Key: FLINK-21854 URL: https://issues.apache.org/jira/browse/FLINK-21854 Project: Flink Issue Type: Bug Componen

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

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

[GitHub] [flink] rmetzger commented on pull request #15086: [FLINK-21561] Predownload/Cache large E2E test artifacts

2021-03-17 Thread GitBox
rmetzger commented on pull request #15086: URL: https://github.com/apache/flink/pull/15086#issuecomment-801673712 I manually re-triggered the failed test, because it failed somewhere else: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14919&view=results --

[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: * 1887407f3da3a30437e00185199e6dcaea4107b4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-17 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303879#comment-17303879 ] Jane Chan commented on FLINK-21849: --- Hi, [~nicholasjiang] and [~jark], thanks for repo

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wangyang0918 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
wangyang0918 commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r596583782 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1079,15 +1080,24 @@ private ApplicationReport startAp

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20757) Optimize data broadcast for sort-merge shuffle

2021-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20757: --- Labels: pull-request-available (was: ) > Optimize data broadcast for sort-merge shuffle > -

[GitHub] [flink] flinkbot commented on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

2021-03-17 Thread GitBox
flinkbot commented on pull request #15259: URL: https://github.com/apache/flink/pull/15259#issuecomment-801658591 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 pro

[GitHub] [flink] wsry opened a new pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

2021-03-17 Thread GitBox
wsry opened a new pull request #15259: URL: https://github.com/apache/flink/pull/15259 ## What is the purpose of the change For data broadcast, we can only copy the record once when writing data into SortBuffer. Besides, we can write only one copy of data when spilling data into dis

[jira] [Commented] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

2021-03-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303866#comment-17303866 ] Yang Wang commented on FLINK-21685: --- [~trohrmann] At the very beginning, we have dedic

[GitHub] [flink] carp84 commented on a change in pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

2021-03-17 Thread GitBox
carp84 commented on a change in pull request #15205: URL: https://github.com/apache/flink/pull/15205#discussion_r596552594 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableSnapshot.java ## @@ -41,9 +41,18 @@ /** The offset

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPublish

[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 @@ publi

[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 @@ publi

[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 r

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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 pro

[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 form

[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 the

[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 @@ .withDescri

[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: [PENDING](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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 S

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 @flinkbo

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporal

[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 Js

[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 r

[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 r

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=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&focusedCommentId=17303840#comment-17303840 ] Guowei Ma commented on FLINK-21214: --- https://dev.azure.com/apache-flink/apache-flink/_

[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 to

[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&focusedCommentId=17303838#comment-17303838 ] lynn1.zhang commented on FLINK-21833: - Please take a look at this. We depend on this

[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&focusedCommentId=17303834#comment-17303834 ] Guowei Ma edited comment on FLINK-20329 at 3/18/21, 3:41 AM: -

[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&focusedCommentId=17303836#comment-17303836 ] Guowei Ma commented on FLINK-20329: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17303834#comment-17303834 ] Guowei Ma commented on FLINK-20329: --- https://dev.azure.com/apache-flink/apache-flink/_

[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 Serv

[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&focusedCommentId=17303831#comment-17303831 ] Guowei Ma commented on FLINK-21103: --- https://dev.azure.com/apache-flink/apache-flink/_

[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 th

[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 pro

[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. ## Verifying

[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: Improv

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 pro

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 mis

[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 resp

[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&focusedCommentId=17303827#comment-17303827 ] Guowei Ma commented on FLINK-21148: --- https://dev.azure.com/apache-flink/apache-flink/_

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 ## @@ -0,

[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&focusedCommentId=17303825#comment-17303825 ] Guowei Ma commented on FLINK-20495: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17303824#comment-17303824 ] Guowei Ma commented on FLINK-21745: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17303823#comment-17303823 ] jinfeng commented on FLINK-21847: - [~fsk119]  Can you assign this to me ?   > Introduce

[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&focusedCommentId=17303822#comment-17303822 ] Guowei Ma commented on FLINK-21728: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17303821#comment-17303821 ] Guowei Ma commented on FLINK-21103: --- https://dev.azure.com/apache-flink/apache-flink/_

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: Impr

[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 @@ .with

[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&focusedCommentId=17303815#comment-17303815 ] Shengkai Fang commented on FLINK-20557: --- [~nicholasjiang] I have some code before.

[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, pleas

[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

  1   2   3   4   5   >