[jira] [Updated] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16720: - Issue Type: Technical Debt (was: Bug) > Maven gets stuck downloading artifacts on Azure

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

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

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632 ## CI report: * f1acca0118fbbf4eeba271205a4032691ff813b1 Azure: [SUCCESS](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 #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791590842 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java ## @@ -106,10 +115,12 @@ publ

[jira] [Closed] (FLINK-25620) Upload artifacts to S3 failed on azure pipeline

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25620. Resolution: Cannot Reproduce > Upload artifacts to S3 failed on azure pipeline > -

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791607490 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriver.java ## @@ -0,0 +1,

[jira] [Updated] (FLINK-25278) Azure failed due to unable to transfer jar from confluent maven repo

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25278: - Issue Type: Technical Debt (was: Bug) > Azure failed due to unable to transfer jar from

[jira] [Updated] (FLINK-25278) Azure failed due to unable to transfer jar from confluent maven repo

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25278: - Fix Version/s: 1.13.6 1.14.4 > Azure failed due to unable to transfer

[jira] [Comment Edited] (FLINK-25278) Azure failed due to unable to transfer jar from confluent maven repo

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477093#comment-17477093 ] Chesnay Schepler edited comment on FLINK-25278 at 1/25/22, 11:10 AM: -

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791603751 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@ pub

[jira] [Closed] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6444. --- Resolution: Duplicate > Add a check that '@VisibleForTesting' methods are only used in tests

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791602122 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791601828 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[jira] [Closed] (FLINK-12340) Cache frontend-maven-plugin npm artifacts

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12340. Resolution: Duplicate > Cache frontend-maven-plugin npm artifacts > --

[jira] [Updated] (FLINK-15633) Javadocs cannot be built on Java 11

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15633: - Parent: FLINK-25244 Issue Type: Sub-task (was: Bug) > Javadocs cannot be built

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791599038 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] Airblader commented on a change in pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-25 Thread GitBox
Airblader commented on a change in pull request #18333: URL: https://github.com/apache/flink/pull/18333#discussion_r791583482 ## File path: flink-architecture-tests/README.md ## @@ -1,43 +1,57 @@ # flink-architecture-tests -This module contains architecture tests using [Arc

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791598277 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@ p

[jira] [Closed] (FLINK-22322) Build hang when compiling Web UI

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22322. Resolution: Cannot Reproduce Likely just a slow network or something. The new npm proxies

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791597460 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791597053 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@ p

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791596942 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriver.java ## @@ -0,0 +1,

[jira] [Updated] (FLINK-25702) Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25702: Fix Version/s: 1.15.0 > Use the configure feature provided by the kafka Serializer/Deserializer. > ---

[jira] [Updated] (FLINK-25702) Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25702: Affects Version/s: 1.14.3 > Use the configure feature provided by the kafka Serializer/Deserializer. > ---

[jira] [Closed] (FLINK-25702) Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge closed FLINK-25702. --- Resolution: Fixed > Use the configure feature provided by the kafka Serializer/Deserializer. > -

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791596001 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791595622 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791595267 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[jira] [Commented] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

2022-01-25 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481730#comment-17481730 ] Fabian Paul commented on FLINK-25753: - [~ruanhang1993] can you have a look at this b

[GitHub] [flink] SteNicholas commented on a change in pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

2022-01-25 Thread GitBox
SteNicholas commented on a change in pull request #18502: URL: https://github.com/apache/flink/pull/18502#discussion_r791593327 ## File path: docs/content.zh/docs/connectors/datastream/kafka.md ## @@ -176,6 +176,15 @@ env.fromSource(kafkaSource, new CustomWatermarkStrategy(),

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791593446 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] SteNicholas commented on a change in pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

2022-01-25 Thread GitBox
SteNicholas commented on a change in pull request #18502: URL: https://github.com/apache/flink/pull/18502#discussion_r791593327 ## File path: docs/content.zh/docs/connectors/datastream/kafka.md ## @@ -176,6 +176,15 @@ env.fromSource(kafkaSource, new CustomWatermarkStrategy(),

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791592992 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriverTest.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #18504: [hotfix][azure] fix ArchUnit flag

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791592672 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriver.java ## @@ -0,0 +1,

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791590842 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java ## @@ -106,10 +115,12 @@ publ

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791589339 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScan.java ## @@ -31,6 +32,8 @@ File

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
tsreaper commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791536943 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@ pub

[GitHub] [flink] flinkbot commented on pull request #18504: [hotfix][azure] fix ArchUnit flag

2022-01-25 Thread GitBox
flinkbot commented on pull request #18504: URL: https://github.com/apache/flink/pull/18504#issuecomment-1021053731 ## CI report: * 187e515b3c9d3a773cc3e05cf0b3575f49385f08 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] curcur commented on pull request #18223: [FLINK-25423][state-processor-api] Enable loading state backend via configuration in state processor api

