[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17485638#comment-17485638 ] Martijn Visser commented on FLINK-24229: [~Gusev] It depends if [~dannycranmer] has time to

[GitHub] [flink] flinkbot edited a comment on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

flinkbot edited a comment on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025854469 ## CI report: * d25cacc0342eebd981a1f254aff684ed6b6a152a Azure:

[GitHub] [flink] matriv commented on a change in pull request #18582: [FLINK-24780][table-planner] Port time/date/timestamp casts to new structure

matriv commented on a change in pull request #18582: URL: https://github.com/apache/flink/pull/18582#discussion_r797384708 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/TimestampToDateCastRule.java ## @@ -0,0

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17485631#comment-17485631 ] Yuri Gusev commented on FLINK-24229: Hi [~MartijnVisser] , Do you think we can merge this before

[GitHub] [flink] flinkbot edited a comment on pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

flinkbot edited a comment on pull request #18575: URL: https://github.com/apache/flink/pull/18575#issuecomment-1025993745 ## CI report: * 7829141285dc11e44799080155ab037f18d76b7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

flinkbot edited a comment on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025854469 ## CI report: * d25cacc0342eebd981a1f254aff684ed6b6a152a Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18582: [FLINK-24780][table-planner] Port time/date/timestamp casts to new structure

slinkydeveloper commented on a change in pull request #18582: URL: https://github.com/apache/flink/pull/18582#discussion_r797376158 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastRuleUtils.java ## @@ -43,6

[jira] [Assigned] (FLINK-25907) Add pluggable delegation token manager

[ https://issues.apache.org/jira/browse/FLINK-25907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-25907: - Assignee: Gabor Somogyi > Add pluggable delegation token manager >

[jira] [Updated] (FLINK-25881) Measure visits on flink.apache.org and nightlies.apache.org/flink as the same visit

[ https://issues.apache.org/jira/browse/FLINK-25881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25881: --- Labels: pull-request-available (was: ) > Measure visits on flink.apache.org and

[GitHub] [flink-web] knaufk merged pull request #503: [FLINK-25881][Website] Fix subdomain tracking and update privacy policy

knaufk merged pull request #503: URL: https://github.com/apache/flink-web/pull/503 -- 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] slinkydeveloper commented on a change in pull request #18582: [FLINK-24780][table-planner] Port time/date/timestamp casts to new structure

slinkydeveloper commented on a change in pull request #18582: URL: https://github.com/apache/flink/pull/18582#discussion_r797372485 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/NumericToTimestampCastRule.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

flinkbot edited a comment on pull request #18575: URL: https://github.com/apache/flink/pull/18575#issuecomment-1025993745 ## CI report: * 7829141285dc11e44799080155ab037f18d76b7b Azure:

[GitHub] [flink] matriv commented on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

matriv commented on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1027702619 > @matriv given your two comments, does it makes sense to just go ahead and remove this validator? Yes, the @JsonCreator is tested statically when we build the lookupMap

[GitHub] [flink] flinkbot edited a comment on pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

flinkbot edited a comment on pull request #18575: URL: https://github.com/apache/flink/pull/18575#issuecomment-1025993745 ## CI report: * 7829141285dc11e44799080155ab037f18d76b7b Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

pnowojski commented on a change in pull request #18575: URL: https://github.com/apache/flink/pull/18575#discussion_r797370556 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorTestBase.java ## @@ -0,0 +1,129 @@ +/*

[jira] [Closed] (FLINK-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP

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

[GitHub] [flink] zentol merged pull request #18579: [FLINK-25564][flink-tests] leave cleanup to rule

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

[jira] [Created] (FLINK-25918) Use FileEnumerator to implement filter pushdown of filepath metadata

Francesco Guardiani created FLINK-25918: --- Summary: Use FileEnumerator to implement filter pushdown of filepath metadata Key: FLINK-25918 URL: https://issues.apache.org/jira/browse/FLINK-25918

[GitHub] [flink] flinkbot edited a comment on pull request #18600: [FLINK-25917][tests] Share RpcSystem

flinkbot edited a comment on pull request #18600: URL: https://github.com/apache/flink/pull/18600#issuecomment-1027685597 ## CI report: * c7f3ce3f0f5e58a497461a661593c7b772afab4a Azure:

[GitHub] [flink] flinkbot commented on pull request #18600: [FLINK-25917][tests] Share RpcSystem

flinkbot commented on pull request #18600: URL: https://github.com/apache/flink/pull/18600#issuecomment-1027686805 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] flinkbot commented on pull request #18600: [FLINK-25917][tests] Share RpcSystem

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

[jira] [Updated] (FLINK-25917) Share RpcSystem aross tests

[ https://issues.apache.org/jira/browse/FLINK-25917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25917: --- Labels: pull-request-available (was: ) > Share RpcSystem aross tests >

[GitHub] [flink] zentol opened a new pull request #18600: [FLINK-25917][tests] Share RpcSystem

zentol opened a new pull request #18600: URL: https://github.com/apache/flink/pull/18600 We currently create a dedicated RpcSystem for each test, meaning that we go through the whole cycle of extracting the rpc-akka jar and creating a new classloader. For testing purposes we can

[GitHub] [flink] flinkbot edited a comment on pull request #18395: [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

flinkbot edited a comment on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015461969 ## CI report: * 70ceb328e6cd50278311a27b2357d0c4e9d184f6 Azure:

[jira] [Created] (FLINK-25917) Share RpcSystem aross tests

Chesnay Schepler created FLINK-25917: Summary: Share RpcSystem aross tests Key: FLINK-25917 URL: https://issues.apache.org/jira/browse/FLINK-25917 Project: Flink Issue Type: Technical

[GitHub] [flink] pnowojski commented on a change in pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

pnowojski commented on a change in pull request #18575: URL: https://github.com/apache/flink/pull/18575#discussion_r797354154 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleFuturesAvailabilityHelper.java ## @@ -0,0 +1,77 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #18395: [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

flinkbot edited a comment on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015461969 ## CI report: * 70ceb328e6cd50278311a27b2357d0c4e9d184f6 Azure:

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17485621#comment-17485621 ] Chesnay Schepler commented on FLINK-25819: -- Better error reporting added: master:

[GitHub] [flink] zentol merged pull request #18521: [FLINK-25819][tests] Improve error reporting

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

[jira] [Closed] (FLINK-25894) Explicitly configure japicmp oldVersion for flink-streaming-java

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

[jira] [Closed] (FLINK-25905) Promoting Experimental methods is marked as a violation

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

[GitHub] [flink] zentol merged pull request #18578: [FLINK-25894][build] Explicitly set streaming-java oldVersion

zentol merged pull request #18578: URL: https://github.com/apache/flink/pull/18578 -- 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 #18395: [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

flinkbot edited a comment on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015461969 ## CI report: * 70ceb328e6cd50278311a27b2357d0c4e9d184f6 Azure:

<    1   2   3   4   5