[GitHub] [flink] AHeise commented on a change in pull request #14348: [FLINK-20433][tests] Stabilizing UnalignedCheckpointITCase.

2020-12-15 Thread GitBox
AHeise commented on a change in pull request #14348: URL: https://github.com/apache/flink/pull/14348#discussion_r543124238 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java ## @@ -321,7 +321,7 @@ public void invoke(Long

[GitHub] [flink] flinkbot edited a comment on pull request #14367: [FLINK-20601][docs] Rework PyFlink CLI documentation.

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14367: URL: https://github.com/apache/flink/pull/14367#issuecomment-743040989 ## CI report: * 8825b36cf590e53bf15837534ad4797594031ed5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249549#comment-17249549 ] jiawen xiao commented on FLINK-19691: - is a good idea,i will try it > Expose `CONNE

[jira] [Commented] (FLINK-20416) Need a cached catalog for batch SQL job

2020-12-15 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249552#comment-17249552 ] Sebastian Liu commented on FLINK-20416: --- Hi [~jark], [~lirui], Thanks for your su

[jira] [Reopened] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-12-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-20422: -- It does appear on buildbot as well: https://ci.apache.org/builders/flink-docs-release-1.1

[GitHub] [flink] godfreyhe closed pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-15 Thread GitBox
godfreyhe closed pull request #14380: URL: https://github.com/apache/flink/pull/14380 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

[jira] [Closed] (FLINK-20515) Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-15 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20515. -- Resolution: Done master: d472159a..5088b8ac > Separate the implementation of BatchExecMultipleInput a

[GitHub] [flink] godfreyhe opened a new pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
godfreyhe opened a new pull request #14384: URL: https://github.com/apache/flink/pull/14384 ## What is the purpose of the change *Separate the implementation of BatchExecExchange and StreamExecExchange* ## Brief change log - *Introduce BatchPhysicalExchange, an

[jira] [Updated] (FLINK-20513) Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20513: --- Labels: pull-request-available (was: ) > Separate the implementation of BatchExecExchange a

[GitHub] [flink] dawidwys opened a new pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
dawidwys opened a new pull request #14385: URL: https://github.com/apache/flink/pull/14385 ## What is the purpose of the change Fix links in documentation across languages ## Verifying this change Build the documentation. **IMPORTANT** Do not use the `-p` or `-i`

[GitHub] [flink] flinkbot commented on pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
flinkbot commented on pull request #14384: URL: https://github.com/apache/flink/pull/14384#issuecomment-745145100 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] dawidwys opened a new pull request #14386: [FLINK-20422][bp-1.12] Fix invalid links across languages

2020-12-15 Thread GitBox
dawidwys opened a new pull request #14386: URL: https://github.com/apache/flink/pull/14386 See #14385 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [flink] flinkbot commented on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
flinkbot commented on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745146042 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 commented on pull request #14386: [FLINK-20422][bp-1.12] Fix invalid links across languages

2020-12-15 Thread GitBox
flinkbot commented on pull request #14386: URL: https://github.com/apache/flink/pull/14386#issuecomment-745147030 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] [Commented] (FLINK-18578) Add rejecting checkpoint logic in source

2020-12-15 Thread mengxiaopeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249563#comment-17249563 ] mengxiaopeng commented on FLINK-18578: -- hi [~jark]  Is this question released in th

[GitHub] [flink] xiaoHoly opened a new pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
xiaoHoly opened a new pull request #14387: URL: https://github.com/apache/flink/pull/14387 …DS` as a configurable option in Jdbc connector ## What is the purpose of the change Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

[jira] [Assigned] (FLINK-20513) Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20513: -- Assignee: godfrey he > Separate the implementation of BatchExecExchange and StreamExecExchang

[jira] [Updated] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19691: --- Labels: pull-request-available (was: ) > Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a con

[jira] [Created] (FLINK-20608) Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan

2020-12-15 Thread godfrey he (Jira)
godfrey he created FLINK-20608: -- Summary: Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan Key: FLINK-20608 URL: https://issues.apache.org/jira/browse/FLINK-20608

[jira] [Assigned] (FLINK-20516) Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan

2020-12-15 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20516: -- Assignee: godfrey he > Separate the implementation of BatchExecTableSourceScan and > StreamE

