[jira] [Created] (FLINK-25770) Delete file is not correct in MergeTreeWriter

2022-01-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-25770: Summary: Delete file is not correct in MergeTreeWriter Key: FLINK-25770 URL: https://issues.apache.org/jira/browse/FLINK-25770 Project: Flink Issue Type: Bug

[GitHub] [flink-table-store] JingsongLi opened a new pull request #13: [FLINK-25770] Delete file is not correct in MergeTreeWriter

2022-01-24 Thread GitBox
JingsongLi opened a new pull request #13: URL: https://github.com/apache/flink-table-store/pull/13 The deletion in MergeTreeWriter.updateCompactResult dose not consider upgrade case, the upgrade file is required by previous snapshot and following snapshot, we should ensure: 1. This file

[jira] [Updated] (FLINK-25770) Delete file is not correct in MergeTreeWriter

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25770: --- Labels: pull-request-available (was: ) > Delete file is not correct in MergeTreeWriter > --

[GitHub] [flink] LadyForest commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
LadyForest commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r789511549 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala ## @@ -47,21 +53,30 @@ import or

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 68b840fe2df44305be126b638e965bf8b3433b88 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] wanglijie95 commented on a change in pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
wanglijie95 commented on a change in pull request #18130: URL: https://github.com/apache/flink/pull/18130#discussion_r790491207 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java ## @@ -645,13 +616,13 @@ pu

[GitHub] [flink] JingsongLi commented on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

2022-01-24 Thread GitBox
JingsongLi commented on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1019821611 > I think here we have two different thread-safety issues. One is that the consumer is invoked by the KafkaProducer that you probably need to fix and trigger the callback vi

[GitHub] [flink] flinkbot edited a comment on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * 41eeab31ee52a29d71acf018f9d1ef5a7750bb85 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * ad18f7d233edacae59cd55c0d56f09f25f2f1658 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] JingsongLi commented on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

2022-01-24 Thread GitBox
JingsongLi commented on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1019822883 @flinkbot run azure -- 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 speci

[GitHub] [flink] PatrickRen commented on pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

2022-01-24 Thread GitBox
PatrickRen commented on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1019822936 @fapaul @JingGe Sorry for my late response! I made a new push just now. Hope this round is acceptable. Basically I changed the usage of `@Topic` annotation, and adopt

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480896#comment-17480896 ] Till Rohrmann commented on FLINK-21608: --- Another instance: https://dev.azure.com/

[jira] [Updated] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21608: -- Affects Version/s: 1.15.0 > YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "

[jira] [Updated] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21608: -- Labels: test-stability (was: auto-deprioritized-major test-stability) > YARNHighAvailabilityI

[jira] [Updated] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21608: -- Priority: Critical (was: Minor) > YARNHighAvailabilityITCase.testClusterClientRetrieval fails

[GitHub] [flink] flinkbot edited a comment on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * 41eeab31ee52a29d71acf018f9d1ef5a7750bb85 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * ad18f7d233edacae59cd55c0d56f09f25f2f1658 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480899#comment-17480899 ] Till Rohrmann commented on FLINK-18356: --- Another instance https://dev.azure.com/a

[GitHub] [flink] flinkbot edited a comment on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632 ## CI report: * 82871d3416aefbce86d6e32e3e26a51c12841534 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-25762) Native k8s- User defined system properties get overriden when cluster is deployed

2022-01-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-25762: - Assignee: Tamir Sagi > Native k8s- User defined system properties get overriden when cluster is

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-19615) HBaseConnectorITCase.testTableSink is unstable

2022-01-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-19615. -- Resolution: Cannot Reproduce No issues reported since November, therefore closing the ticket

[jira] [Assigned] (FLINK-19615) HBaseConnectorITCase.testTableSink is unstable

2022-01-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-19615: -- Assignee: (was: Marios Trivyzas) > HBaseConnectorITCase.testTableSink is unstable

[jira] [Commented] (FLINK-25200) Implement duplicating for s3 filesystem

2022-01-24 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480904#comment-17480904 ] Yun Tang commented on FLINK-25200: -- [~pnowojski] From my knowledge, S3 will involve cop

