[jira] [Commented] (FLINK-24114) Make CompletedOperationCache.COMPLETED_OPERATION_RESULT_CACHE_DURATION_SECONDS configurable (at least for savepoint trigger operations)

2021-09-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408231#comment-17408231 ] Chesnay Schepler commented on FLINK-24114: -- I don't quite understand why this would be required

[jira] [Comment Edited] (FLINK-24114) Make CompletedOperationCache.COMPLETED_OPERATION_RESULT_CACHE_DURATION_SECONDS configurable (at least for savepoint trigger operations)

2021-09-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408231#comment-17408231 ] Chesnay Schepler edited comment on FLINK-24114 at 9/1/21, 3:17 PM: --- I

[jira] [Created] (FLINK-24115) Outdated SQL Temporal Join Example

2021-09-01 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24115: --- Summary: Outdated SQL Temporal Join Example Key: FLINK-24115 URL: https://issues.apache.org/jira/browse/FLINK-24115 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-24095) Elasticsearch7DynamicSinkITCase.testWritingDocuments fails due to socket timeout

2021-09-01 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24095: - Affects Version/s: 1.14.0 > Elasticsearch7DynamicSinkITCase.testWritingDocuments fails

[jira] [Commented] (FLINK-24095) Elasticsearch7DynamicSinkITCase.testWritingDocuments fails due to socket timeout

2021-09-01 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408228#comment-17408228 ] Dawid Wysakowicz commented on FLINK-24095: -- I assume it is the same problem:

[jira] [Reopened] (FLINK-16346) BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Travis

2021-09-01 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-16346: -- Reappeared in 1.12:

[jira] [Updated] (FLINK-16346) BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Travis

2021-09-01 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16346: - Affects Version/s: 1.12.5 > BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails

[GitHub] [flink] dawidwys commented on a change in pull request #17055: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to…

2021-09-01 Thread GitBox
dawidwys commented on a change in pull request #17055: URL: https://github.com/apache/flink/pull/17055#discussion_r700305457 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -1264,6 +1265,42 @@ public void

[GitHub] [flink] dawidwys commented on a change in pull request #17055: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to…

2021-09-01 Thread GitBox
dawidwys commented on a change in pull request #17055: URL: https://github.com/apache/flink/pull/17055#discussion_r700305457 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -1264,6 +1265,42 @@ public void

[jira] [Created] (FLINK-24114) Make CompletedOperationCache.COMPLETED_OPERATION_RESULT_CACHE_DURATION_SECONDS configurable (at least for savepoint trigger operations)

2021-09-01 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-24114: -- Summary: Make CompletedOperationCache.COMPLETED_OPERATION_RESULT_CACHE_DURATION_SECONDS configurable (at least for savepoint trigger operations) Key: FLINK-24114 URL:

[jira] [Created] (FLINK-24113) Introduce option in Application Mode to request cluster shutdown

2021-09-01 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-24113: -- Summary: Introduce option in Application Mode to request cluster shutdown Key: FLINK-24113 URL: https://issues.apache.org/jira/browse/FLINK-24113 Project: Flink

[jira] [Commented] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-09-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408214#comment-17408214 ] Matthias commented on FLINK-23850: -- {quote} Please note FLINK-24051 which makes consumer group.id

[GitHub] [flink] flinkbot commented on pull request #17101: Update yarn.md

2021-09-01 Thread GitBox
flinkbot commented on pull request #17101: URL: https://github.com/apache/flink/pull/17101#issuecomment-910365459 ## CI report: * a1342e87844e902076072e7028b1980648753e8c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17102: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay

2021-09-01 Thread GitBox
flinkbot commented on pull request #17102: URL: https://github.com/apache/flink/pull/17102#issuecomment-910365614 ## CI report: * 63b411205164e87eabe44422c3973895ef645fc6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17089: URL: https://github.com/apache/flink/pull/17089#issuecomment-909842605 ## CI report: * 5ca09de8a0ce3562bcbfc101e66e6ca5c4175162 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17100: [FLINK-23916][python][docs] Expose in python and update the documentation how to set tolerable checkpoint failure number

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17100: URL: https://github.com/apache/flink/pull/17100#issuecomment-910340813 ## CI report: * 116156113d25199e29cf8e634a838d7612ea0585 UNKNOWN * c1b058769c6d786c1f32d939e79ea9e8b0c9a3e3 UNKNOWN Bot commands The

