[jira] [Commented] (FLINK-21455) Deploy history server on kubernetes

2021-03-14 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301441#comment-17301441 ] Yi Tang commented on FLINK-21455: - [~chesnay] what do you mean by the Dispatcher serve t

[GitHub] [flink] zck573693104 commented on a change in pull request #15203: [FLINK-21466][table] Add SQL Client default mode value embedded

2021-03-14 Thread GitBox
zck573693104 commented on a change in pull request #15203: URL: https://github.com/apache/flink/pull/15203#discussion_r594086882 ## File path: docs/dev/table/sqlClient.md ## @@ -45,10 +45,10 @@ The SQL Client is bundled in the regular Flink distribution and thus runnable ou

[jira] [Updated] (FLINK-18727) Remove the previous finished empty Buffer in PipelinedSubpartition when adding a new Buffer

2021-03-14 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-18727: Fix Version/s: (was: 1.13.0) > Remove the previous finished empty Buffer in PipelinedSubpartit

[GitHub] [flink] flinkbot commented on pull request #15213: [FLINK-21774][sql-client] Do not display column names when return set is emtpy in SQL Client

2021-03-14 Thread GitBox
flinkbot commented on pull request #15213: URL: https://github.com/apache/flink/pull/15213#issuecomment-799162574 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] [Closed] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition

2021-03-14 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-17208. --- Resolution: Won't Fix > Reduce redundant data available notification of PipelinedSubpartition >

[jira] [Commented] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition

2021-03-14 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301429#comment-17301429 ] Yingjie Cao commented on FLINK-17208: - This issue is introduced by FLINK-16428, now

[GitHub] [flink] flinkbot edited a comment on pull request #15198: [FLINK-21646][table-planner-blink] Support StreamExecWindowAggregate json serialization/deserialization

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15198: URL: https://github.com/apache/flink/pull/15198#issuecomment-798884575 ## CI report: * e3784819a257b30a892de06671886ffc83b1dcfb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15211: [FLINK-21740][sql client] Fix unstable CliTableauResultViewTest

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15211: URL: https://github.com/apache/flink/pull/15211#issuecomment-799147766 ## CI report: * b8357e04b35bf6f60265dc4efb0f4c4f50b29a78 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * 546bb52a009fee535df450c4ce569f1d8019ff6a UNKNOWN * 34c4d8cfb9b25f9c6afc212df2bfc8934b651ac5 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-79889 ## CI report: * 95bf51ed50d7706aeca72db222e5862a1c78eb79 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 808fe7e590fc53ec5f91285a3d1c1734bd7905dc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-18727) Remove the previous finished empty Buffer in PipelinedSubpartition when adding a new Buffer

2021-03-14 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-18727. --- Resolution: Won't Fix > Remove the previous finished empty Buffer in PipelinedSubpartition when > a

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

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * 524bb7d945c6d7436f75020ec37381eb98efa6bc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21774) Do not display column names when return set is emtpy in SQL Client

2021-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21774: --- Labels: pull-request-available (was: ) > Do not display column names when return set is emt

[jira] [Commented] (FLINK-18727) Remove the previous finished empty Buffer in PipelinedSubpartition when adding a new Buffer

2021-03-14 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301427#comment-17301427 ] Yingjie Cao commented on FLINK-18727: - This issue is introduced by FLINK-16428, now

[GitHub] [flink] flinkbot edited a comment on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * c327e27872f782274cab4e10692ef1d913f85c5d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] SteNicholas opened a new pull request #15213: [FLINK-21774][sql-client] Do not display column names when return set is emtpy in SQL Client

2021-03-14 Thread GitBox
SteNicholas opened a new pull request #15213: URL: https://github.com/apache/flink/pull/15213 ## What is the purpose of the change *Currently, SQL Client displays the column names when the return set of `SHOW MODULES` is empty:* ``` SHOW MODULES; +-+ | module

[GitHub] [flink] wsry closed pull request #12993: [FLINK-18727][network] Remove and recycle the finished empty Buffer in PipelinedSubpartition when adding a new one

2021-03-14 Thread GitBox
wsry closed pull request #12993: URL: https://github.com/apache/flink/pull/12993 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 the

[GitHub] [flink] flinkbot commented on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

2021-03-14 Thread GitBox
flinkbot commented on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-799158641 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] [Created] (FLINK-21790) Shuffle data directories to make data directory section of different TaskManagers fairer