2022-01-25 Thread GitBox
curcur commented on pull request #18223: URL: https://github.com/apache/flink/pull/18223#issuecomment-1021053692 @rkhachatryan would you please help review this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #18503: [FLINK-25331][tests] FlinkImageBuilder checks for Java 17

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

[GitHub] [flink] flinkbot edited a comment on pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1019767867 ## CI report: * 24d79a799e24c30b77ef9e50b9434249c824a82f Azure: [SUCCESS](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-25 Thread GitBox
flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 ## CI report: * 2e2b7be4e3ede352958733f19d58d39636627fa3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18504: [hotfix][azure] fix ArchUnit flag

2022-01-25 Thread GitBox
flinkbot commented on pull request #18504: URL: https://github.com/apache/flink/pull/18504#issuecomment-1021051727 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] [Closed] (FLINK-25759) Upgrade to flink-shaded 15.0

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25759. Fix Version/s: (was: 1.15.0) Resolution: Duplicate > Upgrade to flink-shaded 15

[GitHub] [flink] Airblader opened a new pull request #18504: [hotfix][azure] fix ArchUnit flag

2022-01-25 Thread GitBox
Airblader opened a new pull request #18504: URL: https://github.com/apache/flink/pull/18504 ## What is the purpose of the change This mistake actually prevented the CI from failing when violations have been fixed. (I expect this to fail the CI the first time as there are fixed

[GitHub] [flink] flinkbot commented on pull request #18503: [FLINK-25331][tests] FlinkImageBuilder checks for Java 17

2022-01-25 Thread GitBox
flinkbot commented on pull request #18503: URL: https://github.com/apache/flink/pull/18503#issuecomment-1021048687 ## CI report: * 7097d061789080c31131fd093db5277465028c69 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

2022-01-25 Thread GitBox
flinkbot commented on pull request #18502: URL: https://github.com/apache/flink/pull/18502#issuecomment-1021048562 ## CI report: * 1f83802ae2f9a2dfd9700dfb20e39a7756ee0ff2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25331) Allow testcontainer tests to run on Java 17

2022-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25331: --- Labels: pull-request-available (was: ) > Allow testcontainer tests to run on Java 17 >

[GitHub] [flink] flinkbot commented on pull request #18503: [FLINK-25331][tests] FlinkImageBuilder checks for Java 17

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

[GitHub] [flink] flinkbot edited a comment on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

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

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not be

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not be

[GitHub] [flink] flinkbot commented on pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

2022-01-25 Thread GitBox
flinkbot commented on pull request #18502: URL: https://github.com/apache/flink/pull/18502#issuecomment-102102 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] [Commented] (FLINK-25702) Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-25 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481724#comment-17481724 ] Fabian Paul commented on FLINK-25702: - Merged in master: 8a694ca3a798e0b166624242ed7