[jira] [Updated] (FLINK-23926) change TaxiRide data model to have a single timestamp

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23926: --- Labels: pull-request-available (was: ) > change TaxiRide data model to have a single

[GitHub] [flink] flinkbot edited a comment on pull request #17055: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to…

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17055: URL: https://github.com/apache/flink/pull/17055#issuecomment-908449155 ## CI report: * 84e6a950605ac20acec533be21bf1dcbfc4ac63f Azure:

[GitHub] [flink-training] alpinegizmo commented on a change in pull request #36: [FLINK-23926] one timestamp

2021-09-01 Thread GitBox
alpinegizmo commented on a change in pull request #36: URL: https://github.com/apache/flink-training/pull/36#discussion_r700294637 ## File path: long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java ## @@ -115,31 +115,31 @@

[jira] [Commented] (FLINK-24104) incorrect validation of sink schema

2021-09-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408212#comment-17408212 ] Jark Wu commented on FLINK-24104: - Partial Insert is officially supported since 1.13 via FLINK-18726,

[jira] [Closed] (FLINK-24104) incorrect validation of sink schema

2021-09-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24104. --- Resolution: Not A Problem > incorrect validation of sink schema > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16805: URL: https://github.com/apache/flink/pull/16805#issuecomment-898269056 ## CI report: * d658becaf995317da863a3d9a922923e65265384 UNKNOWN * 842badc4fcd5d74a4e7161fd0e286364edb4 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

2021-09-01 Thread GitBox
Airblader commented on a change in pull request #16598: URL: https://github.com/apache/flink/pull/16598#discussion_r700234951 ## File path: docs/content/docs/connectors/table/pubsub.md ## @@ -0,0 +1,145 @@ +--- +title: PubSub +weight: 20 +type: docs +aliases: + -

[jira] [Comment Edited] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS

2021-09-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408209#comment-17408209 ] Matthias edited comment on FLINK-24112 at 9/1/21, 2:50 PM: --- The workaround

[jira] [Updated] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS

2021-09-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24112: - Labels: test-stability (was: ) > Embedded MariaDB cannot be instantiated on MacOS >

[jira] [Commented] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-09-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408210#comment-17408210 ] Robert Metzger commented on FLINK-22262: I understand that the lifecycle for HA-configmaps is

[jira] [Commented] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS

2021-09-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408209#comment-17408209 ] Matthias commented on FLINK-24112: -- The workaround from the MariaDB4J #48 issue with creating symlinks

[jira] [Updated] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS

2021-09-01 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24112: - Description: {{UnsignedTypeConversionITCase}} fails when executing it locally on MacOS. It fails to

[jira] [Created] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS

2021-09-01 Thread Matthias (Jira)
Matthias created FLINK-24112: Summary: Embedded MariaDB cannot be instantiated on MacOS Key: FLINK-24112 URL: https://issues.apache.org/jira/browse/FLINK-24112 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #17102: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay

2021-09-01 Thread GitBox
flinkbot commented on pull request #17102: URL: https://github.com/apache/flink/pull/17102#issuecomment-910345963 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

[jira] [Created] (FLINK-24111) UnsignedTypeConversionITCase fails locally

2021-09-01 Thread Nicolaus Weidner (Jira)
Nicolaus Weidner created FLINK-24111: Summary: UnsignedTypeConversionITCase fails locally Key: FLINK-24111 URL: https://issues.apache.org/jira/browse/FLINK-24111 Project: Flink Issue

[GitHub] [flink] akalash commented on a change in pull request #17102: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay

2021-09-01 Thread GitBox
akalash commented on a change in pull request #17102: URL: https://github.com/apache/flink/pull/17102#discussion_r700272244 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceUtil.java ## @@ -26,21 +26,22 @@

[jira] [Commented] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

2021-09-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408201#comment-17408201 ] Piotr Nowojski commented on FLINK-23960: I don't think that it's only record specific. Instead