2021-03-14 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21790: --- Summary: Shuffle data directories to make data directory section of different TaskManagers fairer Key: FLINK-21790 URL: https://issues.apache.org/jira/browse/FLINK-21790

[jira] [Commented] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-03-14 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301420#comment-17301420 ] Bhagi commented on FLINK-21432: --- Yang Wang Thanks for the support... i configured this i

[jira] [Commented] (FLINK-21749) unable to use scala Shell

2021-03-14 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301418#comment-17301418 ] Bhagi commented on FLINK-21749: --- Chesnay Schepler , i have configured 6126 as blob.server.

[jira] [Updated] (FLINK-21628) Support Python UDAF in Tumbling Window

2021-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21628: --- Labels: pull-request-available (was: ) > Support Python UDAF in Tumbling Window > -

[jira] [Updated] (FLINK-21749) unable to use scala Shell

2021-03-14 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-21749: -- Attachment: screenshot-1.png > unable to use scala Shell > - > > Key:

[GitHub] [flink] HuangXingBo opened a new pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

2021-03-14 Thread GitBox
HuangXingBo opened a new pull request #15212: URL: https://github.com/apache/flink/pull/15212 ## What is the purpose of the change *This pull request will support Python UDAF in Tumbling Window* ## Brief change log - *Add `window_aggregate.py`, `window_process_func

[jira] [Created] (FLINK-21789) Make FileChannelManagerImpl#getNextPathNum select data directory fairly

2021-03-14 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21789: --- Summary: Make FileChannelManagerImpl#getNextPathNum select data directory fairly Key: FLINK-21789 URL: https://issues.apache.org/jira/browse/FLINK-21789 Project: Flink

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

2021-03-14 Thread GitBox
zuston commented on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-799150019 @SteNicholas Please review again. Thanks. This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-21787) The method $(String) is undefined for the type TableExample

2021-03-14 Thread wangbin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301414#comment-17301414 ] wangbin commented on FLINK-21787: - UTF-8 1.12.1 1.8 2.12 ${target.java.version} $

[jira] [Commented] (FLINK-21787) The method $(String) is undefined for the type TableExample

2021-03-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301413#comment-17301413 ] Jark Wu commented on FLINK-21787: - Could you show the full imports? > The method $(Stri

[jira] [Assigned] (FLINK-21634) ALTER TABLE statement enhancement

2021-03-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21634: --- Assignee: Jane Chan > ALTER TABLE statement enhancement > - > >

[jira] [Assigned] (FLINK-21740) CliTableauResultViewTest.testCancelBatchResult fails

2021-03-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21740: --- Assignee: Shengkai Fang > CliTableauResultViewTest.testCancelBatchResult fails > -

[jira] [Updated] (FLINK-21787) The method $(String) is undefined for the type TableExample

2021-03-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21787: Component/s: Table SQL / API > The method $(String) is undefined for the type TableExample > -

[GitHub] [flink] flinkbot commented on pull request #15211: [FLINK-21740][sql client] Fix unstable CliTableauResultViewTest

2021-03-14 Thread GitBox
flinkbot commented on pull request #15211: URL: https://github.com/apache/flink/pull/15211#issuecomment-799147766 ## CI report: * b8357e04b35bf6f60265dc4efb0f4c4f50b29a78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] PatrickRen commented on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

2021-03-14 Thread GitBox
PatrickRen commented on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-799147723 Thank you @HuangXingBo and @lindong28 ! I just rebased the branch to master and pushed again. Hope we can pass all tests on Azure this time~

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

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * 546bb52a009fee535df450c4ce569f1d8019ff6a UNKNOWN * 34c4d8cfb9b25f9c6afc212df2bfc8934b651ac5 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-798833303 ## CI report: * 60f637033bdc7efb876dcd240b5ceac2f1628e2f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15195: URL: https://github.com/apache/flink/pull/15195#issuecomment-798871942 ## CI report: * 8f844ec2c7ace18f8d6a78efbabea949dd7b9a8c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15112: URL: https://github.com/apache/flink/pull/15112#issuecomment-792620617 ## CI report: * 0d505494b6fc2f31dcad47706fa20714812f1bc6 Azure: [SUCCESS](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-14 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * 524bb7d945c6d7436f75020ec37381eb98efa6bc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * c327e27872f782274cab4e10692ef1d913f85c5d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21419) Remove GC cleaner mechanism for unsafe memory segments

