[jira] [Updated] (FLINK-26046) Link to OpenAPI specification is dead

[ https://issues.apache.org/jira/browse/FLINK-26046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26046: --- Labels: pull-request-available (was: ) > Link to OpenAPI specification is dead > --

[GitHub] [flink] zentol opened a new pull request #18682: [FLINK-26046][rest][docs] Fix link to OpenAPI spec

zentol opened a new pull request #18682: URL: https://github.com/apache/flink/pull/18682 Adds a new short code for referring to static resources (because `ref` always points into content/). -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

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

[jira] [Updated] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Source Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang updated FLINK-25686: Summary: Support Pulsar Schema evolution in Pulsar Source Connector (was: Support Pulsar Schema e

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

flinkbot edited a comment on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686 ## CI report: * 61291e34604181a379a8d6ee1b9cb2f078c27035 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

flinkbot commented on pull request #18681: URL: https://github.com/apache/flink/pull/18681#issuecomment-1033537386 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 commented on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

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

[GitHub] [flink] JingGe opened a new pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

JingGe opened a new pull request #18681: URL: https://github.com/apache/flink/pull/18681 ## What is the purpose of the change The check of areExplicitEnvironmentsAllowed in the StreamExecutionEnvironment should not depend on the ExecutionEnvironment ## Brief change log

[GitHub] [flink] akalash commented on a change in pull request #18645: [FLINK-25745] Document incremental savepoints in CLAIM mode limitation

akalash commented on a change in pull request #18645: URL: https://github.com/apache/flink/pull/18645#discussion_r802435369 ## File path: docs/content/docs/ops/state/savepoints.md ## @@ -269,10 +269,18 @@ the snapshot, while others still depend on it. {{< img src="/fig/resto

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

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

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

slinkydeveloper commented on a change in pull request #18653: URL: https://github.com/apache/flink/pull/18653#discussion_r802413537 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@ -

[GitHub] [flink] flinkbot edited a comment on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 7942048b31c8d18d36367fb319627b80f79944e3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] wanglijie95 commented on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

wanglijie95 commented on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033518994 Thanks for review @zhuzhurk . I 've adderessed all your comments. Please help to review it again. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

flinkbot edited a comment on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917 ## CI report: * 9a224d875c6cd1fe41339151caf3a288099eda77 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 7942048b31c8d18d36367fb319627b80f79944e3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

flinkbot edited a comment on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686 ## CI report: * 61291e34604181a379a8d6ee1b9cb2f078c27035 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489376#comment-17489376 ] David Morávek commented on FLINK-18356: --- [~gaoyunhaii] It's linked with my previou

[jira] [Commented] (FLINK-26045) Document error status codes for the REST API

[ https://issues.apache.org/jira/browse/FLINK-26045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489377#comment-17489377 ] Chesnay Schepler commented on FLINK-26045: -- I'd rather not go in and manually d

[jira] [Commented] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

[ https://issues.apache.org/jira/browse/FLINK-21278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489373#comment-17489373 ] Yao Zhang commented on FLINK-21278: --- Could someone help review this issue please? > N

[GitHub] [flink] flinkbot commented on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

flinkbot edited a comment on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917 ## CI report: * 9a224d875c6cd1fe41339151caf3a288099eda77 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 350b954707a28cac90f84678bb5878660b5d6d16 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-26046) Link to OpenAPI specification is dead

[ https://issues.apache.org/jira/browse/FLINK-26046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-26046: Assignee: Chesnay Schepler > Link to OpenAPI specification is dead >

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 7942048b31c8d18d36367fb319627b80f79944e3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

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

[GitHub] [flink] flinkbot commented on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033509904 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] paul8263 commented on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

paul8263 commented on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-1033509745 @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 specifi

[jira] [Updated] (FLINK-25583) Support compacting small files for FileSink

[ https://issues.apache.org/jira/browse/FLINK-25583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25583: --- Labels: pull-request-available (was: ) > Support compacting small files for FileSink >

[GitHub] [flink] pltbkd opened a new pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd opened a new pull request #18680: URL: https://github.com/apache/flink/pull/18680 ## What is the purpose of the change This pull request makes the FileSink to support compacting small files, based on the new extended sink API. ## Brief change log - User

[jira] [Commented] (FLINK-26046) Link to OpenAPI specification is dead

[ https://issues.apache.org/jira/browse/FLINK-26046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489368#comment-17489368 ] David Morávek commented on FLINK-26046: --- [~chesnay] can you please take a look at

[jira] [Commented] (FLINK-26045) Document error status codes for the REST API

[ https://issues.apache.org/jira/browse/FLINK-26045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489366#comment-17489366 ] David Morávek commented on FLINK-26045: --- [~chesnay] can you please take a look at

[GitHub] [flink] flinkbot edited a comment on pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 7942048b31c8d18d36367fb319627b80f79944e3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

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

[jira] [Created] (FLINK-26046) Link to OpenAPI specification is dead

David Morávek created FLINK-26046: - Summary: Link to OpenAPI specification is dead Key: FLINK-26046 URL: https://issues.apache.org/jira/browse/FLINK-26046 Project: Flink Issue Type: Technical

[jira] [Updated] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26036: -- Fix Version/s: 1.15.0 > LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirec

[jira] [Assigned] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26036: - Assignee: Till Rohrmann > LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWor

[jira] [Commented] (FLINK-26034) Add maven wrapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489364#comment-17489364 ] Till Rohrmann commented on FLINK-26034: --- This could indeed be helpful. Especially

[GitHub] [flink] imaffe edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

imaffe edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1033486400 > > The only concern is my limited knowledge of Pulsar transactions. Maybe you can clarify the following scenarios. > > The job opens a transaction and sends records, n

[jira] [Updated] (FLINK-26034) Add maven wrapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26034: -- Summary: Add maven wrapper for flink (was: Add maven wapper for flink) > Add maven wrapper fo

[jira] [Created] (FLINK-26045) Document error status codes for the REST API

David Morávek created FLINK-26045: - Summary: Document error status codes for the REST API Key: FLINK-26045 URL: https://issues.apache.org/jira/browse/FLINK-26045 Project: Flink Issue Type: Te

[GitHub] [flink] KarmaGYZ removed a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

KarmaGYZ removed a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1033442692 @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] KarmaGYZ commented on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

KarmaGYZ commented on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1033503027 @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 specifi

[jira] [Assigned] (FLINK-25792) Async Sink Base is too being flushed too frequently resulting in backpressure even when buffer is near empty

[ https://issues.apache.org/jira/browse/FLINK-25792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-25792: - Assignee: Zichen Liu (was: Ahmed Hamdy) > Async Sink Base is too being flushed too fre

[GitHub] [flink] zhuzhurk commented on a change in pull request #18673: [FLINK-26004][runtime] Introduce ForwardForLocalKeyByPartitioner

zhuzhurk commented on a change in pull request #18673: URL: https://github.com/apache/flink/pull/18673#discussion_r802323336 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -879,6 +882,28 @@ private vo

[jira] [Commented] (FLINK-24275) Allow idempotent job cancellation

[ https://issues.apache.org/jira/browse/FLINK-24275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489361#comment-17489361 ] Chesnay Schepler commented on FLINK-24275: -- The exit codes for successful opera

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForLocalKeyByPartitioner

flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * d4024099d616391ebf07e286dbe0ee7a122ad420 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

flinkbot edited a comment on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608 ## CI report: * 684a97f9456209609f00381df489b6dc17e329f4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 094559bb04127d51d4ec5d8e287ef4d13ff7cdf9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

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

[jira] [Assigned] (FLINK-25933) Allow configuring different transports in RequestReplyFunctionBuilder

[ https://issues.apache.org/jira/browse/FLINK-25933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25933: - Assignee: Galen Warren > Allow configuring different transports in RequestReplyFunction

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 718956f5995a807ea6b112913679e1c9d4b91986 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 972db53783b183c8f0f829b0510e599f140787af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 7942048b31c8d18d36367fb319627b80f79944e3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489358#comment-17489358 ] Jun Qin commented on FLINK-26018: - I haven't tried with 1.13. [~renqs] could you comment

[GitHub] [flink] imaffe edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

imaffe edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1033486400 > > The only concern is my limited knowledge of Pulsar transactions. Maybe you can clarify the following scenarios. > > The job opens a transaction and sends records, n

[jira] [Commented] (FLINK-25910) Propagate obtained delegation tokens to TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-25910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489355#comment-17489355 ] Gabor Somogyi commented on FLINK-25910: --- Propagating tokens during registration is

[GitHub] [flink] imaffe edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

imaffe edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1033486400 > > The only concern is my limited knowledge of Pulsar transactions. Maybe you can clarify the following scenarios. > > The job opens a transaction and sends records, n

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

slinkydeveloper commented on a change in pull request #18573: URL: https://github.com/apache/flink/pull/18573#discussion_r802392462 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/CompiledPlan.java ## @@ -59,4 +62,12 @@ default void writ

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 094559bb04127d51d4ec5d8e287ef4d13ff7cdf9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 718956f5995a807ea6b112913679e1c9d4b91986 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 7942048b31c8d18d36367fb319627b80f79944e3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] imaffe commented on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

imaffe commented on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1033486400 > > The only concern is my limited knowledge of Pulsar transactions. Maybe you can clarify the following scenarios. > > The job opens a transaction and sends records, now sudd

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25566: --- Component/s: Runtime / Coordination (was: Runtime / Task) > Fail to can

[jira] [Created] (FLINK-26044) Properly declare internal UNNEST function

Timo Walther created FLINK-26044: Summary: Properly declare internal UNNEST function Key: FLINK-26044 URL: https://issues.apache.org/jira/browse/FLINK-26044 Project: Flink Issue Type: Sub-tas

[jira] [Assigned] (FLINK-25785) Update com.h2database:h2 to 2.0.210

[ https://issues.apache.org/jira/browse/FLINK-25785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25785: -- Assignee: Martijn Visser > Update com.h2database:h2 to 2.0.210 >

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489353#comment-17489353 ] Piotr Nowojski commented on FLINK-25566: I see your point and I tend to agree, t

[jira] [Comment Edited] (FLINK-26034) Add maven wapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489350#comment-17489350 ] Aiden Gong edited comment on FLINK-26034 at 2/9/22, 8:29 AM: -

[jira] [Updated] (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 updated FLINK-25907: -- Description: (was: The intention here is mainly: * Update the following documentation: htt

[jira] [Updated] (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 updated FLINK-25907: -- Description: The intention here is mainly: * Update the following documentation: https://nigh

[jira] [Commented] (FLINK-26034) Add maven wapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489350#comment-17489350 ] Aiden Gong commented on FLINK-26034: Hi,[~trohrmann] . What do you think this?  > A

[jira] [Updated] (FLINK-25911) Add delegation token framework documentation

[ https://issues.apache.org/jira/browse/FLINK-25911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-25911: -- Description: The intention here is mainly: * Update the following documentation: https://nigh

[GitHub] [flink] flinkbot edited a comment on pull request #18679: [FLINK-26039][table-runtime] Fix the incorrect value getter in map unnest table function

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26034) Add maven wapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong updated FLINK-26034: --- Description: Idea just support this feature now. It is very helpful for contributors. (was: Idea ju

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26030: -- Priority: Minor (was: Major) > Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers >

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26030: -- Issue Type: Bug (was: Improvement) > Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[jira] [Assigned] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-26043: - Assignee: Gabor Somogyi > Add periodic kerberos relogin to DelegationTokenManager > ---

[jira] [Created] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

Gabor Somogyi created FLINK-26043: - Summary: Add periodic kerberos relogin to DelegationTokenManager Key: FLINK-26043 URL: https://issues.apache.org/jira/browse/FLINK-26043 Project: Flink Iss

[jira] [Closed] (FLINK-25572) Update File Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25572. --- Fix Version/s: 1.15.0 Resolution: Fixed > Update File Sink to use decomposed interfaces > ---

[GitHub] [flink] dmvk closed pull request #18663: [FLINK-25937][runtime] Synchronize DefaultJobMasterServiceFactory#int…

dmvk closed pull request #18663: URL: https://github.com/apache/flink/pull/18663 -- 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-unsubscr..

[jira] [Commented] (FLINK-25572) Update File Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489348#comment-17489348 ] Yun Gao commented on FLINK-25572: - Merged on master via 46788bbabed543cbfff329b16b3f517

[jira] [Commented] (FLINK-24275) Allow idempotent job cancellation

[ https://issues.apache.org/jira/browse/FLINK-24275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489347#comment-17489347 ] Joe Moser commented on FLINK-24275: --- [~chesnay] wouldn't it make sense to document the

[GitHub] [flink] flinkbot commented on pull request #18679: [FLINK-26039][table-runtime] Fix the incorrect value getter in map unnest table function

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

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForLocalKeyByPartitioner

flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * 610d34bf7b10d17b3731c4d7aa877f822594faf8 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

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

[GitHub] [flink] flinkbot edited a comment on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] gaborgsomogyi commented on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

gaborgsomogyi commented on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1033474701 cc @dmvk @gyfora @mbalassi @zentol -- 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

[GitHub] [flink] flinkbot commented on pull request #18679: [FLINK-26039][table-runtime] Fix the incorrect value getter in map unnest table function

flinkbot commented on pull request #18679: URL: https://github.com/apache/flink/pull/18679#issuecomment-1033474406 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

<    4   5   6   7   8   9   10   >