[jira] [Updated] (FLINK-24110) Filter null ComponentJsonObjects

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24110: --- Labels: pull-request-available (was: ) > Filter null ComponentJsonObjects >

[jira] [Updated] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23960: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink-statefun] sjwiesman opened a new pull request #266: [FLINK-24110] Filter null ComponentJsonObjects

2021-09-01 Thread GitBox
sjwiesman opened a new pull request #266: URL: https://github.com/apache/flink-statefun/pull/266 Trailing `---` in the new module.yaml format are interpreted as null `JsonNode`'s. This change filter's them out to avoid confusing error messages. -- This is an automated message

[GitHub] [flink] akalash opened a new pull request #17102: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay

2021-09-01 Thread GitBox
akalash opened a new pull request #17102: URL: https://github.com/apache/flink/pull/17102 ## What is the purpose of the change *PR fixes the checkScheduledTimestamps test* ## Brief change log - *Removed usage of currentTimeMillis without a shift in

[jira] [Updated] (FLINK-24109) Correct egress string serialization

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24109: --- Labels: pull-request-available (was: ) > Correct egress string serialization >

[GitHub] [flink] flinkbot commented on pull request #17100: [FLINK-23916][python][docs] Expose in python and update the documentation how to set tolerable checkpoint failure number

2021-09-01 Thread GitBox
flinkbot commented on pull request #17100: URL: https://github.com/apache/flink/pull/17100#issuecomment-910340813 ## CI report: * 116156113d25199e29cf8e634a838d7612ea0585 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-statefun] sjwiesman opened a new pull request #265: [FLINK-24109] Correct egress string serialization

2021-09-01 Thread GitBox
sjwiesman opened a new pull request #265: URL: https://github.com/apache/flink-statefun/pull/265 Fixes serialization of golang SDK egress builders to always use the utf-8 encoding of strings. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #17098: [FLINK-15648][flink-kubernetes] Support to configure limit for CPU

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17098: URL: https://github.com/apache/flink/pull/17098#issuecomment-910306059 ## CI report: * 30adc0167d8a87246aee7c66b0ae55013efa5462 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17099: URL: https://github.com/apache/flink/pull/17099#issuecomment-910306209 ## CI report: * 895ca9d447a31e81880fdb85039b4d466900804e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17073: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17073: URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473 ## CI report: * 1f35a59a99ab5a57027603ceb8681062c57d498f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16995: [FLINK-22002][tests] Let taskmanager.slot.timeout fall back to akka.ask.timeout

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16995: URL: https://github.com/apache/flink/pull/16995#issuecomment-906282886 ## CI report: * 62b66e5d65f2ddc33956b31e11ab9e01cb1c2199 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * f51e8b846e00a7d5269a0689ac6e6d9d458d2bf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 051a2339b7798da551af17ec6eaa25b5e89b365d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16941: [FLINK-23839][connectors-kafka] Give a more descriptive warnings on I…

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16941: URL: https://github.com/apache/flink/pull/16941#issuecomment-903708623 ## CI report: * f8e78e3bb1920f352374d51a909747816e5e1761 Azure:

[jira] [Closed] (FLINK-23797) SavepointITCase.testStopSavepointWithBoundedInput fails on azure

2021-09-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23797. -- Resolution: Fixed merged commit c7bf8b3 into apache:master merged as 856c927ba93 into

[jira] [Updated] (FLINK-23797) SavepointITCase.testStopSavepointWithBoundedInput fails on azure

2021-09-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23797: --- Affects Version/s: 1.15.0 > SavepointITCase.testStopSavepointWithBoundedInput fails on

[jira] [Updated] (FLINK-23797) SavepointITCase.testStopSavepointWithBoundedInput fails on azure

2021-09-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23797: --- Fix Version/s: 1.15.0 > SavepointITCase.testStopSavepointWithBoundedInput fails on azure >

[GitHub] [flink] pnowojski commented on a change in pull request #17081: [FLINK-23797][tests] Wait for all task running before savepoint for a…