[GitHub] [flink] flinkbot commented on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
flinkbot commented on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745152698 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 #14367: [FLINK-20601][docs] Rework PyFlink CLI documentation.

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14367: URL: https://github.com/apache/flink/pull/14367#issuecomment-743040989 ## CI report: * d1f984ee907996303c30a9fba85ee177cc688855 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20608) Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan

2020-12-15 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20608: --- Component/s: Table SQL / Planner > Separate the implementation of BatchExecLegacyTableSourceScan and

[GitHub] [flink] flinkbot commented on pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
flinkbot commented on pull request #14384: URL: https://github.com/apache/flink/pull/14384#issuecomment-745153275 ## CI report: * efaec8f1fc7041bb9e35b108ad9443f5b5dab077 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Created] (FLINK-20610) Separate the implementation of BatchExecCalc and StreamExecCalc

2020-12-15 Thread godfrey he (Jira)
godfrey he created FLINK-20610: -- Summary: Separate the implementation of BatchExecCalc and StreamExecCalc Key: FLINK-20610 URL: https://issues.apache.org/jira/browse/FLINK-20610 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
flinkbot commented on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745153533 ## CI report: * 16b22c5b5c6406be31101006225aae40c63a6795 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Created] (FLINK-20609) Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan

2020-12-15 Thread godfrey he (Jira)
godfrey he created FLINK-20609: -- Summary: Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan Key: FLINK-20609 URL: https://issues.apache.org/jira/browse/FLINK-20609 Proje

[GitHub] [flink] flinkbot commented on pull request #14386: [FLINK-20422][bp-1.12] Fix invalid links across languages

2020-12-15 Thread GitBox
flinkbot commented on pull request #14386: URL: https://github.com/apache/flink/pull/14386#issuecomment-745153828 ## CI report: * 54a8fd2db3f78c73b098f56bbed34929db33e35e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249569#comment-17249569 ] jiawen xiao commented on FLINK-19691: - [~hailong wang],plea take a look my code ,tha

[GitHub] [flink] xiaoHoly commented on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
xiaoHoly commented on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745154153 @wuchong ,cc This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Created] (FLINK-20611) Support mini batch for window aggregate operation

2020-12-15 Thread Suhan Mao (Jira)
Suhan Mao created FLINK-20611: - Summary: Support mini batch for window aggregate operation Key: FLINK-20611 URL: https://issues.apache.org/jira/browse/FLINK-20611 Project: Flink Issue Type: New F

[jira] [Updated] (FLINK-20611) Support mini batch for window aggregate operation

2020-12-15 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Component/s: Table SQL / Planner > Support mini batch for window aggregate operation > ---

[jira] [Updated] (FLINK-20611) Support mini batch for window aggregate operation

2020-12-15 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Description: Currently, mini batch does not support window aggregate. In our company, many jobs run w

[jira] [Updated] (FLINK-20611) Support mini batch for window aggregate operation

2020-12-15 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Description: Currently, mini batch does not support window aggregate. In our company, many jobs run w

[GitHub] [flink] flinkbot edited a comment on pull request #14386: [FLINK-20422][bp-1.12] Fix invalid links across languages

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14386: URL: https://github.com/apache/flink/pull/14386#issuecomment-745153828 ## CI report: * 54a8fd2db3f78c73b098f56bbed34929db33e35e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14384: URL: https://github.com/apache/flink/pull/14384#issuecomment-745153275 ## CI report: * efaec8f1fc7041bb9e35b108ad9443f5b5dab077 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745153533 ## CI report: * 16b22c5b5c6406be31101006225aae40c63a6795 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
flinkbot commented on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * a2874690cecf694f38ccf0649a5a872e739a4fe7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] kougazhang commented on pull request #14362: [FLINK-20540][jdbc] Fix the defaultUrl for AbstractJdbcCatalog in JDBC connector

2020-12-15 Thread GitBox
kougazhang commented on pull request #14362: URL: https://github.com/apache/flink/pull/14362#issuecomment-745165736 @zentol , hello, I have updated the PR, please code review. This is an automated message from the Apache Git

[GitHub] [flink] HuangXingBo closed pull request #14266: [FLINK-20430][doc] Fix broken links in some Chinese md files

2020-12-15 Thread GitBox
HuangXingBo closed pull request #14266: URL: https://github.com/apache/flink/pull/14266 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] [Closed] (FLINK-20430) Broken links in deployment/index.zh.md