[jira] [Updated] (FLINK-25331) Allow testcontainer tests to run on Java 17

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25331: - Summary: Allow testcontainer tests to run on Java 17 (was: Allow testcontainer tests to

[jira] [Closed] (FLINK-25775) Document JavaScript SDK

2022-01-25 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-25775. Resolution: Fixed Added at 895fb0b4485d4ae43f8e1eb132f3f237e210f72b. > Document JavaScript SDK >

[GitHub] [flink] flinkbot edited a comment on pull request #18501: [FLINK-25348][build] Clear japicmp exclusions

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

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

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

[GitHub] [flink-statefun] igalshilman closed pull request #284: [FLINK-25775] Add Javascript SDK documentation

2022-01-25 Thread GitBox
igalshilman closed pull request #284: URL: https://github.com/apache/flink-statefun/pull/284 -- 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: issue

[GitHub] [flink-statefun] igalshilman commented on pull request #284: [FLINK-25775] Add Javascript SDK documentation

2022-01-25 Thread GitBox
igalshilman commented on pull request #284: URL: https://github.com/apache/flink-statefun/pull/284#issuecomment-1021041343 Thanks a lot for the review @tillrohrmann ! Good catch with the missing `context`! I've made another pass and merged after addressing your comments! -- This is

[GitHub] [flink] flinkbot edited a comment on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

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

[GitHub] [flink] MartijnVisser opened a new pull request #18502: [hotfix][docs][kafka] Add explanation how Kafka Source deals with idl…

2022-01-25 Thread GitBox
MartijnVisser opened a new pull request #18502: URL: https://github.com/apache/flink/pull/18502 …eness when parallelism is higher then the number of partitions ## What is the purpose of the change * Clarifying idleness in Kafka Source ## Brief change log * This PR

[jira] [Assigned] (FLINK-25331) Allow testcontainer tests to run on Java 11

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25331: Assignee: Chesnay Schepler > Allow testcontainer tests to run on Java 11 > --

[jira] [Commented] (FLINK-25331) Allow testcontainer tests to run on Java 11

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481722#comment-17481722 ] Chesnay Schepler commented on FLINK-25331: -- hmm, FlinkImageBuilder#getJavaVersi

[jira] [Updated] (FLINK-25331) Allow testcontainer tests to run on Java 11

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25331: - Parent Issue: FLINK-15736 (was: FLINK-25244) > Allow testcontainer tests to run on Java

[jira] [Created] (FLINK-25805) Use compact DataType serialization for default classes instead of internal ones

2022-01-25 Thread Timo Walther (Jira)
Timo Walther created FLINK-25805: Summary: Use compact DataType serialization for default classes instead of internal ones Key: FLINK-25805 URL: https://issues.apache.org/jira/browse/FLINK-25805 Proje

[jira] [Assigned] (FLINK-25805) Use compact DataType serialization for default classes instead of internal ones

2022-01-25 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-25805: --- Assignee: Francesco Guardiani > Use compact DataType serialization for defa

[GitHub] [flink] flinkbot edited a comment on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

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

[GitHub] [flink] flinkbot commented on pull request #18501: [FLINK-25348][build] Clear japicmp exclusions

2022-01-25 Thread GitBox
flinkbot commented on pull request #18501: URL: https://github.com/apache/flink/pull/18501#issuecomment-1021036379 ## CI report: * 1be52f5e32488f5c181eead80cd029dfd9c7875e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zuston commented on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

2022-01-25 Thread GitBox
zuston commented on pull request #18306: URL: https://github.com/apache/flink/pull/18306#issuecomment-1021036013 @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 specific

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

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

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[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-25 Thread GitBox
flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 19e7922b5364c22ed9a4675154778f07fd1ebf34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

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

[GitHub] [flink] flinkbot commented on pull request #18501: [FLINK-25348][build] Clear japicmp exclusions

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

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

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

[GitHub] [flink] flinkbot commented on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

2022-01-25 Thread GitBox
flinkbot commented on pull request #18500: URL: https://github.com/apache/flink/pull/18500#issuecomment-1021030168 ## CI report: * 5c2d53d24569ad6f9c346ad087aa33ed5f76ebb1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25348) Update release guide to reset japicmp exceptions for every release

2022-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25348: --- Labels: pull-request-available (was: ) > Update release guide to reset japicmp exceptions f

[GitHub] [flink] fapaul commented on pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

2022-01-25 Thread GitBox
fapaul commented on pull request #18043: URL: https://github.com/apache/flink/pull/18043#issuecomment-1021029452 @dmvk I have based this feature now on FLINK-25715. Please have another look. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] zentol opened a new pull request #18501: [FLINK-25348][build] Clear japicmp exclusions

2022-01-25 Thread GitBox
zentol opened a new pull request #18501: URL: https://github.com/apache/flink/pull/18501 These exclusions are all no longer relevant, as they only apply to migrations between 2 previous versions. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Commented] (FLINK-25348) Update release guide to reset japicmp exceptions for every release

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481717#comment-17481717 ] Chesnay Schepler commented on FLINK-25348: -- Not cleaning it for patch releases

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[jira] [Commented] (FLINK-25348) Update release guide to reset japicmp exceptions for every release

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481716#comment-17481716 ] Chesnay Schepler commented on FLINK-25348: -- I like the idea of cleaning up the

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791560202 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriver.java ## @@ -0,0 +1,

[GitHub] [flink] flinkbot commented on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

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

[GitHub] [flink] flinkbot edited a comment on pull request #18490: [FLINK-25794][sql-runtime] Clean cache after memory segments in it after they are released to MemoryManager

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

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[jira] [Updated] (FLINK-25312) Hive supports managed table

2022-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25312: --- Labels: pull-request-available (was: ) > Hive supports managed table >

[GitHub] [flink] LadyForest opened a new pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

2022-01-25 Thread GitBox
LadyForest opened a new pull request #18500: URL: https://github.com/apache/flink/pull/18500 ## What is the purpose of the change This PR aims to let `HiveCatalog` support Flink's managed table. More details can be found at [FLIP-188](https://cwiki.apache.org/confluence/display/FLIN

[jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

2022-01-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481712#comment-17481712 ] Dawid Wysakowicz commented on FLINK-13856: -- A POC for bulk deleting files: htt

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791551477 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@ p

[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-25 Thread GitBox
flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce metadataConsumer to InitContext in Sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 96c787f1dd4b373c00d1acb03b918c823a0

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-25 Thread GitBox
JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791549241 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@ p

[GitHub] [flink] tillrohrmann commented on a change in pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #17485: URL: https://github.com/apache/flink/pull/17485#discussion_r791547330 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperMultipleComponentLeaderElectionDriver.java ## @@ -0,0 +1,

[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-25 Thread GitBox
flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

<    3   4   5   6   7   8   9   >