2021-09-01 Thread GitBox
pnowojski commented on a change in pull request #17081: URL: https://github.com/apache/flink/pull/17081#discussion_r700263724 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java ## @@ -206,6 +206,7 @@ private void

[GitHub] [flink] pnowojski merged pull request #17081: [FLINK-23797][tests] Wait for all task running before savepoint for a…

2021-09-01 Thread GitBox
pnowojski merged pull request #17081: URL: https://github.com/apache/flink/pull/17081 -- 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-24110) Filter null ComponentJsonObjects

2021-09-01 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-24110: Summary: Filter null ComponentJsonObjects Key: FLINK-24110 URL: https://issues.apache.org/jira/browse/FLINK-24110 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24109) Correct egress string serialization

2021-09-01 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-24109: Summary: Correct egress string serialization Key: FLINK-24109 URL: https://issues.apache.org/jira/browse/FLINK-24109 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #17101: Update yarn.md

2021-09-01 Thread GitBox
flinkbot commented on pull request #17101: URL: https://github.com/apache/flink/pull/17101#issuecomment-910322196 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 #17100: [FLINK-23916][python][docs] Expose in python and update the documentation how to set tolerable checkpoint failure number

2021-09-01 Thread GitBox
flinkbot commented on pull request #17100: URL: https://github.com/apache/flink/pull/17100#issuecomment-910319839 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 a change in pull request #17055: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to…

2021-09-01 Thread GitBox
akalash commented on a change in pull request #17055: URL: https://github.com/apache/flink/pull/17055#discussion_r700246383 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -1264,6 +1265,42 @@ public void

[GitHub] [flink] datayjz opened a new pull request #17101: Update yarn.md

2021-09-01 Thread GitBox
datayjz opened a new pull request #17101: URL: https://github.com/apache/flink/pull/17101 remove "test" link. ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we

[jira] [Updated] (FLINK-23916) Add documentation for how to configure the CheckpointFailureManager

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23916: --- Labels: pull-request-available (was: ) > Add documentation for how to configure the

[GitHub] [flink] pnowojski opened a new pull request #17100: [FLINK-23916][python][docs] Expose in python and update the documentation how to set tolerable checkpoint failure number

2021-09-01 Thread GitBox
pnowojski opened a new pull request #17100: URL: https://github.com/apache/flink/pull/17100 This PR adds python API and updates the docs for setting the tolerable number of checkpoint failures. ## Does this pull request potentially affect one of the following parts: -

[GitHub] [flink] akalash commented on a change in pull request #17081: [FLINK-23797][tests] Wait for all task running before savepoint for a…

2021-09-01 Thread GitBox
akalash commented on a change in pull request #17081: URL: https://github.com/apache/flink/pull/17081#discussion_r700242348 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java ## @@ -206,6 +206,7 @@ private void

[GitHub] [flink] flinkbot commented on pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
flinkbot commented on pull request #17099: URL: https://github.com/apache/flink/pull/17099#issuecomment-910306209 ## CI report: * 895ca9d447a31e81880fdb85039b4d466900804e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17098: [FLINK-15648][flink-kubernetes] Support to configure limit for CPU

2021-09-01 Thread GitBox
flinkbot commented on pull request #17098: URL: https://github.com/apache/flink/pull/17098#issuecomment-910306059 ## CI report: * 30adc0167d8a87246aee7c66b0ae55013efa5462 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17075: URL: https://github.com/apache/flink/pull/17075#issuecomment-909241018 ## CI report: * b82cefc42d4ba12493f3ee1783fd1feff00cc858 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16941: [FLINK-23839][connectors-kafka] Give a more descriptive warnings on I…

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16941: URL: https://github.com/apache/flink/pull/16941#issuecomment-903708623 ## CI report: * f8e78e3bb1920f352374d51a909747816e5e1761 Azure:

[jira] [Commented] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

2021-09-01 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408182#comment-17408182 ] Anton Kalashnikov commented on FLINK-23960: --- [~pnowojski], thanks for explanation. But now I

[GitHub] [flink] dannycranmer commented on a change in pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-09-01 Thread GitBox
dannycranmer commented on a change in pull request #17040: URL: https://github.com/apache/flink/pull/17040#discussion_r700155763 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBase.java ## @@ -0,0 +1,69 @@ +/* +