2020-12-15 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-20430. Resolution: Won't Fix > Broken links in deployment/index.zh.md > -

[GitHub] [flink] AHeise commented on a change in pull request #14348: [FLINK-20433][tests] Stabilizing UnalignedCheckpointITCase.

2020-12-15 Thread GitBox
AHeise commented on a change in pull request #14348: URL: https://github.com/apache/flink/pull/14348#discussion_r543196339 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java ## @@ -321,7 +321,7 @@ public void invoke(Long

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
V1ncentzzZ commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r543196684 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcOptions.java ## @@ -100,14 +100

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * a2874690cecf694f38ccf0649a5a872e739a4fe7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] shizhengchao opened a new pull request #14388: [FLINK-20607][docs] Fix an error of multiple input types in udfs page

2020-12-15 Thread GitBox
shizhengchao opened a new pull request #14388: URL: https://github.com/apache/flink/pull/14388 ## What is the purpose of the change This pull request fixes an error of multiple input types in udfs page. Demonstration error of multiple input types in FunctionHint: ```

[GitHub] [flink] HuangXingBo opened a new pull request #14389: [FLINK-20528][python] Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work

2020-12-15 Thread GitBox
HuangXingBo opened a new pull request #14389: URL: https://github.com/apache/flink/pull/14389 ## What is the purpose of the change *This pull request will Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work* ## Verifying

[jira] [Commented] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249598#comment-17249598 ] Till Rohrmann commented on FLINK-20605: --- Thanks for reporting this issue [~chesnay

[jira] [Updated] (FLINK-20528) Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work

2020-12-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20528: --- Labels: pull-request-available (was: ) > Add Python building blocks to make sure the basic

[jira] [Updated] (FLINK-20607) a wrong example in udfs page.

2020-12-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20607: --- Labels: pull-request-available (was: ) > a wrong example in udfs page. > --

[GitHub] [flink] zentol commented on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
zentol commented on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745183234 FYI, this still fails locally for me if I'm not using the -p flags. With the -p flag it succeeds. This is an au

[GitHub] [flink] flinkbot commented on pull request #14388: [FLINK-20607][docs] Fix an error of multiple input types in udfs page

2020-12-15 Thread GitBox
flinkbot commented on pull request #14388: URL: https://github.com/apache/flink/pull/14388#issuecomment-745183388 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 commented on pull request #14389: [FLINK-20528][python] Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work

2020-12-15 Thread GitBox
flinkbot commented on pull request #14389: URL: https://github.com/apache/flink/pull/14389#issuecomment-745183368 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] tillrohrmann closed pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

2020-12-15 Thread GitBox
tillrohrmann closed pull request #13879: URL: https://github.com/apache/flink/pull/13879 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 g

[jira] [Commented] (FLINK-16764) Allow custom Kafka topic discovery logic

2020-12-15 Thread pine zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249602#comment-17249602 ] pine zhao commented on FLINK-16764: --- hi,how's the issue going on  > Allow custom Kafk

[GitHub] [flink] rmetzger commented on pull request #14383: [FLINK-20589] Remove old scheduling strategies

2020-12-15 Thread GitBox
rmetzger commented on pull request #14383: URL: https://github.com/apache/flink/pull/14383#issuecomment-745186042 Thanks a lot for the review! I'll merge this PR now! This is an automated message from the Apache Git Service.

[GitHub] [flink] rmetzger merged pull request #14383: [FLINK-20589] Remove old scheduling strategies

2020-12-15 Thread GitBox
rmetzger merged pull request #14383: URL: https://github.com/apache/flink/pull/14383 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] [Comment Edited] (FLINK-16764) Allow custom Kafka topic discovery logic

2020-12-15 Thread pine zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249602#comment-17249602 ] pine zhao edited comment on FLINK-16764 at 12/15/20, 10:06 AM: ---

[jira] [Commented] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249605#comment-17249605 ] Chesnay Schepler commented on FLINK-20605: -- I think what happens is that when t

[jira] [Closed] (FLINK-20592) Remove LazyFromSourcesSchedulingStrategy

2020-12-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20592. -- Resolution: Fixed Resolved in https://github.com/apache/flink/commit/9ba5ab4f4dcbc8f1e8dcf799

