[jira] [Closed] (FLINK-20122) Test Small file compaction

[ https://issues.apache.org/jira/browse/FLINK-20122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-20122. --- > Test Small file compaction > -- > > Key: FLINK-20122 >

[jira] [Resolved] (FLINK-20122) Test Small file compaction

[ https://issues.apache.org/jira/browse/FLINK-20122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao resolved FLINK-20122. - Resolution: Fixed > Test Small file compaction > -- > > Key:

[GitHub] [flink] godfreyhe commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

godfreyhe commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r536535874 ## File path: flink-table/flink-table-planner/src/test/scala/resources/testStatementSetExecutionExplain1.out ## @@ -0,0 +1,121 @@ +== Abstract Syntax

[GitHub] [flink] flinkbot edited a comment on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

flinkbot edited a comment on pull request #14314: URL: https://github.com/apache/flink/pull/14314#issuecomment-739134416 ## CI report: * fcf9dbf8a268276a89f010eb8df6a2ec636d2e36 Azure:

[GitHub] [flink] flinkbot commented on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

flinkbot commented on pull request #14314: URL: https://github.com/apache/flink/pull/14314#issuecomment-739134416 ## CI report: * fcf9dbf8a268276a89f010eb8df6a2ec636d2e36 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

flinkbot commented on pull request #14314: URL: https://github.com/apache/flink/pull/14314#issuecomment-739133725 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20492: --- Labels: pull-request-available (was: ) > The SourceOperatorStreamTask should implement

[GitHub] [flink] becketqin opened a new pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

becketqin opened a new pull request #14314: URL: https://github.com/apache/flink/pull/14314 …Task() to SourceOperatorStreamTask. ## What is the purpose of the change The `SourceOperatorStreamTask` does not implement `cancelTask()` and `finishTask()` at this point. This causes

[GitHub] [flink] flinkbot edited a comment on pull request #14313: [FLINK-20475][doc] Fix the broken links in gettingStarted.zh.md

flinkbot edited a comment on pull request #14313: URL: https://github.com/apache/flink/pull/14313#issuecomment-739118411 ## CI report: * 6cf6eb565ed17de3f2201f9129be67f725cc8704 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * a88c6caabb50541ecdc8fcafa232adf0e799 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14313: [FLINK-20475][doc] Fix the broken links in gettingStarted.zh.md

flinkbot edited a comment on pull request #14313: URL: https://github.com/apache/flink/pull/14313#issuecomment-739118411 ## CI report: * 6cf6eb565ed17de3f2201f9129be67f725cc8704 Azure:

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Description: The {{SourceOperatorStreamTask}} does not implement {{cancelTask}} and

[GitHub] [flink] flinkbot commented on pull request #14313: [FLINK-20475][doc] Fix the broken links in gettingStarted.zh.md

flinkbot commented on pull request #14313: URL: https://github.com/apache/flink/pull/14313#issuecomment-739118411 ## CI report: * 6cf6eb565ed17de3f2201f9129be67f725cc8704 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14313: [FLINK-20475][doc] Fix the broken links in gettingStarted.zh.md

flinkbot commented on pull request #14313: URL: https://github.com/apache/flink/pull/14313#issuecomment-739117347 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] HuangXingBo commented on pull request #14299: [hotfix][hbase] Fix NOTICE file of hbase 2.2

HuangXingBo commented on pull request #14299: URL: https://github.com/apache/flink/pull/14299#issuecomment-739117297 @dianfu Could you help review it? Thanks. This is an automated message from the Apache Git Service. To

[GitHub] [flink] HuangXingBo commented on pull request #14313: [FLINK-20475][doc] Fix the broken links in gettingStarted.zh.md

HuangXingBo commented on pull request #14313: URL: https://github.com/apache/flink/pull/14313#issuecomment-739117148 @dianfu Could you help review it? Thanks. This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-20475) Broken Link in gettingStarted.zh.md

[ https://issues.apache.org/jira/browse/FLINK-20475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20475: --- Labels: pull-request-available (was: ) > Broken Link in gettingStarted.zh.md >

[GitHub] [flink] HuangXingBo opened a new pull request #14313: [FLINK-20475][doc] Fix the broken links in gettingStarted.zh.md

HuangXingBo opened a new pull request #14313: URL: https://github.com/apache/flink/pull/14313 ## What is the purpose of the change *This pull request will fix the broken links in gettingStarted.zh.md* ## Brief change log - *Fix the broken links in

[jira] [Commented] (FLINK-20494) SQLClientHBaseITCase Task Timeout

[ https://issues.apache.org/jira/browse/FLINK-20494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244398#comment-17244398 ] Huang Xingbo commented on FLINK-20494: --

[jira] [Commented] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244397#comment-17244397 ] Brad Davis commented on FLINK-19710: The upstream PR has been merged.  Is this issue just waiting on

[jira] [Closed] (FLINK-17736) Add flink CEP examples

[ https://issues.apache.org/jira/browse/FLINK-17736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming closed FLINK-17736. -- Resolution: Won't Do The examples in the integration test is enough, close it. > Add flink CEP

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244395#comment-17244395 ] Huang Xingbo commented on FLINK-16947: --

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244394#comment-17244394 ] Huang Xingbo commented on FLINK-16947: --

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

Huang Xingbo created FLINK-20495: Summary: Elasticsearch6DynamicSinkITCase Hang Key: FLINK-20495 URL: https://issues.apache.org/jira/browse/FLINK-20495 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20494) SQLClientHBaseITCase Task Timeout

Huang Xingbo created FLINK-20494: Summary: SQLClientHBaseITCase Task Timeout Key: FLINK-20494 URL: https://issues.apache.org/jira/browse/FLINK-20494 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20493) SQLClientSchemaRegistryITCase test failed

[ https://issues.apache.org/jira/browse/FLINK-20493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244389#comment-17244389 ] Huang Xingbo commented on FLINK-20493: -- Now the timeout is set to 1 minute. I'm not sure if

[jira] [Created] (FLINK-20493) SQLClientSchemaRegistryITCase test failed

Huang Xingbo created FLINK-20493: Summary: SQLClientSchemaRegistryITCase test failed Key: FLINK-20493 URL: https://issues.apache.org/jira/browse/FLINK-20493 Project: Flink Issue Type: Bug

[GitHub] [flink] V1ncentzzZ commented on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

V1ncentzzZ commented on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-739109344 Hi @godfreyhe , The code has been updated as you said. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Fix Version/s: 1.12.0 > The SourceOperatorStreamTask should implement cancelTask() and

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Affects Version/s: (was: 1.12.0) > The SourceOperatorStreamTask should implement

[jira] [Created] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

Jiangjie Qin created FLINK-20492: Summary: The SourceOperatorStreamTask should implement cancelTask() and finishTask() Key: FLINK-20492 URL: https://issues.apache.org/jira/browse/FLINK-20492 Project:

[jira] [Assigned] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20492: Assignee: Jiangjie Qin > The SourceOperatorStreamTask should implement cancelTask() and

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 07e1b12f433dec764812f49b9c0348d25498d6f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 07e1b12f433dec764812f49b9c0348d25498d6f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 57afbcf067fb64d6e669a45accbb95aaca082345 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 07e1b12f433dec764812f49b9c0348d25498d6f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * 61cdd876e27d23952da5c66f6d201c7c7102ad3f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14311: [FLINK-20490][table-planner-blink] Don't share inputs between FlinkPhysicalRel and ExecNode

flinkbot edited a comment on pull request #14311: URL: https://github.com/apache/flink/pull/14311#issuecomment-738797093 ## CI report: * 8097824271a1688deaaf384d42b46ff1b16ca52f Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536244626 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 57afbcf067fb64d6e669a45accbb95aaca082345 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

flinkbot edited a comment on pull request #14292: URL: https://github.com/apache/flink/pull/14292#issuecomment-737644985 ## CI report: * 6ca7d5619e4d14b3da3cca362da015785ba199eb Azure:

[GitHub] [flink] flinkbot commented on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

flinkbot commented on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 57afbcf067fb64d6e669a45accbb95aaca082345 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Comment Edited] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244090#comment-17244090 ] Dawid Wysakowicz edited comment on FLINK-19970 at 12/4/20, 4:21 PM:

[GitHub] [flink] zentol commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

zentol commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536217125 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and limitations

[GitHub] [flink] zentol commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

zentol commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536216828 ## File path: docs/deployment/resource-providers/standalone/docker.md ## @@ -352,6 +352,27 @@ as described in [how to run the Flink

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244094#comment-17244094 ] Thomas Wozniakowski commented on FLINK-19970: - Ah sorry, I mixed up the `key` and `id` value

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Attachment: screenshot-3.png > State leak in CEP Operators (expired events/keys

[GitHub] [flink] zentol commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

zentol commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536213406 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitations

[jira] [Comment Edited] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244090#comment-17244090 ] Dawid Wysakowicz edited comment on FLINK-19970 at 12/4/20, 4:13 PM:

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244090#comment-17244090 ] Dawid Wysakowicz commented on FLINK-19970: -- No, my test case matches your scenario #1. In my

[GitHub] [flink] flinkbot edited a comment on pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

flinkbot edited a comment on pull request #14310: URL: https://github.com/apache/flink/pull/14310#issuecomment-738741642 ## CI report: * cded2fcb5f10c8d6bdbfdece1c591fa658377f90 Azure:

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244083#comment-17244083 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] Am I correct in saying

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 4a2942d056be51f8064a94bfb064143decda77db Azure:

[GitHub] [flink] flinkbot commented on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

flinkbot commented on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738864641 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-20491) Support Broadcast State in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20491: --- Labels: pull-request-available (was: ) > Support Broadcast State in BATCH execution mode >

[GitHub] [flink] aljoscha opened a new pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

aljoscha opened a new pull request #14312: URL: https://github.com/apache/flink/pull/14312 Right now, we don't support `DataStream.connect(BroadcastStream)` in `BATCH` execution mode. I believe we can add support for this with not too much work. The key insight is that we can

[jira] [Created] (FLINK-20491) Support Broadcast State in BATCH execution mode

Aljoscha Krettek created FLINK-20491: Summary: Support Broadcast State in BATCH execution mode Key: FLINK-20491 URL: https://issues.apache.org/jira/browse/FLINK-20491 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14309: [FLINK-20485][table] Improve performance of data views

flinkbot edited a comment on pull request #14309: URL: https://github.com/apache/flink/pull/14309#issuecomment-738733577 ## CI report: * 2cc967f7c4d001bcd2c1960018893f49e34f65b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

flinkbot edited a comment on pull request #14305: URL: https://github.com/apache/flink/pull/14305#issuecomment-738174107 ## CI report: * 215d2414fd5ea678eeca7c8b5f5fc3e1ff973600 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

flinkbot edited a comment on pull request #14292: URL: https://github.com/apache/flink/pull/14292#issuecomment-737644985 ## CI report: * 7d1723792f216e5c11cad7cfa8d8f1d58e5c842a Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

leonardBang commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r536190157 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * Unknown: [CANCELED](TBD) * 61cdd876e27d23952da5c66f6d201c7c7102ad3f Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

leonardBang commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r536190157 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 4a2942d056be51f8064a94bfb064143decda77db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

flinkbot edited a comment on pull request #14292: URL: https://github.com/apache/flink/pull/14292#issuecomment-737644985 ## CI report: * 7d1723792f216e5c11cad7cfa8d8f1d58e5c842a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * Unknown: [CANCELED](TBD) * 61cdd876e27d23952da5c66f6d201c7c7102ad3f UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244051#comment-17244051 ] Dawid Wysakowicz commented on FLINK-19970: -- The changes apply only to the flink-cep module yes.

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244047#comment-17244047 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz], Just to confirm, it's

[GitHub] [flink] V1ncentzzZ commented on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

V1ncentzzZ commented on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-738834116 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] sjwiesman commented on pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

sjwiesman commented on pull request #14292: URL: https://github.com/apache/flink/pull/14292#issuecomment-738830651 thank you @alpinegizmo I've applied your suggestions inline. This is an automated message from the Apache

[GitHub] [flink] tillrohrmann commented on pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

tillrohrmann commented on pull request #13879: URL: https://github.com/apache/flink/pull/13879#issuecomment-738825711 Maybe the state check in `SharedSlot.allocateLogicalSlot` is wrong? Maybe we simply need to return a failed logical slot future if the internal state of the shared slot is

[GitHub] [flink] tillrohrmann commented on a change in pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

tillrohrmann commented on a change in pull request #13879: URL: https://github.com/apache/flink/pull/13879#discussion_r536139471 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java ## @@ -160,38 +162,58 @@

[GitHub] [flink] StephanEwen commented on pull request #14303: [FLINK-20379][Connector/Kafka] Improve the KafkaRecordDesrializer interface

StephanEwen commented on pull request #14303: URL: https://github.com/apache/flink/pull/14303#issuecomment-738820798 On the "Move Deserialization From SplitReader to RecordEmitter" discussion: I would be interested in seeing how this impacts performance. The current Kafka connector

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244030#comment-17244030 ] Yun Gao commented on FLINK-20476: - A quick look of the above instances shows that almost all failures

[GitHub] [flink] flinkbot edited a comment on pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

flinkbot edited a comment on pull request #14305: URL: https://github.com/apache/flink/pull/14305#issuecomment-738174107 ## CI report: * 4ee770ed510ddacabe8edb97fc355be1ebaa8ffd Azure:

[jira] [Closed] (FLINK-20469) Enable TaskManager start and terminate in MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-20469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-20469. --- Resolution: Fixed merged into master by 736dc7475144b4217b6e229c34d72dc9e0a1a31a merged

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

rkhachatryan commented on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-738812585 @SteNicholas yes, but I think the PR won't be merged soon. I expect a lot of feedback from @pnowojski The latest AZP failure is caused by FLINK-19863

[GitHub] [flink-web] StephanEwen commented on pull request #397: Add 1.12 Release announcement.

StephanEwen commented on pull request #397: URL: https://github.com/apache/flink-web/pull/397#issuecomment-738812170 Thanks, reads well. +1 from my side This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] azagrebin closed pull request #14300: [FLINK-20469][minicluster] Enable TaskManager start and terminate in MiniCluster

azagrebin closed pull request #14300: URL: https://github.com/apache/flink/pull/14300 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] tillrohrmann commented on a change in pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

tillrohrmann commented on a change in pull request #14301: URL: https://github.com/apache/flink/pull/14301#discussion_r536125712 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PerJobCheckpointRecoveryFactory.java ## @@ -29,13 +30,13 @@ *

[GitHub] [flink] flinkbot edited a comment on pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

flinkbot edited a comment on pull request #14305: URL: https://github.com/apache/flink/pull/14305#issuecomment-738174107 ## CI report: * 4ee770ed510ddacabe8edb97fc355be1ebaa8ffd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14311: [FLINK-20490][table-planner-blink] Don't share inputs between FlinkPhysicalRel and ExecNode

flinkbot edited a comment on pull request #14311: URL: https://github.com/apache/flink/pull/14311#issuecomment-738797093 ## CI report: * 8097824271a1688deaaf384d42b46ff1b16ca52f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * 64f5b48580f748cc15bc7ee65db45dd937b4821a Azure:

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244020#comment-17244020 ] Yun Gao commented on FLINK-20476: - I'll have a look, very sorry for the inconvenient... > New File Sink

[GitHub] [flink] tillrohrmann commented on a change in pull request #14300: [FLINK-20469][minicluster] Enable TaskManager start and terminate in MiniCluster

tillrohrmann commented on a change in pull request #14300: URL: https://github.com/apache/flink/pull/14300#discussion_r536116043 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -551,18 +559,27 @@ protected boolean

[jira] [Commented] (FLINK-19550) StreamingFileSink can't be interrupted when writing to S3

[ https://issues.apache.org/jira/browse/FLINK-19550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244017#comment-17244017 ] Roman Khachatryan commented on FLINK-19550: --- Thanks for sharing this!   Did you update

[GitHub] [flink] flinkbot commented on pull request #14311: [FLINK-20490][table-planner-blink] Don't share inputs between FlinkPhysicalRel and ExecNode

flinkbot commented on pull request #14311: URL: https://github.com/apache/flink/pull/14311#issuecomment-738797093 ## CI report: * 8097824271a1688deaaf384d42b46ff1b16ca52f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

flinkbot edited a comment on pull request #14301: URL: https://github.com/apache/flink/pull/14301#issuecomment-738011652 ## CI report: * 7170ccf1ed3381fd6ffe951fa5de2b16f0032866 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536113556 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and

[GitHub] [flink-web] morsapaes commented on pull request #397: Add 1.12 Release announcement.

morsapaes commented on pull request #397: URL: https://github.com/apache/flink-web/pull/397#issuecomment-738786467 > Generally reads well. Some comments/corrections in line, otherwise +1 from my side. @StephanEwen, ironed the issues out. Please have another look.

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244007#comment-17244007 ] Dawid Wysakowicz commented on FLINK-19970: -- Could you please double check that you've run my

[jira] [Commented] (FLINK-19595) Flink SQL support S3 select

[ https://issues.apache.org/jira/browse/FLINK-19595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244004#comment-17244004 ] Steve Loughran commented on FLINK-19595: s3a connector supports s3 select (HADOOP-15229) :

[GitHub] [flink] flinkbot commented on pull request #14311: [FLINK-20490][table-planner-blink] Don't share inputs between FlinkPhysicalRel and ExecNode

flinkbot commented on pull request #14311: URL: https://github.com/apache/flink/pull/14311#issuecomment-738782403 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-20490) Don't share inputs between FlinkPhysicalRel and ExecNode

[ https://issues.apache.org/jira/browse/FLINK-20490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20490: --- Labels: pull-request-available (was: ) > Don't share inputs between FlinkPhysicalRel and

[GitHub] [flink] godfreyhe opened a new pull request #14311: [FLINK-20490][table-planner-blink] Don't share inputs between FlinkPhysicalRel and ExecNode

godfreyhe opened a new pull request #14311: URL: https://github.com/apache/flink/pull/14311 ## What is the purpose of the change *This pr aim to let ExecNode have its own input instance. It is prepared for the implementation separation between RelNode and ExecNode.*

[jira] [Commented] (FLINK-19550) StreamingFileSink can't be interrupted when writing to S3

[ https://issues.apache.org/jira/browse/FLINK-19550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243998#comment-17243998 ] Steve Loughran commented on FLINK-19550: s3a in 3.2.2 and 3.3.1 will ship with 1.11.901, see

[jira] [Updated] (FLINK-20490) Don't share inputs between FlinkPhysicalRel and ExecNode

[ https://issues.apache.org/jira/browse/FLINK-20490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20490: --- Description: Currently, all execution nodes extend both from {{RelNode}} and {{ExecNode}}, and

[jira] [Closed] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19863. --- Resolution: Fixed Fixed in - master (1.13.0): 6c183175c9bc61625c30e74287c7a10929ce328f - release-1.12:

[GitHub] [flink] wuchong merged pull request #14274: [FLINK-19863][test] Fix SQLClientHBaseITCase.testHBase failed with process timeout

wuchong merged pull request #14274: URL: https://github.com/apache/flink/pull/14274 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-20490) Don't share inputs between FlinkPhysicalRel and ExecNode

[ https://issues.apache.org/jira/browse/FLINK-20490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20490: -- Assignee: godfrey he > Don't share inputs between FlinkPhysicalRel and ExecNode >

  1   2   3   >