[GitHub] [flink] xintongsong commented on a change in pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-24 Thread GitBox
xintongsong commented on a change in pull request #18430: URL: https://github.com/apache/flink/pull/18430#discussion_r790487706 ## File path: docs/content/docs/deployment/filesystems/gcs.md ## @@ -50,57 +48,40 @@ env.getCheckpointConfig().setCheckpointStorage("gs:///"); ```

[GitHub] [flink] beyond1920 commented on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

2022-01-24 Thread GitBox
beyond1920 commented on pull request #18414: URL: https://github.com/apache/flink/pull/18414#issuecomment-1019837686 Merged. Thanks for contribution @simenliuxing -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] flinkbot edited a comment on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632 ## CI report: * 82871d3416aefbce86d6e32e3e26a51c12841534 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] beyond1920 merged pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

2022-01-24 Thread GitBox
beyond1920 merged pull request #18414: URL: https://github.com/apache/flink/pull/18414 -- 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] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18456: [FLINK-21790][network] Shuffle data directories to make directory selection of different TaskManagers fairer

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 ## CI report: * cd74a88227edf6a00098a9d651634e009ac3fe9f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] paul8263 opened a new pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

2022-01-24 Thread GitBox
paul8263 opened a new pull request #18460: URL: https://github.com/apache/flink/pull/18460 ## What is the purpose of the change Totally translated state.md into Chinese ## Brief change log - docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## Verifying

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25767) Translation of page 'Working with State' is incomplete

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25767: --- Labels: pull-request-available (was: ) > Translation of page 'Working with State' is incomp

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480906#comment-17480906 ] Till Rohrmann commented on FLINK-25771: --- cc [~echauchot]. > CassandraConnectorITC

[jira] [Created] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

2022-01-24 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-25771: - Summary: CassandraConnectorITCase.testRetrialAndDropTables fails on AZP Key: FLINK-25771 URL: https://issues.apache.org/jira/browse/FLINK-25771 Project: Flink

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480909#comment-17480909 ] Yun Gao commented on FLINK-23047: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

2022-01-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480910#comment-17480910 ] Dawid Wysakowicz commented on FLINK-25683: -- Fixed in: * master ** 9aa879f50c32d

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

2022-01-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25683: - Fix Version/s: 1.15.0 1.14.4 > wrong result if table transfrom to Dat

[GitHub] [flink] flinkbot commented on pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

2022-01-24 Thread GitBox
flinkbot commented on pull request #18460: URL: https://github.com/apache/flink/pull/18460#issuecomment-1019842362 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 pr