[jira] [Closed] (FLINK-20591) Remove JobManagerOptions.SCHEDULING_STRATEGY

2020-12-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20591. -- Release Note: The configuration parameter `jobmanager.scheduler.scheduling-strategy` has been

[jira] [Closed] (FLINK-20593) Remove EagerSchedulingStrategy

2020-12-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20593. -- Resolution: Fixed Resolved in https://github.com/apache/flink/commit/774e6a334b05daa72570513a

[jira] [Comment Edited] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249605#comment-17249605 ] Chesnay Schepler edited comment on FLINK-20605 at 12/15/20, 10:06 AM:

[GitHub] [flink] zentol commented on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
zentol commented on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745187765 There may be similar problems in the sidenav.html; it appears to always refer to search-results.md. This is an

[jira] [Closed] (FLINK-19832) Improve handling of immediately failed physical slot in SlotSharingExecutionSlotAllocator

2020-12-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-19832. - Resolution: Fixed Fixed via 1.13.0: 58ed205390078929c0691196cf692029c837ea9c f097b9387e99876f7b

[jira] [Commented] (FLINK-20547) Batch job fails due to the exception in network stack

2020-12-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249610#comment-17249610 ] Roman Khachatryan commented on FLINK-20547: --- [~kevin.cyj], [~Thesharing] did y

[GitHub] [flink] flinkbot edited a comment on pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14384: URL: https://github.com/apache/flink/pull/14384#issuecomment-745153275 ## CI report: * efaec8f1fc7041bb9e35b108ad9443f5b5dab077 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14388: [FLINK-20607][docs] Fix an error of multiple input types in udfs page

2020-12-15 Thread GitBox
flinkbot commented on pull request #14388: URL: https://github.com/apache/flink/pull/14388#issuecomment-745191567 ## CI report: * e88b034759b082dbd67aeb98da0a2685e057902d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #14389: [FLINK-20528][python] Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work

2020-12-15 Thread GitBox
flinkbot commented on pull request #14389: URL: https://github.com/apache/flink/pull/14389#issuecomment-745192120 ## CI report: * 3385ab7b31e3d312cc4f98ab9b619c15ad400215 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] dawidwys commented on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
dawidwys commented on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745193078 Weren't the changes in `sidenav.html` reverted in: * 50a1c8d853ba0e4363e753077caa86891b632dd5 for 1.12 * 06c81645f917981d7bd5cbe13a445becbe35c033 ? ---

[GitHub] [flink] dawidwys edited a comment on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
dawidwys edited a comment on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745193078 Weren't the changes in `sidenav.html` reverted in: * 50a1c8d853ba0e4363e753077caa86891b632dd5 for 1.12 * 06c81645f917981d7bd5cbe13a445becbe35c033 for master ? -

[GitHub] [flink] zentol commented on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
zentol commented on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745195380 With https://github.com/apache/flink/commit/06c81645f917981d7bd5cbe13a445becbe35c033 things are working. This i

[jira] [Created] (FLINK-20612) Add benchmarks for scheduler

2020-12-15 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-20612: Summary: Add benchmarks for scheduler Key: FLINK-20612 URL: https://issues.apache.org/jira/browse/FLINK-20612 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-20612) Add benchmarks for scheduler

2020-12-15 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20612: - Description: With Flink 1.12, we failed to run large-scale jobs on our cluster. When we were tr

[jira] [Updated] (FLINK-20611) Support 2 phase local aggregate for window aggregate operation