2021-03-14 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301408#comment-17301408 ] Kezhu Wang commented on FLINK-21419: Glad to see, we all lean to fail concurrent fre

[jira] [Created] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

2021-03-14 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21788: --- Summary: Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle Key: FLINK-21788 URL: https://issues.apache.org/jira/browse/FLINK-21788

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

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * f022fba23fd33b0f7c6854b0394d81b536d4eb3a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15195: URL: https://github.com/apache/flink/pull/15195#issuecomment-798871942 ## CI report: * 8f844ec2c7ace18f8d6a78efbabea949dd7b9a8c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-798833303 ## CI report: * 60f637033bdc7efb876dcd240b5ceac2f1628e2f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-21787) The method $(String) is undefined for the type TableExample

2021-03-14 Thread wangbin (Jira)
wangbin created FLINK-21787: --- Summary: The method $(String) is undefined for the type TableExample Key: FLINK-21787 URL: https://issues.apache.org/jira/browse/FLINK-21787 Project: Flink Issue Type

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15112: URL: https://github.com/apache/flink/pull/15112#issuecomment-792620617 ## CI report: * 0d505494b6fc2f31dcad47706fa20714812f1bc6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354][statebackend] Introduce ChangelogStateBackend to delegate state access

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN * 8e3149727880b6f2d8ce7f2b851f51be5b34

[GitHub] [flink] flinkbot commented on pull request #15211: [FLINK-21740][sql client] Fix unstable CliTableauResultViewTest

2021-03-14 Thread GitBox
flinkbot commented on pull request #15211: URL: https://github.com/apache/flink/pull/15211#issuecomment-799135590 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-21740) CliTableauResultViewTest.testCancelBatchResult fails

2021-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21740: --- Labels: pull-request-available test-stability (was: test-stability) > CliTableauResultView

[GitHub] [flink] fsk119 opened a new pull request #15211: [FLINK-21740][sql client] Fix unstable CliTableauResultViewTest

2021-03-14 Thread GitBox
fsk119 opened a new pull request #15211: URL: https://github.com/apache/flink/pull/15211 ## What is the purpose of the change *Before explain the reason why test fails, I will just describe the logic in the test. There are 3 parts in the test: `TestingExecutor`, `Terminal` an

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

2021-03-14 Thread GitBox
godfreyhe commented on a change in pull request #15210: URL: https://github.com/apache/flink/pull/15210#discussion_r594063426 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecChangelogNormalize.java #

[jira] [Commented] (FLINK-21753) Cycle references between memory manager and gc cleaner action

2021-03-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301400#comment-17301400 ] Xintong Song commented on FLINK-21753: -- I think returning a runnable from {{UnsafeM

[jira] [Assigned] (FLINK-21753) Cycle references between memory manager and gc cleaner action

2021-03-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21753: Assignee: Kezhu Wang > Cycle references between memory manager and gc cleaner action > --

[GitHub] [flink] beyond1920 commented on a change in pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
beyond1920 commented on a change in pull request #15195: URL: https://github.com/apache/flink/pull/15195#discussion_r594063115 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalWindowJoin.scala ##

[GitHub] [flink] flinkbot edited a comment on pull request #15209: [FLINK-21784] Allow extension of HeapBackend RestoreOperation

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15209: URL: https://github.com/apache/flink/pull/15209#issuecomment-798996080 ## CI report: * f22543ce4a30c01b8fb50325f0578378bf90d1ea Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15210: URL: https://github.com/apache/flink/pull/15210#issuecomment-799070139 ## CI report: * 3f76649b56bcb7c9159b44b0cbdf0db19a5b36c7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792438797 ## CI report: * bb6396608d6b3b0a2dc30824be5b9b9ef948afbc Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] wuchong commented on a change in pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
wuchong commented on a change in pull request #15195: URL: https://github.com/apache/flink/pull/15195#discussion_r594060694 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/WindowJoinTest.xml ## @@ -0,0

[GitHub] [flink] wuchong commented on a change in pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
wuchong commented on a change in pull request #15195: URL: https://github.com/apache/flink/pull/15195#discussion_r594060604 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowJoinUtil.scala ## @@ -0,0 +1,219 @@ +/

[jira] [Commented] (FLINK-21753) Cycle references between memory manager and gc cleaner action

2021-03-14 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301395#comment-17301395 ] Kezhu Wang commented on FLINK-21753: HI [~xintongsong], I am interesting in fix for

