[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #113: [Flink-17644] Add state expiration to the Java SDK

sjwiesman commented on a change in pull request #113: URL: https://github.com/apache/flink-statefun/pull/113#discussion_r426813593 ## File path: statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] pnowojski merged pull request #12231: [FLINK-17799][network] Fix performance regression in the network stack

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

[jira] [Closed] (FLINK-17799) Performance regression in all network benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17799. -- Resolution: Fixed Merged to 1.11 branch as b834ff6b2f merged to master as a875235389 > Perfor

[GitHub] [flink] kl0u commented on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

kl0u commented on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630368825 @gaoyunhaii the changes in the `StreamingFileSink` look good. I have not checked the `flink-hadoop-bulk` module, so someone else can do a more in-depth review on that.

[GitHub] [flink] kl0u edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

kl0u edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630368825 @gaoyunhaii the changes in the `StreamingFileSink` look good. As long as nothing fails on Azure (we have to wait and see before merging) and given that there was no change r

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

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

[GitHub] [flink] kl0u edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

kl0u edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630368825 @gaoyunhaii the changes in the `StreamingFileSink` look good. As long as nothing fails on Azure (we have to wait and see before merging) and given that there was no change r

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Fix Version/s: (was: 1.10.0) 1.11.0 > PackagedProgram' extractedTempL

[jira] [Assigned] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17745: -- Assignee: Kostas Kloudas > PackagedProgram' extractedTempLibraries and jarfiles may b

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Issue Type: Improvement (was: Bug) > PackagedProgram' extractedTempLibraries and jarfiles m

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Affects Version/s: (was: 1.10.0) 1.11.0 > PackagedProgram' extrac

[jira] [Commented] (FLINK-17506) SavepointEnvironment does not honour 'io.tmp.dirs' property

[ https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110533#comment-17110533 ] Seth Wiesman commented on FLINK-17506: -- [~david.artiga] That has been resolved. F

[GitHub] [flink] sjwiesman commented on pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

sjwiesman commented on pull request #12041: URL: https://github.com/apache/flink/pull/12041#issuecomment-630376259 Fixed in Master: 7934fc04ac098e2143cab9459b216725fe1b8be6 release-1.11: ce10080de0e6c35d60147318381c096cf77ec252 release-1.10: 313051c0ffdacb1bca2d26482bd9bc7036bf9fd2

[GitHub] [flink] sjwiesman closed pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

sjwiesman closed pull request #12041: URL: https://github.com/apache/flink/pull/12041 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 t

[jira] [Resolved] (FLINK-17506) SavepointEnvironment does not honour 'io.tmp.dirs' property

[ https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-17506. -- Resolution: Fixed > SavepointEnvironment does not honour 'io.tmp.dirs' property >

[jira] [Updated] (FLINK-17506) SavepointEnvironment does not honour 'io.tmp.dirs' property

[ https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-17506: - Affects Version/s: 1.12.0 > SavepointEnvironment does not honour 'io.tmp.dirs' property > --

[GitHub] [flink] kl0u opened a new pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

kl0u opened a new pull request #12233: URL: https://github.com/apache/flink/pull/12233 ## What is the purpose of the change The `PackagesProgram` so far was looking in the user's jar for other jars under a `lib/` directory it was extracting them, copy them to separate files, and put

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17745: --- Labels: pull-request-available (was: ) > PackagedProgram' extractedTempLibraries and jarfil

[GitHub] [flink] flinkbot commented on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

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

[GitHub] [flink] flinkbot edited a comment on pull request #12221: [FLINK-17797][FLINK-17798][hbase][jdbc] Align the behavior between the new and legacy HBase/JDBC table source

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

[GitHub] [flink] twalthr closed pull request #12103: [FLINK-16998][core] Add a changeflag to Row

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

[jira] [Commented] (FLINK-16998) Add a changeflag to Row type

[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110549#comment-17110549 ] Timo Walther commented on FLINK-16998: -- Changeflag has been added. Backwards compat

[GitHub] [flink] flinkbot commented on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

flinkbot commented on pull request #12233: URL: https://github.com/apache/flink/pull/12233#issuecomment-630388527 ## CI report: * 08d1dabd6e910a0560299200129951ecf811af99 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * e1a615f3322b72015953856f1316691fd0c77896 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #113: [Flink-17644] Add state expiration to the Java SDK

sjwiesman commented on a change in pull request #113: URL: https://github.com/apache/flink-statefun/pull/113#discussion_r426858040 ## File path: statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache So

[GitHub] [flink-statefun] sjwiesman closed pull request #113: [Flink-17644] Add state expiration to the Java SDK

sjwiesman closed pull request #113: URL: https://github.com/apache/flink-statefun/pull/113 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

[jira] [Commented] (FLINK-17644) Add support for state TTL.

[ https://issues.apache.org/jira/browse/FLINK-17644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110569#comment-17110569 ] Seth Wiesman commented on FLINK-17644: -- Fixed in dd85b1184715a4e19aac527584e00f9e17

[GitHub] [flink-statefun] sjwiesman commented on pull request #113: [Flink-17644] Add state expiration to the Java SDK

sjwiesman commented on pull request #113: URL: https://github.com/apache/flink-statefun/pull/113#issuecomment-630400906 Closed in dd85b1184715a4e19aac527584e00f9e17c47aeb This is an automated message from the Apache Git Servi

[jira] [Resolved] (FLINK-17644) Add support for state TTL.

[ https://issues.apache.org/jira/browse/FLINK-17644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-17644. -- Resolution: Fixed > Add support for state TTL. > -- > >

[jira] [Assigned] (FLINK-17644) Add support for state TTL.

[ https://issues.apache.org/jira/browse/FLINK-17644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-17644: Assignee: Igal Shilman > Add support for state TTL. > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

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

[GitHub] [flink] zentol commented on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

zentol commented on pull request #12233: URL: https://github.com/apache/flink/pull/12233#issuecomment-630405992 AFAIK it should not be redundant, since classes in nested jars aren't accessible by default. See https://docs.oracle.com/javase/tutorial/deployment/jar/downman.html. > To

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

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

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * aa5d10422ec019419efbb3a0e9c1f0900b960529 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

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

[jira] [Commented] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110576#comment-17110576 ] Flavio Pompermaier commented on FLINK-17762: Now FLINK-17029 is unlocked and

[GitHub] [flink] roeyshemtov commented on pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

roeyshemtov commented on pull request #11972: URL: https://github.com/apache/flink/pull/11972#issuecomment-630412268 @aljoscha Fixed the CR comments, can u check? This is an automated message from the Apache Git Service. To r

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

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

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 22f64e5fd5c999213d4b0d764cc9eb8e602a9e2f Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12229: [FLINK-17675][docs] Update jquery dependency to 3.5.1

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

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

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

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

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

[GitHub] [flink] StephanEwen commented on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

StephanEwen commented on pull request #12234: URL: https://github.com/apache/flink/pull/12234#issuecomment-630418413 This change does need some more targeted unit tests. This is an automated message from the Apache Git Servic

[jira] [Updated] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing.

[ https://issues.apache.org/jira/browse/FLINK-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16986: --- Labels: pull-request-available (was: ) > Enhance the OperatorEvent handling guarantee durin

[GitHub] [flink] StephanEwen opened a new pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

StephanEwen opened a new pull request #12234: URL: https://github.com/apache/flink/pull/12234 ## What is the purpose of the change Ensures that sending of `OperatorEvents` from `OperatorCoordinator` to `StreamOperator` follows exactly-once semantics. The checkpointing procedur

[GitHub] [flink] flinkbot commented on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

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

[GitHub] [flink] kl0u commented on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

kl0u commented on pull request #12233: URL: https://github.com/apache/flink/pull/12233#issuecomment-630430453 You are right @zentol that the nested jars will not be accessible by default. My main point about the "redundant" part is that we ship them twice, once as part of the original jar

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

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

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 22f64e5fd5c999213d4b0d764cc9eb8e602a9e2f Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

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

[GitHub] [flink] flinkbot edited a comment on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

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

[GitHub] [flink] flinkbot edited a comment on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

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

[GitHub] [flink] flinkbot edited a comment on pull request #12223: [FLINK-15813][runtime] Set default value of config “jobmanager.execution.failover-strategy” to “region”

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

[GitHub] [flink] flinkbot edited a comment on pull request #12075: [FLINK-17004] Document the LIKE clause of CREATE TABLE statement.

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

[GitHub] [flink-statefun] igalshilman commented on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

igalshilman commented on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-630483536 Hi @slinkydeveloper, I've been investigating this and came up with a working solution: 1) basically we need to wrap the `AFUnixSocket` with a `Socket` and delegate

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110707#comment-17110707 ] Kurt Young commented on FLINK-17793: I also agree that view and table are not very d

[GitHub] [flink] gaoyunhaii commented on a change in pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

gaoyunhaii commented on a change in pull request #12224: URL: https://github.com/apache/flink/pull/12224#discussion_r426969381 ## File path: flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/committer/HadoopRenameFileCommitter.java ## @@ -0,0 +

[GitHub] [flink] gaoyunhaii commented on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

gaoyunhaii commented on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630511481 Very thanks @JingsongLi and @kl0u for the review! This is an automated message from the Apache Git Service. T

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * aa5d10422ec019419efbb3a0e9c1f0900b960529 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110756#comment-17110756 ] Canbin Zheng commented on FLINK-17196: -- Thank you [~trohrmann]! > Improve the impl

[GitHub] [flink] JingsongLi opened a new pull request #12235: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

JingsongLi opened a new pull request #12235: URL: https://github.com/apache/flink/pull/12235 ## What is the purpose of the change This is 1.11 cherry-pick version of https://github.com/apache/flink/pull/12220 Integrate mapred record writer to hive streaming sink. Hadoop Rec

[GitHub] [flink] flinkbot commented on pull request #12235: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12220: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * aa5d10422ec019419efbb3a0e9c1f0900b960529 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-15679) Improve Flink's ID system

[ https://issues.apache.org/jira/browse/FLINK-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15679: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Improve Flink's ID system > ---

[jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option

[ https://issues.apache.org/jira/browse/FLINK-17535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17535: --- Fix Version/s: 1.12.0 > Treat min/max as part of the hierarchy of config option > --

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15959: --- Fix Version/s: 1.12.0 > Add min number of slots configuration to limit total number of slots > -

[jira] [Updated] (FLINK-17540) Adding tests/tools checking the pattern of new configuration options following the xyz.max/min pattern

[ https://issues.apache.org/jira/browse/FLINK-17540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17540: --- Fix Version/s: 1.12.0 > Adding tests/tools checking the pattern of new configuration options > foll

[jira] [Updated] (FLINK-15324) Make MesosResourceManager inherit from ActiveResourceManager

[ https://issues.apache.org/jira/browse/FLINK-15324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15324: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Make MesosResourceManager inherit from

[jira] [Updated] (FLINK-16788) Support username and password options for Elasticsearch SQL connector

[ https://issues.apache.org/jira/browse/FLINK-16788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16788: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support username and password options f

[jira] [Commented] (FLINK-16788) Support username and password options for Elasticsearch SQL connector

[ https://issues.apache.org/jira/browse/FLINK-16788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110765#comment-17110765 ] Yangze Guo commented on FLINK-16788: Change the fix version to 1.12.0 since 1.11.0 h

[jira] [Updated] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17331: --- Fix Version/s: 1.12.0 > Add NettyMessageContent interface for all the class which could be write to

[jira] [Commented] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110766#comment-17110766 ] Yang Wang commented on FLINK-15792: --- Make sense to me. It will make thing easier to de

[GitHub] [flink] jinglining commented on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining commented on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-630529747 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] banmoy commented on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

banmoy commented on pull request #12139: URL: https://github.com/apache/flink/pull/12139#issuecomment-630530026 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110768#comment-17110768 ] Yang Wang commented on FLINK-17745: --- Do we have a case that the fat contains other jar

[jira] [Commented] (FLINK-17623) Elasticsearch sink should support user resource cleanup

[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110770#comment-17110770 ] Yangze Guo commented on FLINK-17623: Sorry for the belated response. In this case, I

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17623: --- Fix Version/s: 1.12.0 > Elasticsearch sink should support user resource cleanup > --

[GitHub] [flink] flinkbot edited a comment on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12220: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

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

[GitHub] [flink] flinkbot commented on pull request #12235: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

flinkbot commented on pull request #12235: URL: https://github.com/apache/flink/pull/12235#issuecomment-630534111 ## CI report: * 6514d8bd0422cc1b8b5b0769c93306d7f5b5e237 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17416: -- Priority: Major (was: Blocker) > Flink-kubernetes doesn't work on java 8 8u252 >

[jira] [Commented] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110778#comment-17110778 ] Yang Wang commented on FLINK-17416: --- For now, the reasonable solution is bumping the f

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110779#comment-17110779 ] Yang Wang commented on FLINK-17565: --- [~felixzheng] Do we have some problems to bump th

[GitHub] [flink] flinkbot edited a comment on pull request #12216: [FLINK-17788][scala-shell] scala shell in yarn mode is broken

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

[GitHub] [flink] flinkbot edited a comment on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * aa5d10422ec019419efbb3a0e9c1f0900b960529 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12220: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12235: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

flinkbot edited a comment on pull request #12235: URL: https://github.com/apache/flink/pull/12235#issuecomment-630534111 ## CI report: * 6514d8bd0422cc1b8b5b0769c93306d7f5b5e237 UNKNOWN * 0adf4c6ffa6d9ec479607b803b9bc62fdc2e771b UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

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

[jira] [Commented] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110781#comment-17110781 ] Jingsong Lee commented on FLINK-17789: -- Thanks for your detailed analysis. Now onl

[jira] [Updated] (FLINK-17527) kubernetes-session.sh uses log4j-console.properties

[ https://issues.apache.org/jira/browse/FLINK-17527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17527: --- Labels: pull-request-available (was: ) > kubernetes-session.sh uses log4j-console.propertie

[GitHub] [flink] wangyang0918 opened a new pull request #12236: [FLINK-17527][flink-dist] Make kubernetes-session.sh use session log4j/logback configuration files

wangyang0918 opened a new pull request #12236: URL: https://github.com/apache/flink/pull/12236 ## What is the purpose of the change Currently, `kubernetes-session.sh` uses the log4j-console.properties and `yarn-session.sh` uses `log4j-yarn-session.properties`. They should hav

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110788#comment-17110788 ] Canbin Zheng commented on FLINK-17565: -- [~fly_in_gis] Previously we discussed it in

[jira] [Commented] (FLINK-17015) Fix NPE from NullAwareMapIterator

[ https://issues.apache.org/jira/browse/FLINK-17015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110787#comment-17110787 ] Zhijiang commented on FLINK-17015: -- If I understand correctly, FLINK-17610 can also be

<    2   3   4   5   6   7   8   9   >