2020-12-15 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Summary: Support 2 phase local aggregate for window aggregate operation (was: Support mini batch for

[jira] [Updated] (FLINK-20611) Support 2 phase local aggregate for window aggregate operation

2020-12-15 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Description: In our company, many jobs run with window aggregate and suffer from large amounts of int

[jira] [Updated] (FLINK-20612) Add benchmarks for scheduler

2020-12-15 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20612: - Description: With Flink 1.12, we failed to run large-scale jobs on our cluster. When we were tr

[GitHub] [flink] dawidwys commented on pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
dawidwys commented on pull request #14385: URL: https://github.com/apache/flink/pull/14385#issuecomment-745201464 Thx for checking it! Merging. This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] dawidwys merged pull request #14385: [FLINK-20422] Fix invalid links across languages

2020-12-15 Thread GitBox
dawidwys merged pull request #14385: URL: https://github.com/apache/flink/pull/14385 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-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-12-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249619#comment-17249619 ] Dawid Wysakowicz commented on FLINK-20422: -- Fixed outstanding issues in: * mast

[jira] [Closed] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-12-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-20422. Resolution: Fixed > Remove {{ site.baseurl }} from .html files in flink documentation > --

[GitHub] [flink] flinkbot edited a comment on pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14384: URL: https://github.com/apache/flink/pull/14384#issuecomment-745153275 ## CI report: * efaec8f1fc7041bb9e35b108ad9443f5b5dab077 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14389: [FLINK-20528][python] Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14389: URL: https://github.com/apache/flink/pull/14389#issuecomment-745192120 ## CI report: * 3385ab7b31e3d312cc4f98ab9b619c15ad400215 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14388: [FLINK-20607][docs] Fix an error of multiple input types in udfs page

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14388: URL: https://github.com/apache/flink/pull/14388#issuecomment-745191567 ## CI report: * e88b034759b082dbd67aeb98da0a2685e057902d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dawidwys merged pull request #14386: [FLINK-20422][bp-1.12] Fix invalid links across languages

2020-12-15 Thread GitBox
dawidwys merged pull request #14386: URL: https://github.com/apache/flink/pull/14386 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] [Assigned] (FLINK-14712) Improve back-pressure reporting mechanism

2020-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14712: -- Assignee: Piotr Nowojski (was: lining) > Improve back-pressure reporting mechanism >

[jira] [Assigned] (FLINK-14814) Show the vertex that produces the backpressure source in the job

2020-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14814: -- Assignee: (was: lining) > Show the vertex that produces the backpressure source i

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

2020-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14815: -- Assignee: (was: lining) > Expose network metric for sub task in rest api > --

[jira] [Commented] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249624#comment-17249624 ] Till Rohrmann commented on FLINK-20605: --- I guess for the first problem we need to

[jira] [Assigned] (FLINK-14127) Better BackPressure Detection in WebUI

2020-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14127: -- Assignee: (was: Yadong Xie) > Better BackPressure Detection in WebUI > --

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

2020-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17328: -- Assignee: (was: lining) > Expose network metric for job vertex in rest api >

[jira] [Commented] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249630#comment-17249630 ] Chesnay Schepler commented on FLINK-20605: -- Yes, for 1 and 2 that was my plan a

[jira] [Assigned] (FLINK-19013) Log start/end of state restoration

2020-12-15 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-19013: Assignee: Yun Tang > Log start/end of state restoration > -- > >

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r543264307 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcOptions.java ## @@ -100,14 +100,2

[GitHub] [flink] flinkbot edited a comment on pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14384: URL: https://github.com/apache/flink/pull/14384#issuecomment-745153275 ## CI report: * efaec8f1fc7041bb9e35b108ad9443f5b5dab077 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * a2874690cecf694f38ccf0649a5a872e739a4fe7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rkhachatryan commented on a change in pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-15 Thread GitBox
rkhachatryan commented on a change in pull request #14057: URL: https://github.com/apache/flink/pull/14057#discussion_r543278831 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AlternatingController.java ## @@ -193,6 +202,11 @@ private Ch

[GitHub] [flink] rkhachatryan commented on a change in pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-15 Thread GitBox
rkhachatryan commented on a change in pull request #14057: URL: https://github.com/apache/flink/pull/14057#discussion_r543280004 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AlternatingController.java ## @@ -114,6 +114,7 @@ public void

[GitHub] [flink] rkhachatryan commented on a change in pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-15 Thread GitBox
rkhachatryan commented on a change in pull request #14057: URL: https://github.com/apache/flink/pull/14057#discussion_r543283061 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AlternatingController.java ## @@ -146,28 +146,7 @@ private vo

[GitHub] [flink] klion26 commented on pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

2020-12-15 Thread GitBox
klion26 commented on pull request #13488: URL: https://github.com/apache/flink/pull/13488#issuecomment-745246841 kindly ping @NicoK @carp84 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #14384: [FLINK-20513][table-planner-blink] Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-15 Thread GitBox
flinkbot edited a comment on pull request #14384: URL: https://github.com/apache/flink/pull/14384#issuecomment-745153275 ## CI report: * efaec8f1fc7041bb9e35b108ad9443f5b5dab077 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   >