[GitHub] [flink] beyond1920 commented on a change in pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
beyond1920 commented on a change in pull request #15195: URL: https://github.com/apache/flink/pull/15195#discussion_r594057866 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/WindowJoinTest.xml ## @@ -0

[GitHub] [flink] beyond1920 commented on a change in pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
beyond1920 commented on a change in pull request #15195: URL: https://github.com/apache/flink/pull/15195#discussion_r594057866 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/WindowJoinTest.xml ## @@ -0

[GitHub] [flink] beyond1920 commented on a change in pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
beyond1920 commented on a change in pull request #15195: URL: https://github.com/apache/flink/pull/15195#discussion_r594057275 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowJoinUtil.scala ## @@ -0,0 +1,219 @@

[jira] [Created] (FLINK-21786) sample Job execution failed

2021-03-14 Thread Bhagi (Jira)
Bhagi created FLINK-21786: - Summary: sample Job execution failed Key: FLINK-21786 URL: https://issues.apache.org/jira/browse/FLINK-21786 Project: Flink Issue Type: Bug Components: Deploymen

[jira] [Closed] (FLINK-21177) Introduce the counterpart of slotmanager.number-of-slots.max in fine-grained resource management

2021-03-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21177. Resolution: Done Merged via * master (1.13): c775463288739580b2100a64c7a5ce36fc646a8c > Introduc

[GitHub] [flink] xintongsong closed pull request #15145: [FLINK-21177][runtime] Support limiting max resources with FineGrainedSlotManager

2021-03-14 Thread GitBox
xintongsong closed pull request #15145: URL: https://github.com/apache/flink/pull/15145 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 edited a comment on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15205: URL: https://github.com/apache/flink/pull/15205#issuecomment-798969965 ## CI report: * 8087d8f7d23911e311e212464badff6c89945e1d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-798833303 ## CI report: * 60f637033bdc7efb876dcd240b5ceac2f1628e2f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15195: URL: https://github.com/apache/flink/pull/15195#issuecomment-798871942 ## CI report: * 8f844ec2c7ace18f8d6a78efbabea949dd7b9a8c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * c327e27872f782274cab4e10692ef1d913f85c5d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15195: URL: https://github.com/apache/flink/pull/15195#issuecomment-798871942 ## CI report: * 8f844ec2c7ace18f8d6a78efbabea949dd7b9a8c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * 2ecf0b62e16a219f12a07f8a8867cbfde0dbef2f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * 672883a19e109f4dd7f735f95ac56a0167b5

[GitHub] [flink] flinkbot edited a comment on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * c327e27872f782274cab4e10692ef1d913f85c5d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] beyond1920 commented on pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
beyond1920 commented on pull request #15195: URL: https://github.com/apache/flink/pull/15195#issuecomment-799076070 @wuchong Thanks for review. I've address all your comments. This is an automated message from the Apache Git

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

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15210: URL: https://github.com/apache/flink/pull/15210#issuecomment-799070139 ## CI report: * 3f76649b56bcb7c9159b44b0cbdf0db19a5b36c7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * 2ecf0b62e16a219f12a07f8a8867cbfde0dbef2f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15153: [FLINK-21707][runtime] Do not trigger scheduling of non-CREATED regions in PipelinedRegionSchedulingStrategy

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15153: URL: https://github.com/apache/flink/pull/15153#issuecomment-796722164 ## CI report: * 51356714415e233af381f7098579db127b673d8b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-21785) Support StreamExecCorrelate json serde

2021-03-14 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-21785: --- Summary: Support StreamExecCorrelate json serde Key: FLINK-21785 URL: https://issues.apache.org/jira/browse/FLINK-21785 Project: Flink Issue Type: Sub-task

[GitHub] [flink] anlen321 edited a comment on pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

2021-03-14 Thread GitBox
anlen321 edited a comment on pull request #14684: URL: https://github.com/apache/flink/pull/14684#issuecomment-798913741 > I have rebased and squashed the branch to trigger the build again. Will merge it once build is passed. Thank you very much! ---

[GitHub] [flink] beyond1920 commented on a change in pull request #15195: [FLINK-19609][table-planner-blink] Support streaming window join in planner

2021-03-14 Thread GitBox
beyond1920 commented on a change in pull request #15195: URL: https://github.com/apache/flink/pull/15195#discussion_r594034270 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/WindowJoinTest.xml ## @@ -0