[jira] [Commented] (FLINK-24107) StateFun doesn't open correctly in intellij when started with JDK11

2021-09-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408176#comment-17408176 ] Chesnay Schepler commented on FLINK-24107: -- Why is that a problem though? The benefit is that

[jira] [Assigned] (FLINK-23916) Add documentation for how to configure the CheckpointFailureManager

2021-09-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-23916: -- Assignee: Piotr Nowojski > Add documentation for how to configure the

[jira] [Commented] (FLINK-23896) The new KafkaSink drops data if job fails between checkpoint and transaction commit.

2021-09-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408166#comment-17408166 ] Arvid Heise commented on FLINK-23896: - [~ruanhang1993] manually verified that this particular issue

[GitHub] [flink] flinkbot edited a comment on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-907834154 ## CI report: * 752c9db951f0ba3f26695b873b1f81dc6e830cab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 371e8744569d180669b538e27bcdd355914571a6 Azure:

[jira] [Updated] (FLINK-24107) StateFun doesn't open correctly in intellij when started with JDK11

2021-09-01 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-24107: - Priority: Minor (was: Major) > StateFun doesn't open correctly in intellij when started with

[jira] [Assigned] (FLINK-24107) StateFun doesn't open correctly in intellij when started with JDK11

2021-09-01 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-24107: Assignee: (was: Igal Shilman) > StateFun doesn't open correctly in intellij when

[GitHub] [flink] flinkbot edited a comment on pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16805: URL: https://github.com/apache/flink/pull/16805#issuecomment-898269056 ## CI report: * d658becaf995317da863a3d9a922923e65265384 UNKNOWN * 842badc4fcd5d74a4e7161fd0e286364edb4 Azure:

[jira] [Updated] (FLINK-24108) Translate KafkaSink documentation to Chinese

2021-09-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24108: Description: A few things have changed that should all be synced. In particular: - Metrics of

[jira] [Updated] (FLINK-24108) Translate KafkaSink documentation to Chinese

2021-09-01 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24108: Labels: documentation (was: ) > Translate KafkaSink documentation to Chinese >

[jira] [Created] (FLINK-24108) Translate KafkaSink documentation to Chinese

2021-09-01 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-24108: --- Summary: Translate KafkaSink documentation to Chinese Key: FLINK-24108 URL: https://issues.apache.org/jira/browse/FLINK-24108 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
flinkbot commented on pull request #17099: URL: https://github.com/apache/flink/pull/17099#issuecomment-910270313 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 #17098: [FLINK-15648] [flink-kubernetes]: Support to configure limit for CPU

2021-09-01 Thread GitBox
flinkbot commented on pull request #17098: URL: https://github.com/apache/flink/pull/17098#issuecomment-910268170 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

[jira] [Updated] (FLINK-24106) Remove notice that python does not support state TTL

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24106: --- Labels: pull-request-available (was: ) > Remove notice that python does not support state

[GitHub] [flink] Myasuka opened a new pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
Myasuka opened a new pull request #17099: URL: https://github.com/apache/flink/pull/17099 ## What is the purpose of the change Remove notice that pyflink does not support state TTL. ## Brief change log ## Verifying this change This change is a trivial

[GitHub] [flink] dmvk commented on pull request #16941: [FLINK-23839][connectors-kafka] Give a more descriptive warnings on I…

2021-09-01 Thread GitBox
dmvk commented on pull request #16941: URL: https://github.com/apache/flink/pull/16941#issuecomment-910266387 @NicoK @autophagy Thanks for the review! I've addressed your comments, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Assigned] (FLINK-24106) Remove notice that python does not support state TTL

2021-09-01 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24106: Assignee: Yun Tang > Remove notice that python does not support state TTL >

[jira] [Updated] (FLINK-15648) Support to configure limit for CPU and memory requirement

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15648: --- Labels: pull-request-available (was: ) > Support to configure limit for CPU and memory

[jira] [Assigned] (FLINK-24107) StateFun doesn't open correctly in intellij when started with JDK11

