[jira] [Created] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

Dawid Wysakowicz created FLINK-24206: Summary: PulsarSourceITCase fails with "Consumer not found" Key: FLINK-24206 URL: https://issues.apache.org/jira/browse/FLINK-24206 Project: Flink Is

[jira] [Issue Comment Deleted] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23971: - Comment: was deleted (was: https://dev.azure.com/apache-flink/apache-flink/_build/resul

[jira] [Commented] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411727#comment-17411727 ] Dawid Wysakowicz commented on FLINK-23971: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] Airblader commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704106009 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java ## @@ -46

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * 0a44a1d73f9dec54cf272e7c0355654a3c0012fb Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #17194: [FLINK-24034] Upgrade commons-compress to 1.21 and other apache.commons updates

flinkbot commented on pull request #17194: URL: https://github.com/apache/flink/pull/17194#issuecomment-914969570 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 #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * 3125a2df1fde0b2fbd8aa27b71786d2b089a04c3 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] amazingJing commented on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

amazingJing commented on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-914968797 > @amazingJing I think the failure might be something already fixed in master branch. You can try to rebase the https://github.com/zoltar9264/flink/tree/FLINK-23949 branch w

[GitHub] [flink] Airblader commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704103712 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java ## @@ -46

[jira] [Updated] (FLINK-24034) Upgrade commons-compress to 1.21

[ https://issues.apache.org/jira/browse/FLINK-24034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24034: --- Labels: pull-request-available (was: ) > Upgrade commons-compress to 1.21 > ---

[GitHub] [flink] flinkbot commented on pull request #17193: [FLINK-24203][runtime][tests] Resolve AbstractServerTest fails due to port conflict

flinkbot commented on pull request #17193: URL: https://github.com/apache/flink/pull/17193#issuecomment-914968375 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] MartijnVisser opened a new pull request #17194: [FLINK-24034] Upgrade commons-compress to 1.21 and other apache.commons updates

MartijnVisser opened a new pull request #17194: URL: https://github.com/apache/flink/pull/17194 ## What is the purpose of the change * Update commons-compress to 1.21 due to CVE-2021-35517 * Updated other apache.commons dependencies to latest version ## Brief change log

[GitHub] [flink] pnowojski commented on a change in pull request #17135: [FLINK-24098] Document FLIP-147 capabiliites and limitations

pnowojski commented on a change in pull request #17135: URL: https://github.com/apache/flink/pull/17135#discussion_r704100504 ## File path: docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md ## @@ -239,8 +239,9 @@ important observation that puts certain requireme

[GitHub] [flink] Airblader commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704102162 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java ## @@ -562,6 +563,43 @@ public static ApiExpre

[jira] [Updated] (FLINK-24204) Failed to insert nested types using value construction functions

[ https://issues.apache.org/jira/browse/FLINK-24204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24204: - Parent: FLINK-12251 Issue Type: Sub-task (was: Bug) > Failed to insert nested types usi

[jira] [Assigned] (FLINK-24034) Upgrade commons-compress to 1.21

[ https://issues.apache.org/jira/browse/FLINK-24034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24034: Assignee: Martijn Visser (was: Chesnay Schepler) > Upgrade commons-compress to 1

[jira] [Commented] (FLINK-24204) Failed to insert nested types using value construction functions

[ https://issues.apache.org/jira/browse/FLINK-24204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411722#comment-17411722 ] Timo Walther commented on FLINK-24204: -- This is kind of a duplicate of FLINK-17321.

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

ruanhang1993 commented on a change in pull request #17184: URL: https://github.com/apache/flink/pull/17184#discussion_r704099530 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/extensions/ClassLoaderExtension.java ##

[jira] [Updated] (FLINK-24203) AbstractServerTest fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-24203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24203: --- Labels: pull-request-available test-stability (was: test-stability) > AbstractServerTest fa

[jira] [Updated] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed f

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24168: - Priority: Critical (was: Blocker) > Rowtime type is not correct for windowTableFunction or Over

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411719#comment-17411719 ] Timo Walther commented on FLINK-24168: -- We don't need to block 1.14. This issue was

[GitHub] [flink] xmarker opened a new pull request #17193: [FLINK-24203][runtime][tests] Resolve AbstractServerTest fails due to port conflict

xmarker opened a new pull request #17193: URL: https://github.com/apache/flink/pull/17193 ## What is the purpose of the change *This pull request for fix AbstractServerTest.testServerInitializationFailure falls due to port conflict* ## Brief change log * Cat

[GitHub] [flink] flinkbot commented on pull request #17192: [FLINK-24195][doc]Translate "DESCRIBE Statements" page of "SQL" into …

flinkbot commented on pull request #17192: URL: https://github.com/apache/flink/pull/17192#issuecomment-914959905 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-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24195: --- Labels: pull-request-available (was: ) > Translate "DESCRIBE Statements" page of "SQL" into

[GitHub] [flink] hapihu opened a new pull request #17192: [FLINK-24195][doc]Translate "DESCRIBE Statements" page of "SQL" into …

hapihu opened a new pull request #17192: URL: https://github.com/apache/flink/pull/17192 Translate "DESCRIBE Statements" page of "SQL" into Chinese https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/describe/ docs/content.zh/docs/dev/table/sql/describe.m

[GitHub] [flink] pnowojski commented on a change in pull request #17135: [FLINK-24098] Document FLIP-147 capabiliites and limitations

pnowojski commented on a change in pull request #17135: URL: https://github.com/apache/flink/pull/17135#discussion_r704089770 ## File path: docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md ## @@ -147,6 +154,11 @@ env.getCheckpointConfig.enableUnalignedCheckpoin

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

slinkydeveloper commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704089572 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java ##

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

slinkydeveloper commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704088995 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java ##

[jira] [Commented] (FLINK-24182) Tasks canceler should not immediately interrupt

[ https://issues.apache.org/jira/browse/FLINK-24182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411718#comment-17411718 ] Piotr Nowojski commented on FLINK-24182: Yes. We would have to allow {{TaskInter

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

slinkydeveloper commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704083943 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java ## @@ -562,6 +563,43 @@ public static Ap

[GitHub] [flink] PatrickRen commented on pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

PatrickRen commented on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-914952450 Thanks @AHeise for the review! I made some refactor since your last review so you may want to review the PR again. I split changes into 4 commits: - 47e181c changes the ret

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * 0a44a1d73f9dec54cf272e7c0355654a3c0012fb Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] Myasuka commented on pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

Myasuka commented on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-914950626 @Jiayi-Liao , I think you still need add a test, and you can debug the `SavepointITCase#testTriggerSavepointWithCheckpointingDisabled()` to see whether your changes have been co

[GitHub] [flink] flinkbot edited a comment on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

flinkbot edited a comment on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-913385726 ## CI report: * 001d8c3dbc6d3344aa26baff0deebe3343c87318 UNKNOWN * 34424f3a53dcfd09dfaa0b0ecb30b86d3f3b75d3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24182) Tasks canceler should not immediately interrupt

[ https://issues.apache.org/jira/browse/FLINK-24182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411711#comment-17411711 ] Arvid Heise commented on FLINK-24182: - I also saw another source of interrupts. Not

[jira] [Assigned] (FLINK-24199) Expose StreamExecutionEnvironment#configure in Python API

[ https://issues.apache.org/jira/browse/FLINK-24199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-24199: --- Assignee: Nicholas Jiang > Expose StreamExecutionEnvironment#configure in Python API >

[GitHub] [flink] PatrickRen closed pull request #16488: [FLINK-21117][connector/kafka] Set checkpoint timeout to Long.MAX to reveal thread dump on CI if test get stuck

PatrickRen closed pull request #16488: URL: https://github.com/apache/flink/pull/16488 -- 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 specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] PatrickRen closed pull request #15943: [FLINK-20655][e2e] Add E2E test for new KafkaSource based on FLIP-27

PatrickRen closed pull request #15943: URL: https://github.com/apache/flink/pull/15943 -- 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 specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] SteNicholas removed a comment on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

SteNicholas removed a comment on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-914920602 @Airblader , I have addressed the minor comments above and left a reply for the `CatalogTable` holding. Please take a look. @wuchong , do you have any comments?

[GitHub] [flink] Airblader commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704069593 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java ## @@ -46

[jira] [Commented] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411704#comment-17411704 ] Yun Gao commented on FLINK-20443: - Hi [~liliwei], very thanks for opening the PR!  Ther

[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * 60714061929e12788a2b7aee4bb30125651b3f5a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

flinkbot edited a comment on pull request #17184: URL: https://github.com/apache/flink/pull/17184#issuecomment-914328876 ## CI report: * 39e7b6d0a0eb8f68fa58b66856694470919491d0 UNKNOWN * c652a8a01a0ad750621845d63b91cadd5ba36807 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

flinkbot edited a comment on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-913385726 ## CI report: * 001d8c3dbc6d3344aa26baff0deebe3343c87318 UNKNOWN * 34424f3a53dcfd09dfaa0b0ecb30b86d3f3b75d3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411701#comment-17411701 ] Xintong Song commented on FLINK-24137: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-24205) AggregateReduceGroupingITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24205: - Labels: test-stability (was: ) > AggregateReduceGroupingITCase hangs on azure > ---

[jira] [Created] (FLINK-24205) AggregateReduceGroupingITCase hangs on azure

Xintong Song created FLINK-24205: Summary: AggregateReduceGroupingITCase hangs on azure Key: FLINK-24205 URL: https://issues.apache.org/jira/browse/FLINK-24205 Project: Flink Issue Type: Bug

[GitHub] [flink] Airblader commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r704064726 ## File path: docs/data/sql_functions.yml ## @@ -708,6 +708,41 @@ json: -- '[]' JSON_QUERY('{}', 'strict $.invalid' EMPTY ARRAY ON ERROR)

[GitHub] [flink] SteNicholas commented on a change in pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

SteNicholas commented on a change in pull request #17155: URL: https://github.com/apache/flink/pull/17155#discussion_r704062837 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTableOptionsOperation.java ## @@ -22,15 +22,3

[GitHub] [flink] Airblader commented on a change in pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on a change in pull request #17133: URL: https://github.com/apache/flink/pull/17133#discussion_r704061117 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/architecture/ApiRules.java ## @@ -0,0 +1,93 @@ +/

[GitHub] [flink] curcur commented on pull request #17120: [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished

curcur commented on pull request #17120: URL: https://github.com/apache/flink/pull/17120#issuecomment-914931221 Hey @dawidwys and @gaoyunhaii, does TransactionHolder#empty increases complexity for serialization/deserialization? The reason to introduce an empty state is to reduce comp

[GitHub] [flink] Airblader commented on a change in pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

Airblader commented on a change in pull request #17155: URL: https://github.com/apache/flink/pull/17155#discussion_r704055469 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTableOptionsOperation.java ## @@ -22,15 +22,32

[GitHub] [flink] Airblader commented on a change in pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

Airblader commented on a change in pull request #17155: URL: https://github.com/apache/flink/pull/17155#discussion_r704055469 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTableOptionsOperation.java ## @@ -22,15 +22,32

[GitHub] [flink] Jiayi-Liao commented on pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

Jiayi-Liao commented on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-914924350 > I think current changes look good. However, I think we should still better add a test to verify whether job could still trigger and complete a savepoint if checkpoint folde

[GitHub] [flink] SteNicholas commented on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

SteNicholas commented on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-914920602 @Airblader , I have addressed the minor comments above and left a reply for the `CatalogTable` holding. Please take a look. @wuchong , do you have any comments? -- This

[GitHub] [flink] SteNicholas commented on a change in pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

SteNicholas commented on a change in pull request #17155: URL: https://github.com/apache/flink/pull/17155#discussion_r704049843 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTableOptionsOperation.java ## @@ -22,15 +22,3

[GitHub] [flink] SteNicholas commented on a change in pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

SteNicholas commented on a change in pull request #17155: URL: https://github.com/apache/flink/pull/17155#discussion_r704049843 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTableOptionsOperation.java ## @@ -22,15 +22,3

[GitHub] [flink] flinkbot edited a comment on pull request #17191: [BP-1.14][FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector

flinkbot edited a comment on pull request #17191: URL: https://github.com/apache/flink/pull/17191#issuecomment-914902776 ## CI report: * cb88a954e079d39b24eef3d646212a5b84a47b48 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

flinkbot edited a comment on pull request #17189: URL: https://github.com/apache/flink/pull/17189#issuecomment-914637509 ## CI report: * 43ca8a7a85dbaa613fc1921e6358b2986cb3f3c2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-24204) Failed to insert nested types using value constructed functions

Jark Wu created FLINK-24204: --- Summary: Failed to insert nested types using value constructed functions Key: FLINK-24204 URL: https://issues.apache.org/jira/browse/FLINK-24204 Project: Flink Issue

[jira] [Updated] (FLINK-24204) Failed to insert nested types using value construction functions

[ https://issues.apache.org/jira/browse/FLINK-24204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24204: Summary: Failed to insert nested types using value construction functions (was: Failed to insert nested

[GitHub] [flink] flinkbot commented on pull request #17191: [BP-1.14][FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17190: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

flinkbot edited a comment on pull request #17190: URL: https://github.com/apache/flink/pull/17190#issuecomment-914893423 ## CI report: * 312d3fdff5268054063007839731ff74f8ed7d71 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * df32ec43e5a4bec2d9f78f173fe9ff45cc454eb3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #17191: [BP-1.14][FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector

flinkbot commented on pull request #17191: URL: https://github.com/apache/flink/pull/17191#issuecomment-914897953 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-24203) AbstractServerTest fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-24203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411677#comment-17411677 ] xmarker commented on FLINK-24203: - [~xtsong] I can help resolve the issue > AbstractSer

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411676#comment-17411676 ] Jark Wu commented on FLINK-24168: - I also vote for {{MATCH_ROWTIME(rowtime)}} and deprec

[GitHub] [flink] PatrickRen opened a new pull request #17191: [BP-1.14][FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector

PatrickRen opened a new pull request #17191: URL: https://github.com/apache/flink/pull/17191 ## What is the purpose of the change This pull request changes the implementation of updating numBytesIn/Out metric in Kafka connector to handle the counter correctly in chained operator sce

[jira] [Created] (FLINK-24203) AbstractServerTest fails due to port conflict

Xintong Song created FLINK-24203: Summary: AbstractServerTest fails due to port conflict Key: FLINK-24203 URL: https://issues.apache.org/jira/browse/FLINK-24203 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #17190: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

flinkbot commented on pull request #17190: URL: https://github.com/apache/flink/pull/17190#issuecomment-914893423 ## CI report: * 312d3fdff5268054063007839731ff74f8ed7d71 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411673#comment-17411673 ] Xintong Song commented on FLINK-23848: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * df32ec43e5a4bec2d9f78f173fe9ff45cc454eb3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411672#comment-17411672 ] Xintong Song commented on FLINK-24163: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411671#comment-17411671 ] Xintong Song commented on FLINK-15493: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24202) BoundedSourceITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411670#comment-17411670 ] Xintong Song commented on FLINK-24202: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24202) BoundedSourceITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411668#comment-17411668 ] Xintong Song commented on FLINK-24202: -- cc [~roman] > BoundedSourceITCase hangs on

[jira] [Created] (FLINK-24202) BoundedSourceITCase hangs on azure

Xintong Song created FLINK-24202: Summary: BoundedSourceITCase hangs on azure Key: FLINK-24202 URL: https://issues.apache.org/jira/browse/FLINK-24202 Project: Flink Issue Type: Bug

[GitHub] [flink] sonaa55 commented on pull request #15518: [hotfix][tests] Update ci/log4j.properties to use rootLogger for streaming.connectors.kafka

sonaa55 commented on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-914889166 $ ./bin/xinfra-monitor-start.sh config/xinfra-monitor.properties -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Commented] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411661#comment-17411661 ] Yun Tang commented on FLINK-24148: -- merged in master: 371f247a45adac24f7fbd4e92782cc4dc

[jira] [Updated] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24148: - Fix Version/s: 1.14.1 1.15.0 > Add bloom filter policy option in RocksDBConfiguredOpt

[GitHub] [flink] Myasuka closed pull request #17142: [FLINK-24148] Add bloom filter option in RocksDBConfiguredOptions

Myasuka closed pull request #17142: URL: https://github.com/apache/flink/pull/17142 -- 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 specific comment. To unsubscribe, e-mail: issues-unsubsc

[GitHub] [flink] flinkbot commented on pull request #17190: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

flinkbot commented on pull request #17190: URL: https://github.com/apache/flink/pull/17190#issuecomment-914881462 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-24201) HistoryServer didn't contain TaskManager Logs

zlzhang0122 created FLINK-24201: --- Summary: HistoryServer didn't contain TaskManager Logs Key: FLINK-24201 URL: https://issues.apache.org/jira/browse/FLINK-24201 Project: Flink Issue Type: Bug

[GitHub] [flink] gaoyunhaii opened a new pull request #17190: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

gaoyunhaii opened a new pull request #17190: URL: https://github.com/apache/flink/pull/17190 This picks https://github.com/apache/flink/pull/17131 to release-1.14 -- 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 edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * df32ec43e5a4bec2d9f78f173fe9ff45cc454eb3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] dianfu commented on a change in pull request #17180: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same

dianfu commented on a change in pull request #17180: URL: https://github.com/apache/flink/pull/17180#discussion_r703992024 ## File path: flink-python/pyflink/fn_execution/beam/beam_worker_pool_service.py ## @@ -155,7 +159,12 @@ def _start_sdk_worker_main(self, start_worker_requ

[GitHub] [flink] dianfu commented on a change in pull request #17180: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same

dianfu commented on a change in pull request #17180: URL: https://github.com/apache/flink/pull/17180#discussion_r703969699 ## File path: flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java ## @@ -98,29 +104,48 @@ private tran

[GitHub] [flink] gaoyunhaii closed pull request #17170: [FLINK-24163][test] Increase the checkpoint timeout for PartiallyFinishedSourcesITCase

gaoyunhaii closed pull request #17170: URL: https://github.com/apache/flink/pull/17170 -- 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 specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] gaoyunhaii commented on pull request #17170: [FLINK-24163][test] Increase the checkpoint timeout for PartiallyFinishedSourcesITCase

gaoyunhaii commented on pull request #17170: URL: https://github.com/apache/flink/pull/17170#issuecomment-914871020 Very thanks @dawidwys for the review! I'll change the comment and merge~ -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * 60714061929e12788a2b7aee4bb30125651b3f5a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24195: --- Assignee: wuguihu > Translate "DESCRIBE Statements" page of "SQL" into Chinese > --

[jira] [Assigned] (FLINK-24196) Translate "EXPLAIN Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24196: --- Assignee: wuguihu > Translate "EXPLAIN Statements" page of "SQL" into Chinese > ---

[GitHub] [flink] curcur commented on a change in pull request #16978: [FLINK-23607][state/changelog] Cleanup dependencies

curcur commented on a change in pull request #16978: URL: https://github.com/apache/flink/pull/16978#discussion_r703984449 ## File path: flink-test-utils-parent/flink-test-utils/pom.xml ## @@ -115,6 +115,14 @@ under the License. +

[GitHub] [flink] curcur commented on a change in pull request #16978: [FLINK-23607][state/changelog] Cleanup dependencies

curcur commented on a change in pull request #16978: URL: https://github.com/apache/flink/pull/16978#discussion_r703984449 ## File path: flink-test-utils-parent/flink-test-utils/pom.xml ## @@ -115,6 +115,14 @@ under the License. +

[jira] [Created] (FLINK-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure

Xintong Song created FLINK-24200: Summary: CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure Key: FLINK-24200 URL: https://issues.apache.org/jira/browse/FLINK-24200 Project: Flin

[jira] [Commented] (FLINK-16346) BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-16346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411642#comment-17411642 ] Xintong Song commented on FLINK-16346: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] Myasuka commented on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

Myasuka commented on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-914859317 @amazingJing I think the failure might be something already fixed in master branch. You can try to rebase the https://github.com/zoltar9264/flink/tree/FLINK-23949 branch with la

[jira] [Closed] (FLINK-24115) Outdated SQL Temporal Join Example

[ https://issues.apache.org/jira/browse/FLINK-24115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24115. --- Fix Version/s: 1.15.0 1.13.3 1.14.0 Resolution: Fixed Fixed in

[GitHub] [flink] wuchong merged pull request #17122: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

wuchong merged pull request #17122: URL: https://github.com/apache/flink/pull/17122 -- 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 specific comment. To unsubscribe, e-mail: issues-unsubsc

[GitHub] [flink] wuchong merged pull request #17124: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

wuchong merged pull request #17124: URL: https://github.com/apache/flink/pull/17124 -- 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 specific comment. To unsubscribe, e-mail: issues-unsubsc

  1   2   3   4   5   6   >