[GitHub] [flink] matriv commented on a change in pull request #17888: [Flink-24077] fix sporadic ut failing

matriv commented on a change in pull request #17888: URL: https://github.com/apache/flink/pull/17888#discussion_r755214396 ## File path: flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java ## @@ -250,13 +252,25

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * 7f5fbf7c933209fd8cb7f8681499ddadaaa4eeef Azure:

[GitHub] [flink] nicoweidner commented on pull request #17855: [FLINK-24983][build] Upgrade surefire to 3.0.5-M5

nicoweidner commented on pull request #17855: URL: https://github.com/apache/flink/pull/17855#issuecomment-976675499 > Oh it's definitely related. I'm wondering why I never saw that on CI with Java 17... > > but more to the point, it's because the `integration-tests` surefire

[GitHub] [flink] flinkbot edited a comment on pull request #17857: [FLINK-24985][tests] Relax assumptions of stacktrace layout

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

[GitHub] [flink] JingGe commented on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

JingGe commented on pull request #17851: URL: https://github.com/apache/flink/pull/17851#issuecomment-976672019 @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

[jira] [Updated] (FLINK-24978) Upgrade ASM to 9.2

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * 7f5fbf7c933209fd8cb7f8681499ddadaaa4eeef Azure:

[GitHub] [flink-shaded] XComp commented on a change in pull request #103: [FLINK-24978] Upgrade ASM to 9.2

XComp commented on a change in pull request #103: URL: https://github.com/apache/flink-shaded/pull/103#discussion_r755208406 ## File path: flink-shaded-asm-9/src/main/resources/META-INF/NOTICE ## @@ -7,7 +7,7 @@ The Apache Software Foundation (http://www.apache.org/). This

[GitHub] [flink] zentol commented on pull request #17855: [FLINK-24983][build] Upgrade surefire to 3.0.5-M5

zentol commented on pull request #17855: URL: https://github.com/apache/flink/pull/17855#issuecomment-976668983 Oh it's definitely related. I'm wondering why I never saw that on CI with Java 17... but more to the point, it's because the `integration-tests` surefire execution is

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [Flink-24077] fix sporadic ut failing

flinkbot edited a comment on pull request #17888: URL: https://github.com/apache/flink/pull/17888#issuecomment-976661814 ## CI report: * b6a5b1890492cd51454d4ab44a3bba2db0fe8444 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * 7f5fbf7c933209fd8cb7f8681499ddadaaa4eeef Azure:

[GitHub] [flink] zentol edited a comment on pull request #17852: [FLINK-24979][build][hbase] Remove MaxPermSize setting

zentol edited a comment on pull request #17852: URL: https://github.com/apache/flink/pull/17852#issuecomment-976661587 > Can we run into situations now where the fork number is not set when generating the logs? No, because mvn.forkNumber is still set in the root pom surefire

[GitHub] [flink] flinkbot commented on pull request #17888: [Flink-24077] fix sporadic ut failing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17882: [FLINK-24971][BP-1.12] Adding retry mechanism in case git clone fails

flinkbot edited a comment on pull request #17882: URL: https://github.com/apache/flink/pull/17882#issuecomment-976334078 ## CI report: * a72b0de8df9c3eca5580d18034b754288ff92658 Azure:

[GitHub] [flink] zentol commented on pull request #17852: [FLINK-24979][build][hbase] Remove MaxPermSize setting

zentol commented on pull request #17852: URL: https://github.com/apache/flink/pull/17852#issuecomment-976661587 > Can we run into situations now where the fork number is not set when generating the logs? No, because mvn.forkNumber is still set in the root pom surefire

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

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

[jira] [Closed] (FLINK-24981) Fix JDK12+ profile activations