2021-09-01 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-24107: Assignee: Igal Shilman > StateFun doesn't open correctly in intellij when started with

[jira] [Created] (FLINK-24107) StateFun doesn't open correctly in intellij when started with JDK11

2021-09-01 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-24107: Summary: StateFun doesn't open correctly in intellij when started with JDK11 Key: FLINK-24107 URL: https://issues.apache.org/jira/browse/FLINK-24107 Project: Flink

[GitHub] [flink] dnutiu opened a new pull request #17098: [FLINK-15648] [flink-kubernetes]: Support to configure limit for CPU

2021-09-01 Thread GitBox
dnutiu opened a new pull request #17098: URL: https://github.com/apache/flink/pull/17098 ## What is the purpose of the change The purpose of this PR is to allow the user to configure the Taskmanager's and Jobmanager's CPU limits when deploying Flink using the Kubernetes Resource

[GitHub] [flink] dmvk commented on a change in pull request #16941: [FLINK-23839][connectors-kafka] Give a more descriptive warnings on I…

2021-09-01 Thread GitBox
dmvk commented on a change in pull request #16941: URL: https://github.com/apache/flink/pull/16941#discussion_r700189496 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java ## @@ -1355,6

[GitHub] [flink] twalthr commented on a change in pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

2021-09-01 Thread GitBox
twalthr commented on a change in pull request #16805: URL: https://github.com/apache/flink/pull/16805#discussion_r700189785 ## File path: flink-python/pyflink/table/tests/test_expression.py ## @@ -19,7 +19,7 @@ from pyflink.table import DataTypes from

[jira] [Commented] (FLINK-24024) Fix syntax mistake in session Window TVF

2021-09-01 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408153#comment-17408153 ] Timo Walther commented on FLINK-24024: -- [~qingru zhang] Let's move this discussion on the mailing

[jira] [Commented] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

2021-09-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408152#comment-17408152 ] Piotr Nowojski commented on FLINK-24086: Can you elaborate what do you mean by: {quote} We

[GitHub] [flink] dmvk commented on a change in pull request #16941: [FLINK-23839][connectors-kafka] Give a more descriptive warnings on I…

2021-09-01 Thread GitBox
dmvk commented on a change in pull request #16941: URL: https://github.com/apache/flink/pull/16941#discussion_r700183491 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java ## @@ -61,13 +62,25 @@ private

[jira] [Created] (FLINK-24106) Remove notice that python does not support state TTL

2021-09-01 Thread Yun Tang (Jira)
Yun Tang created FLINK-24106: Summary: Remove notice that python does not support state TTL Key: FLINK-24106 URL: https://issues.apache.org/jira/browse/FLINK-24106 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24105) state TTL might not take effect for pyflink

2021-09-01 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24105: - Parent: FLINK-23822 Issue Type: Sub-task (was: Bug) > state TTL might not take effect for

[jira] [Created] (FLINK-24105) state TTL might not take effect for pyflink

2021-09-01 Thread Yun Tang (Jira)
Yun Tang created FLINK-24105: Summary: state TTL might not take effect for pyflink Key: FLINK-24105 URL: https://issues.apache.org/jira/browse/FLINK-24105 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17090: URL: https://github.com/apache/flink/pull/17090#issuecomment-909842676 ## CI report: * fbf565cf0173162a227bafad913398138d02af23 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17097: [FLINK-24047][tests] Retry if leader election is in progress

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17097: URL: https://github.com/apache/flink/pull/17097#issuecomment-910200050 ## CI report: * 9b27cc0b4a03e389b297eb3325328bc73726042e UNKNOWN * 29fd058bb1bcb381b1b6d7420d5a019a56d67dda Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17075: URL: https://github.com/apache/flink/pull/17075#issuecomment-909241018 ## CI report: * a44ab55d1d4b86781f25b2367d2443850d5705be Azure:

[GitHub] [flink] tillrohrmann commented on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

2021-09-01 Thread GitBox
tillrohrmann commented on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-910251066 Sounds good. The problem should not block the release because it was not introduced recently. -- This is an automated message from the Apache Git Service. To respond to

<    1   2   3   4   5   6   7   8   >