[jira] [Commented] (FLINK-21740) CliTableauResultViewTest.testCancelBatchResult fails

2021-03-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301367#comment-17301367 ] Shengkai Fang commented on FLINK-21740: --- Hi, all. Before explain the reason why t

[jira] [Assigned] (FLINK-20740) Use managed memory to avoid direct memory OOM error for sort-merge shuffle (introduce a separated buffer pool)

2021-03-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20740: Assignee: Yingjie Cao > Use managed memory to avoid direct memory OOM error for sort-merg

[jira] [Updated] (FLINK-20740) Use managed memory to avoid direct memory OOM error for sort-merge shuffle (introduce a separated buffer pool)

2021-03-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20740: - Affects Version/s: (was: 1.12.0) > Use managed memory to avoid direct memory OOM error for s

[GitHub] [flink] flinkbot commented on pull request #15210: [FLINK-21704] Support json ser/de for ChangelogSource

2021-03-14 Thread GitBox
flinkbot commented on pull request #15210: URL: https://github.com/apache/flink/pull/15210#issuecomment-799070139 ## CI report: * 3f76649b56bcb7c9159b44b0cbdf0db19a5b36c7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15198: [FLINK-21646][table-planner-blink] Support StreamExecWindowAggregate json serialization/deserialization

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15198: URL: https://github.com/apache/flink/pull/15198#issuecomment-798884575 ## CI report: * eb4538dd5d430ef046e18d515e2ae616505c6545 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15153: [FLINK-21707][runtime] Do not trigger scheduling of non-CREATED regions in PipelinedRegionSchedulingStrategy

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15153: URL: https://github.com/apache/flink/pull/15153#issuecomment-796722164 ## CI report: * 51356714415e233af381f7098579db127b673d8b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-14 Thread GitBox
xintongsong commented on pull request #15064: URL: https://github.com/apache/flink/pull/15064#issuecomment-799068697 Hi @rmetzger, I'd like to bring your attention to my previous comment, where I suggested to remove the warning on not supporting fine-grained resource specifications for

[jira] [Commented] (FLINK-21753) Cycle references between memory manager and gc cleaner action

2021-03-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301362#comment-17301362 ] Xintong Song commented on FLINK-21753: -- Thanks [~kezhuw]. While the master branch

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

2021-03-14 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301360#comment-17301360 ] Yang Wang commented on FLINK-21685: --- [~petrizhang] I think your analysis is right. The

[jira] [Commented] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

2021-03-14 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301357#comment-17301357 ] Danny Chen commented on FLINK-21520: That's also a good news, how did you get this c

[GitHub] [flink] zhuzhurk commented on a change in pull request #15153: [FLINK-21707][runtime] Do not trigger scheduling of non-CREATED regions in PipelinedRegionSchedulingStrategy

2021-03-14 Thread GitBox
zhuzhurk commented on a change in pull request #15153: URL: https://github.com/apache/flink/pull/15153#discussion_r594027269 ## File path: flink-tests/src/test/java/org/apache/flink/test/scheduling/PipelinedRegionSchedulingITCase.java ## @@ -204,4 +248,22 @@ public void invoke

[GitHub] [flink] flinkbot commented on pull request #15210: [FLINK-21704] Support json ser/de for ChangelogSource

2021-03-14 Thread GitBox
flinkbot commented on pull request #15210: URL: https://github.com/apache/flink/pull/15210#issuecomment-799062920 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 #15198: [FLINK-21646][table-planner-blink] Support StreamExecWindowAggregate json serialization/deserialization

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15198: URL: https://github.com/apache/flink/pull/15198#issuecomment-798884575 ## CI report: * eb4538dd5d430ef046e18d515e2ae616505c6545 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-79889 ## CI report: * 4468f453ee57c6e76b37ff6d9e245eb32d6a2989 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * f022fba23fd33b0f7c6854b0394d81b536d4eb3a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21704) Support StreamExecChangelogNormalize and StreamExecDropUpdateBefore json serde

2021-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21704: --- Labels: pull-request-available (was: ) > Support StreamExecChangelogNormalize and StreamEx

[GitHub] [flink] flinkbot edited a comment on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792438797 ## CI report: * Unknown: [CANCELED](TBD) * bb6396608d6b3b0a2dc30824be5b9b9ef948afbc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-14 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 621d7c223c5e8044ecb7965faf086431500f7d63 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   >