[ https://issues.apache.org/jira/browse/FLINK-24981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24981. Resolution: Fixed master: b5ce1a1ac25fc375f0623d9c63124fef38578dc0 > Fix JDK12+ profile

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * 7f5fbf7c933209fd8cb7f8681499ddadaaa4eeef Azure:

[GitHub] [flink] zentol merged pull request #17853: [FLINK-24981][build] Fix profile activations for JDK 12+

zentol merged pull request #17853: URL: https://github.com/apache/flink/pull/17853 -- 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:

[GitHub] [flink] flinkbot commented on pull request #17888: [Flink-24077] fix sporadic ut failing

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

[GitHub] [flink] zentol commented on a change in pull request #17133: [FLINK-24138] Architectural tests

zentol commented on a change in pull request #17133: URL: https://github.com/apache/flink/pull/17133#discussion_r755189758 ## File path: flink-architecture-tests/src/test/java/org/apache/flink/architecture/rules/ApiAnnotationRules.java ## @@ -0,0 +1,168 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * a2e241da13d788d165fe7f106b38f707a1cbf79f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * 7f5fbf7c933209fd8cb7f8681499ddadaaa4eeef Azure:

[GitHub] [flink] JingGe opened a new pull request #17888: [Flink-24077] fix sporadic ut failing

JingGe opened a new pull request #17888: URL: https://github.com/apache/flink/pull/17888 ## What is the purpose of the change try to fix some unstable failing tests. ## Brief change log - add check of row count after insert - explicitly call await() for batch

[GitHub] [flink] MartijnVisser commented on pull request #17463: [Hotfix] Fix typos.

MartijnVisser commented on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-976644996 Please also make sure that the PR template is properly filled in. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] MartijnVisser commented on a change in pull request #17463: [Hotfix] Fix typos.

MartijnVisser commented on a change in pull request #17463: URL: https://github.com/apache/flink/pull/17463#discussion_r755184904 ## File path:

[GitHub] [flink-benchmarks] Aitozi commented on a change in pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

Aitozi commented on a change in pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41#discussion_r755188360 ## File path: src/main/java/org/apache/flink/state/benchmark/StateBenchmarkBase.java ## @@ -52,10 +54,25 @@ final ThreadLocalRandom random =

[GitHub] [flink] flinkbot edited a comment on pull request #17887: [FLINK-25020] Properly forward exception

flinkbot edited a comment on pull request #17887: URL: https://github.com/apache/flink/pull/17887#issuecomment-976615140 ## CI report: * 15a77538ee4fdbc85ca6c875ae3797b0a9b2d9e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

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

[jira] [Updated] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16931: --- Priority: Not a Priority (was: Minor) > Large _metadata file lead to JobManager not

[GitHub] [flink-benchmarks] pnowojski commented on a change in pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

pnowojski commented on a change in pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41#discussion_r755179227 ## File path: src/main/java/org/apache/flink/state/benchmark/StateBenchmarkBase.java ## @@ -52,10 +54,25 @@ final ThreadLocalRandom random =

[GitHub] [flink] flinkbot edited a comment on pull request #17839: [FLINK-24859] document new connectors formats

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

[GitHub] [flink] flinkbot commented on pull request #17887: [FLINK-25020] Properly forward exception

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

[GitHub] [flink] flinkbot edited a comment on pull request #17885: [FLINK-24772][docs] Update documentation for individual window table-value function

flinkbot edited a comment on pull request #17885: URL: https://github.com/apache/flink/pull/17885#issuecomment-976414441 ## CI report: * 9e922727fac6574c00a3b9120128a798f61147f3 Azure:

[jira] [Updated] (FLINK-25020) FlinkSecurityManager can swallow exception