[jira] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047 ] Yun Gao deleted comment on FLINK-23047: - was (Author: gaoyunhaii): [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=29945&view=logs&j=c91190b6-40ae-57b2-5999-31b869b0a7c1&t

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25771: Affects Version/s: 1.13.5 (was: 1.15.0) > CassandraConnectorITCase.testRetrialA

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

2022-01-24 Thread GitBox
flinkbot commented on pull request #18460: URL: https://github.com/apache/flink/pull/18460#issuecomment-1019844798 ## CI report: * 6385885a06a970cc31f450251e9f6b0d4150a0dd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480912#comment-17480912 ] Till Rohrmann commented on FLINK-25673: --- Another instance: https://dev.azure.com/

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

2022-01-24 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480913#comment-17480913 ] Yangze Guo commented on FLINK-18356: Another instance from my Azure: https://dev.azu

[jira] [Closed] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

2022-01-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25683. Resolution: Fixed > wrong result if table transfrom to DataStream then window process in b

[jira] [Comment Edited] (FLINK-18356) Exit code 137 returned from process

2022-01-24 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480913#comment-17480913 ] Yangze Guo edited comment on FLINK-18356 at 1/24/22, 8:38 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

2022-01-24 Thread GitBox
fapaul commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r790515844 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/DataStreamCsvITCase.java ## @@ -0,0 +1,390 @@ +/* + * Licensed to the Apa

[GitHub] [flink] flinkbot edited a comment on pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18460: URL: https://github.com/apache/flink/pull/18460#issuecomment-1019844798 ## CI report: * 6385885a06a970cc31f450251e9f6b0d4150a0dd Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-25772) GCS filessystem fails license checker

2022-01-24 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-25772: - Summary: GCS filessystem fails license checker Key: FLINK-25772 URL: https://issues.apache.org/jira/browse/FLINK-25772 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-25772) GCS filessystem fails license checker

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25772: -- Labels: test-stability (was: ) > GCS filessystem fails license checker >

[jira] [Commented] (FLINK-25772) GCS filessystem fails license checker

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480918#comment-17480918 ] Till Rohrmann commented on FLINK-25772: --- cc [~xtsong], [~galenwarren] could you ta

[jira] [Updated] (FLINK-25772) GCS filesystem fails license checker

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25772: -- Summary: GCS filesystem fails license checker (was: GCS filessystem fails license checker) >

[jira] [Updated] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25758: -- Issue Type: Bug (was: Improvement) > GCS Filesystem implementation fails on Java 11 tests due

[jira] [Closed] (FLINK-25772) GCS filesystem fails license checker

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25772. - Fix Version/s: (was: 1.15.0) Resolution: Duplicate > GCS filesystem fails license che

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #13: [FLINK-25770] Delete file is not correct in MergeTreeWriter

2022-01-24 Thread GitBox
tsreaper commented on a change in pull request #13: URL: https://github.com/apache/flink-table-store/pull/13#discussion_r790492629 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeWriter.java ## @@ -134,26 +139,36 @@ publi

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #13: [FLINK-25770] Delete file is not correct in MergeTreeWriter

2022-01-24 Thread GitBox
tsreaper commented on a change in pull request #13: URL: https://github.com/apache/flink-table-store/pull/13#discussion_r790514373 ## File path: flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/TestCommitThread.java ## @@ -173,7 +173,11 @@ publi

[GitHub] [flink] tillrohrmann commented on a change in pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-24 Thread GitBox
tillrohrmann commented on a change in pull request #18452: URL: https://github.com/apache/flink/pull/18452#discussion_r790521866 ## File path: flink-filesystems/flink-gs-fs-hadoop/pom.xml ## @@ -214,6 +214,8 @@ under the License.

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480923#comment-17480923 ] Till Rohrmann commented on FLINK-25307: --- Any progress on this issue [~gaoyunhaii]?

[jira] [Updated] (FLINK-25764) Docker sets JobManager's rpc address to same host by default

2022-01-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25764: - Priority: Minor (was: Major) > Docker sets JobManager's rpc address to same host by def

[jira] [Closed] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25749. - Resolution: Fixed > YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25764) Docker sets JobManager's rpc address to same host by default

2022-01-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480927#comment-17480927 ] Chesnay Schepler commented on FLINK-25764: -- The docker image having a default f

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync

2022-01-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480929#comment-17480929 ] Chesnay Schepler commented on FLINK-25765: -- ??manage user's expectations regard

[GitHub] [flink] Myasuka commented on a change in pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

2022-01-24 Thread GitBox
Myasuka commented on a change in pull request #18460: URL: https://github.com/apache/flink/pull/18460#discussion_r790516189 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -25,32 +25,23 @@ specific language governing permissions and limitations

[GitHub] [flink] dannycranmer merged pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-24 Thread GitBox
dannycranmer merged pull request #18348: URL: https://github.com/apache/flink/pull/18348 -- 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-un

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 237027aabd1c103dbdd722e67f1f2a8475149c48 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * a44383b3a2c7a6dc5a9c96ad225ad8baaf03fee4 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] alpreu commented on a change in pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

2022-01-24 Thread GitBox
alpreu commented on a change in pull request #18145: URL: https://github.com/apache/flink/pull/18145#discussion_r790522381 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java ## @@ -281,27 +283,

[GitHub] [flink] wsry commented on a change in pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
wsry commented on a change in pull request #18130: URL: https://github.com/apache/flink/pull/18130#discussion_r790532234 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannel.java ## @@ -94,6 +97,7 @@ protected InputChann

[jira] [Updated] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

2022-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-25486: -- Priority: Blocker (was: Critical) > Perjob can not recover from checkpoint when zookeeper lea

[GitHub] [flink] zhuzhurk closed pull request #18126: [FLINK-25036][runtime] Introduce vertex wise scheduling strategy

2022-01-24 Thread GitBox
zhuzhurk closed pull request #18126: URL: https://github.com/apache/flink/pull/18126 -- 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-unsubs

  1   2   3   4   5   6   7   8   9   10   >