[ https://issues.apache.org/jira/browse/FLINK-25020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25020: --- Labels: pull-request-available (was: ) > FlinkSecurityManager can swallow exception >

[GitHub] [flink] flinkbot commented on pull request #17887: [FLINK-25020] Properly forward exception

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

[GitHub] [flink] akalash commented on pull request #17796: [FLINK-24846][streaming] Closing the mailbox only after it drains all mails including recursive ones

akalash commented on pull request #17796: URL: https://github.com/apache/flink/pull/17796#issuecomment-976609683 @pnowojski, I understand the problem something like this: 1. AsyncWaitOperator#processElement registers the timeout for the entry 2. endInput happens which waits for

[GitHub] [flink] flinkbot edited a comment on pull request #17839: [FLINK-24859] document new connectors formats

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

[jira] [Created] (FLINK-25020) FlinkSecurityManager can swallow exception

Chesnay Schepler created FLINK-25020: Summary: FlinkSecurityManager can swallow exception Key: FLINK-25020 URL: https://issues.apache.org/jira/browse/FLINK-25020 Project: Flink Issue

[GitHub] [flink] echauchot commented on pull request #17839: [FLINK-24859] document new connectors formats

echauchot commented on pull request #17839: URL: https://github.com/apache/flink/pull/17839#issuecomment-976603434 @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

[GitHub] [flink] XComp commented on a change in pull request #17857: [FLINK-24985][tests] Relax assumptions of stacktrace layout

XComp commented on a change in pull request #17857: URL: https://github.com/apache/flink/pull/17857#discussion_r755157198 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolDestroyTest.java ## @@ -119,8 +119,15 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17789: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17789: URL: https://github.com/apache/flink/pull/17789#issuecomment-968290372 ## CI report: * 3db6df5e2bfaf867f718ed0fb8d2929511a1e85c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17865: [FLINK-24993][core] Harden ExceptionUtils against changes to exceptions

flinkbot edited a comment on pull request #17865: URL: https://github.com/apache/flink/pull/17865#issuecomment-975516895 ## CI report: * 707f22044b3dc3ef8c61a49b892f3515df6a8644 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

flinkbot edited a comment on pull request #17851: URL: https://github.com/apache/flink/pull/17851#issuecomment-975348551 ## CI report: * d345c99d5d16c997c423941618e5441d17ba3f9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17848: [FLINK-24583] [connectors/elasticsearch] Improve test stability by blocking until ES has acknowledged all records

flinkbot edited a comment on pull request #17848: URL: https://github.com/apache/flink/pull/17848#issuecomment-975246406 ## CI report: * ab1fe6e89640d5ebc7c2f8329fdfb1ff22694b49 Azure:

[jira] [Commented] (FLINK-24978) Upgrade ASM to 9.2

[ https://issues.apache.org/jira/browse/FLINK-24978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448021#comment-17448021 ] Chesnay Schepler commented on FLINK-24978: -- PRs should be detected automatically. > Upgrade

[GitHub] [flink] flinkbot edited a comment on pull request #17865: [FLINK-24993][core] Harden ExceptionUtils against changes to exceptions

flinkbot edited a comment on pull request #17865: URL: https://github.com/apache/flink/pull/17865#issuecomment-975516895 ## CI report: * 707f22044b3dc3ef8c61a49b892f3515df6a8644 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17848: [FLINK-24583] [connectors/elasticsearch] Improve test stability by blocking until ES has acknowledged all records

flinkbot edited a comment on pull request #17848: URL: https://github.com/apache/flink/pull/17848#issuecomment-975246406 ## CI report: * ab1fe6e89640d5ebc7c2f8329fdfb1ff22694b49 Azure:

[GitHub] [flink] zentol commented on pull request #17865: [FLINK-24993][core] Harden ExceptionUtils against changes to exceptions

zentol commented on pull request #17865: URL: https://github.com/apache/flink/pull/17865#issuecomment-976576232 @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 #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 8364104af21c6c012779149008980072b18cb87c Azure:

[jira] [Updated] (FLINK-25019) Remove misleading comment regarding flink-shaded-netty re-use

[ https://issues.apache.org/jira/browse/FLINK-25019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25019: - Priority: Minor (was: Major) > Remove misleading comment regarding flink-shaded-netty

[jira] [Updated] (FLINK-25019) Remove misleading comment regarding flink-shaded-netty re-use

[ https://issues.apache.org/jira/browse/FLINK-25019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25019: - Description: In FLINK-24447 we modified Zookeeper to bundle Netty, but added a comment

[jira] [Updated] (FLINK-25019) Remove misleading comment regarding flink-shaded-netty re-use

[ https://issues.apache.org/jira/browse/FLINK-25019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25019: - Summary: Remove misleading comment regarding flink-shaded-netty re-use (was: Incorrect

[jira] [Created] (FLINK-25019) Incorrect netty shading prefix

Chesnay Schepler created FLINK-25019: Summary: Incorrect netty shading prefix Key: FLINK-25019 URL: https://issues.apache.org/jira/browse/FLINK-25019 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-24978) Upgrade ASM to 9.2

[ https://issues.apache.org/jira/browse/FLINK-24978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448018#comment-17448018 ] Matthias edited comment on FLINK-24978 at 11/23/21, 1:49 PM: - Doesn't the PR

[jira] [Commented] (FLINK-24978) Upgrade ASM to 9.2

[ https://issues.apache.org/jira/browse/FLINK-24978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448018#comment-17448018 ] Matthias commented on FLINK-24978: -- Doesn't the PR detection work on the {{apache/flink-shaded}}

[jira] [Commented] (FLINK-24920) Update README examples

[ https://issues.apache.org/jira/browse/FLINK-24920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448016#comment-17448016 ] Martijn Visser commented on FLINK-24920: [~Sergey Nuyanzin] I think there's indeed some more

[jira] [Updated] (FLINK-24920) Update README examples

[ https://issues.apache.org/jira/browse/FLINK-24920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24920: --- Summary: Update README examples (was: Update README) > Update README examples >

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 51b6f01db6e073d4f943fca2d0aba057bbabac72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

flinkbot edited a comment on pull request #17554: URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174 ## CI report: * cf579eec3aa9afc68f2cf9f5b77d5805ec4496b4 Azure:

[GitHub] [flink] MartijnVisser commented on a change in pull request #17839: [FLINK-24859] document new connectors formats

MartijnVisser commented on a change in pull request #17839: URL: https://github.com/apache/flink/pull/17839#discussion_r755110746 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -0,0 +1,99 @@ +--- +title: "Parquet files" +weight: 4 +type: docs

[jira] [Created] (FLINK-25018) Upgrade Curator to 5.2.0

Chesnay Schepler created FLINK-25018: Summary: Upgrade Curator to 5.2.0 Key: FLINK-25018 URL: https://issues.apache.org/jira/browse/FLINK-25018 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-25017) Drop Zookeeper 3.4

[ https://issues.apache.org/jira/browse/FLINK-25017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25017: --- Labels: pull-request-available (was: ) > Drop Zookeeper 3.4 > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink-shaded] zentol opened a new pull request #104: [FLINK-25017] Drop Zookeeper 3.4

zentol opened a new pull request #104: URL: https://github.com/apache/flink-shaded/pull/104 We no longer need to publish a 3.4 artifact, because there will be no future patches to ZK 3.4. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-24905) KDS implementation of Async Sink Table API

[ https://issues.apache.org/jira/browse/FLINK-24905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448010#comment-17448010 ] Arvid Heise commented on FLINK-24905: - Table API is not giving a strong guarantee for state upgrades

[jira] [Commented] (FLINK-25017) Drop Zookeeper 3.4

[ https://issues.apache.org/jira/browse/FLINK-25017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448011#comment-17448011 ] Chesnay Schepler commented on FLINK-25017: -- ZK 3.4 is no longer being maintained, and we

[jira] [Created] (FLINK-25017) Drop Zookeeper 3.4

Chesnay Schepler created FLINK-25017: Summary: Drop Zookeeper 3.4 Key: FLINK-25017 URL: https://issues.apache.org/jira/browse/FLINK-25017 Project: Flink Issue Type: Improvement

[GitHub] [flink-benchmarks] Aitozi commented on a change in pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

Aitozi commented on a change in pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41#discussion_r755120413 ## File path: src/main/java/org/apache/flink/state/benchmark/StateBenchmarkBase.java ## @@ -52,10 +54,25 @@ final ThreadLocalRandom random =

[GitHub] [flink] dmvk commented on a change in pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

dmvk commented on a change in pull request #17607: URL: https://github.com/apache/flink/pull/17607#discussion_r755120267 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java ## @@ -87,18 +88,19 @@ private static

[GitHub] [flink] dmvk commented on a change in pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

dmvk commented on a change in pull request #17607: URL: https://github.com/apache/flink/pull/17607#discussion_r755118309 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java ## @@ -87,18 +88,19 @@ private static

[jira] [Closed] (FLINK-24990) LookupJoinITCase fails on Java 17

[ https://issues.apache.org/jira/browse/FLINK-24990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24990. Resolution: Fixed master: f4b2153b82b3b0dc1c65fa33550a23380e4185b6 > LookupJoinITCase

[jira] [Closed] (FLINK-25005) Add java17-target profile

[ https://issues.apache.org/jira/browse/FLINK-25005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25005. Resolution: Fixed master: 63707c862b33e4da5c7e5b600361c5bb30078738 > Add java17-target

[GitHub] [flink] zentol merged pull request #17869: [FLINK-25005][build] Add java17-target profile

zentol merged pull request #17869: URL: https://github.com/apache/flink/pull/17869 -- 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:

[GitHub] [flink] zentol merged pull request #17862: [FLINK-24990][tests] Make InMemory[Async]LookupFunction public

zentol merged pull request #17862: URL: https://github.com/apache/flink/pull/17862 -- 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:

[GitHub] [flink-benchmarks] Aitozi commented on a change in pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

Aitozi commented on a change in pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41#discussion_r755114500 ## File path: src/main/java/org/apache/flink/state/benchmark/StateBenchmarkBase.java ## @@ -20,15 +20,17 @@ import

[GitHub] [flink-benchmarks] Aitozi commented on a change in pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

Aitozi commented on a change in pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41#discussion_r755114314 ## File path: src/main/java/org/apache/flink/state/benchmark/ListStateBenchmark.java ## @@ -26,6 +26,7 @@ import org.openjdk.jmh.annotations.Level;

[GitHub] [flink] nicoweidner commented on pull request #17862: [FLINK-24990][tests] Make InMemory[Async]LookupFunction public

nicoweidner commented on pull request #17862: URL: https://github.com/apache/flink/pull/17862#issuecomment-976519118 > I can give you a branch though where this is setup if you want. It's fine, I just looked up the mentioned code (UserDefinedFunctionHelper). I just thought at first

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 29429eaf63b982ce386614cb90caeb70697cefb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e0d7451523be3976f3c8695a0f3c9c782a76fddf Azure:

[GitHub] [flink] dmvk commented on a change in pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

dmvk commented on a change in pull request #17607: URL: https://github.com/apache/flink/pull/17607#discussion_r755105408 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java ## @@ -87,18 +88,19 @@ private static

[GitHub] [flink] MartijnVisser commented on pull request #17728: [FLINK-24832][tests][testinfrastructure] Update JUnit5 to v5.8.1

MartijnVisser commented on pull request #17728: URL: https://github.com/apache/flink/pull/17728#issuecomment-976504505 @AHeise Please merge -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e0d7451523be3976f3c8695a0f3c9c782a76fddf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e0d7451523be3976f3c8695a0f3c9c782a76fddf Azure:

[GitHub] [flink-benchmarks] pnowojski commented on a change in pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

pnowojski commented on a change in pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41#discussion_r755090811 ## File path: README.md ## @@ -31,14 +31,33 @@ There're mainly two ways: mvn -Dflink.version= clean package exec:exec \ -Dbenchmarks=""

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * b3703f43ebbe0c33d7ca3a607b7cd6fb49169e5b Azure:

[GitHub] [flink] dmvk commented on a change in pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

dmvk commented on a change in pull request #17607: URL: https://github.com/apache/flink/pull/17607#discussion_r755095766 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java ## @@ -87,18 +88,19 @@ private static

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e0d7451523be3976f3c8695a0f3c9c782a76fddf Azure:

[GitHub] [flink-ml] zhipeng93 commented on pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on pull request #28: URL: https://github.com/apache/flink-ml/pull/28#issuecomment-976486651 Hi@lindong28 , thanks for the review and I have address your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Closed] (FLINK-24989) Upgrade shade-plugin to 3.2.4

[ https://issues.apache.org/jira/browse/FLINK-24989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24989. Resolution: Fixed master: a26cd47c1a1332ded2ecdeb6cabca7a3e589f4e4 > Upgrade

[jira] [Closed] (FLINK-24988) Upgrade lombok to 1.18.22

[ https://issues.apache.org/jira/browse/FLINK-24988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24988. Resolution: Fixed master: b485560c1129a303eab8655e97d56d7bc8e8bfe7 > Upgrade lombok to

[GitHub] [flink] zentol merged pull request #17860: [FLINK-24988][build] Upgrade lombok to 1.18.22

zentol merged pull request #17860: URL: https://github.com/apache/flink/pull/17860 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * b3703f43ebbe0c33d7ca3a607b7cd6fb49169e5b Azure:

[GitHub] [flink] zentol merged pull request #17861: [FLINK-24989][build] Bump shade-plugin to 3.2.4

zentol merged pull request #17861: URL: https://github.com/apache/flink/pull/17861 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e0d7451523be3976f3c8695a0f3c9c782a76fddf Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r755088231 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasL2.java ## @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] XComp commented on pull request #17858: [FLINK-24986][tests] Replace anonymous StreamStateHandle class

XComp commented on pull request #17858: URL: https://github.com/apache/flink/pull/17858#issuecomment-976480406 The test failure is related to [FLINK-23525](https://issues.apache.org/jira/browse/FLINK-23525) -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 08d4751f06377557fc6a8b2fc9db6008f17bd23d Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r755088231 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasL2.java ## @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e0d7451523be3976f3c8695a0f3c9c782a76fddf Azure:

<    1   2   3   4   5   6   7   8   9   >