[GitHub] [flink] akalash commented on pull request #15221: [FLINK-17012][streaming] 'RUNNING' state split into 'RUNNING' and 'RE…

2021-06-18 Thread GitBox
akalash commented on pull request #15221: URL: https://github.com/apache/flink/pull/15221#issuecomment-864007286 I created this ticket - https://issues.apache.org/jira/browse/FLINK-23034. And I already have a PR - https://github.com/apache/flink/pull/16199. @zentol if you have time can you

[GitHub] [flink] gaoyunhaii commented on pull request #16194: [FLINK-21952][network] Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

2021-06-18 Thread GitBox
gaoyunhaii commented on pull request #16194: URL: https://github.com/apache/flink/pull/16194#issuecomment-864130044 Very thanks @pnowojski for the review~ -- 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-statefun] austince commented on pull request #240: [hotfix] Correct endpoint definition in docs

2021-06-18 Thread GitBox
austince commented on pull request #240: URL: https://github.com/apache/flink-statefun/pull/240#issuecomment-864020944 -- 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. For q

[GitHub] [flink] flinkbot edited a comment on pull request #16190: [FLINK-23027] Move chill dependency to flink-scala

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16190: URL: https://github.com/apache/flink/pull/16190#issuecomment-863803503 -- 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. For

[GitHub] [flink] flinkbot edited a comment on pull request #16202: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16202: URL: https://github.com/apache/flink/pull/16202#issuecomment-864077519 -- 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. For

[GitHub] [flink] flinkbot edited a comment on pull request #16151: [FLINK-22593][tests] Waiting for all tasks running before triggering …

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16151: URL: https://github.com/apache/flink/pull/16151#issuecomment-859691952 ## CI report: * 72a0fb3c6c8f8568d30ab8ff58d643776e03a963 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

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

[GitHub] [flink] gaoyunhaii opened a new pull request #16194: [FLINK-21952] Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

2021-06-18 Thread GitBox
gaoyunhaii opened a new pull request #16194: URL: https://github.com/apache/flink/pull/16194 ## What is the purpose of the change This PR fixes the bug that wrongly wrap the Netty connection reset exception as `LocalTransportException`. ## Brief change log - 6252cb5c4d9

[GitHub] [flink] flinkbot edited a comment on pull request #16193: [FLINK-23030][network] PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16193: URL: https://github.com/apache/flink/pull/16193#issuecomment-863860115 -- 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. For

[GitHub] [flink] flinkbot edited a comment on pull request #16185: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16185: URL: https://github.com/apache/flink/pull/16185#issuecomment-863252396 ## CI report: * 99220a46a01b73ddbb8cc603b1d24b1f8e3279e5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] igalshilman commented on pull request #240: [hotfix] Correct endpoint definition in docs

2021-06-18 Thread GitBox
igalshilman commented on pull request #240: URL: https://github.com/apache/flink-statefun/pull/240#issuecomment-864030673 -- 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. Fo

[GitHub] [flink] dannycranmer opened a new pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

2021-06-18 Thread GitBox
dannycranmer opened a new pull request #16206: URL: https://github.com/apache/flink/pull/16206 ## What is the purpose of the change Fixing bad shading of AWS SDK config file resulting in errors when consuming from EFO. This is cause by the recent SDK upgrade: https://github.com/apac

[GitHub] [flink-web] sjwiesman closed pull request #451: [FLINK-23038][docs] fix glossary link

2021-06-18 Thread GitBox
sjwiesman closed pull request #451: URL: https://github.com/apache/flink-web/pull/451 -- 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. For queries about this service, plea

[GitHub] [flink] flinkbot edited a comment on pull request #16192: [Flink-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16192: URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019 ## CI report: * 479051d3a1aac6b25cb7307de8791044c66b7872 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pnowojski merged pull request #16174: [FLINK-22946][runtime] Recycle floating buffer outside the lock to avoid deadlock

2021-06-18 Thread GitBox
pnowojski merged pull request #16174: URL: https://github.com/apache/flink/pull/16174 -- 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. For queries about this service, plea

[GitHub] [flink] flinkbot commented on pull request #16199: [FLINK-23034][runtime] Added compatibility for ExecutionState in Hist…

2021-06-18 Thread GitBox
flinkbot commented on pull request #16199: URL: https://github.com/apache/flink/pull/16199#issuecomment-864006883 -- 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. For querie

[GitHub] [flink] flinkbot edited a comment on pull request #14820: [FLINK-21085][runtime][checkpoint] Allows triggering checkpoint for non-source tasks

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #14820: URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711 -- 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. For

[GitHub] [flink] rmetzger merged pull request #16181: [BP-1.13][FLINK-22980][tests] Set parallelism on job vertex required by adapti…

2021-06-18 Thread GitBox
rmetzger merged pull request #16181: URL: https://github.com/apache/flink/pull/16181 -- 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. For queries about this service, pleas

[GitHub] [flink] flinkbot commented on pull request #16188: [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable

2021-06-18 Thread GitBox
flinkbot commented on pull request #16188: URL: https://github.com/apache/flink/pull/16188#issuecomment-863705522 -- 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. For querie

[GitHub] [flink] flinkbot edited a comment on pull request #16197: [FLINK-22662][yarn][test] Add logs for YARNHighAvailabilityITCase

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16197: URL: https://github.com/apache/flink/pull/16197#issuecomment-863935872 -- 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. For

[GitHub] [flink] MyLanPangzi opened a new pull request #16189: [hotfix][docs] libs cep Remove redundant sentences

2021-06-18 Thread GitBox
MyLanPangzi opened a new pull request #16189: URL: https://github.com/apache/flink/pull/16189 ## 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 avoid re-transferring the

[GitHub] [flink] fapaul commented on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

2021-06-18 Thread GitBox
fapaul commented on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-864009515 @cmick I have set up a proper integration and added a test for the stop with savepoint capability https://github.com/apache/flink/commit/661d6f8bd17fdf1d5c0307aea1161f374006151e

[GitHub] [flink] Myasuka commented on a change in pull request #16178: [FLINK-23018][state] Enable TTL state factory to handle extended state descriptors

2021-06-18 Thread GitBox
Myasuka commented on a change in pull request #16178: URL: https://github.com/apache/flink/pull/16178#discussion_r654272322 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java ## @@ -97,37 +96,35 @@ private TtlStateFactory(

[GitHub] [flink] zentol opened a new pull request #16190: [FLINK-23027] Move chill dependency to flink-scala

2021-06-18 Thread GitBox
zentol opened a new pull request #16190: URL: https://github.com/apache/flink/pull/16190 -- 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. For queries about this service, p

[GitHub] [flink] flinkbot edited a comment on pull request #16084: [FLINK-22518][docs] Translate the page of "High Availability (HA)" in…

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16084: URL: https://github.com/apache/flink/pull/16084#issuecomment-855421865 -- 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. For

[GitHub] [flink] Myasuka commented on a change in pull request #16035: [FLINK-22808][state/changelog] Log metadata

2021-06-18 Thread GitBox
Myasuka commented on a change in pull request #16035: URL: https://github.com/apache/flink/pull/16035#discussion_r654110979 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/StateChangeLoggerTestBase.java ## @@ -0,0

[GitHub] [flink] tinawenqiao commented on a change in pull request #16183: [FLINK-22974][dist] Add execution checkpointing related configs in flink-conf.yaml

2021-06-18 Thread GitBox
tinawenqiao commented on a change in pull request #16183: URL: https://github.com/apache/flink/pull/16183#discussion_r654185324 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -107,7 +107,18 @@ parallelism.default: 1 #=

[jira] [Updated] (FLINK-23037) Document limitations of UC

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23037: --- Labels: pull-request-available (was: ) > Document limitations of UC > -

[GitHub] [flink] flinkbot commented on pull request #16192: [Flink-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

2021-06-18 Thread GitBox
flinkbot commented on pull request #16192: URL: https://github.com/apache/flink/pull/16192#issuecomment-863830293 -- 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. For querie

[GitHub] [flink] iemre commented on pull request #16195: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
iemre commented on pull request #16195: URL: https://github.com/apache/flink/pull/16195#issuecomment-864077045 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific co

[GitHub] [flink] flinkbot edited a comment on pull request #16203: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16203: URL: https://github.com/apache/flink/pull/16203#issuecomment-864077645 -- 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. For

[GitHub] [flink] flinkbot edited a comment on pull request #16200: [FLINK-23037][docs] Document limitations of unaligned checkpoints

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16200: URL: https://github.com/apache/flink/pull/16200#issuecomment-864052927 ## CI report: * 920b4ccb1cb9246264e38fc30310f89dae5389f2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pnowojski merged pull request #16151: [FLINK-22593][tests] Waiting for all tasks running before triggering …

2021-06-18 Thread GitBox
pnowojski merged pull request #16151: URL: https://github.com/apache/flink/pull/16151 -- 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. For queries about this service, plea

[GitHub] [flink] dawidwys commented on a change in pull request #16135: [FLINK-22961][streaming] firstBarrierArrivalTime is recalculated when…

2021-06-18 Thread GitBox
dawidwys commented on a change in pull request #16135: URL: https://github.com/apache/flink/pull/16135#discussion_r654245153 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/SingleCheckpointBarrierHandler.java ## @@ -255,7 +2

[GitHub] [flink] flinkbot commented on pull request #16200: [FLINK-23037][docs] Document limitations of unaligned checkpoints

2021-06-18 Thread GitBox
flinkbot commented on pull request #16200: URL: https://github.com/apache/flink/pull/16200#issuecomment-864037440 -- 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. For querie

[GitHub] [flink] flinkbot commented on pull request #16189: [hotfix][docs] libs cep Remove redundant sentences

2021-06-18 Thread GitBox
flinkbot commented on pull request #16189: URL: https://github.com/apache/flink/pull/16189#issuecomment-863710691 -- 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. For querie

[GitHub] [flink] xintongsong closed pull request #16197: [FLINK-22662][yarn][test] Add logs for YARNHighAvailabilityITCase

2021-06-18 Thread GitBox
xintongsong closed pull request #16197: URL: https://github.com/apache/flink/pull/16197 -- 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. For queries about this service, pl

[GitHub] [flink] flinkbot edited a comment on pull request #16199: [FLINK-23034][runtime] Added compatibility for ExecutionState in Hist…

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16199: URL: https://github.com/apache/flink/pull/16199#issuecomment-864014078 -- 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. For

[GitHub] [flink] flinkbot commented on pull request #16193: [FLINK-23030][network] PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

2021-06-18 Thread GitBox
flinkbot commented on pull request #16193: URL: https://github.com/apache/flink/pull/16193#issuecomment-863835340 -- 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. For querie

[GitHub] [flink] akalash commented on pull request #16135: [FLINK-22961][streaming] firstBarrierArrivalTime is recalculated when…

2021-06-18 Thread GitBox
akalash commented on pull request #16135: URL: https://github.com/apache/flink/pull/16135#issuecomment-863942914 -- 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. For queries

[GitHub] [flink] dannycranmer opened a new pull request #16203: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
dannycranmer opened a new pull request #16203: URL: https://github.com/apache/flink/pull/16203 ## What is the purpose of the change Update AWS SDK v1 and v2 and DynamoDB Streams Kinesis adapter to latest version ## Brief change log Bumped: - AWS SDK v1 from `1.11.754

[GitHub] [flink] rkhachatryan commented on a change in pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

2021-06-18 Thread GitBox
rkhachatryan commented on a change in pull request #15420: URL: https://github.com/apache/flink/pull/15420#discussion_r654382931 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/restore/AggregatingStateChangeApplier.java ##

[GitHub] [flink] iemre commented on pull request #16196: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
iemre commented on pull request #16196: URL: https://github.com/apache/flink/pull/16196#issuecomment-864076637 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific co

[GitHub] [flink] flinkbot commented on pull request #16196: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
flinkbot commented on pull request #16196: URL: https://github.com/apache/flink/pull/16196#issuecomment-863896043 -- 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. For querie

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-06-18 Thread GitBox
tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r654337428 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] flinkbot edited a comment on pull request #16186: [hotfix][docs] Fix groupBy() javadocs

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16186: URL: https://github.com/apache/flink/pull/16186#issuecomment-863331453 ## CI report: * 2e28354d8d5190e1a88d4f5af20bff7b6d3eed14 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16189: [hotfix][docs] libs cep Remove redundant sentences

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16189: URL: https://github.com/apache/flink/pull/16189#issuecomment-863713861 -- 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. For

[GitHub] [flink] Zakelly commented on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-18 Thread GitBox
Zakelly commented on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-863947779 @Myasuka , thanks for the review! Would you mind taking another look? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] dawidwys commented on a change in pull request #14820: [FLINK-21085][runtime][checkpoint] Allows triggering checkpoint for non-source tasks

2021-06-18 Thread GitBox
dawidwys commented on a change in pull request #14820: URL: https://github.com/apache/flink/pull/14820#discussion_r654200272 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java ## @@ -175,10 +176,23 @@ protecte

[GitHub] [flink] iemre commented on pull request #16204: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
iemre commented on pull request #16204: URL: https://github.com/apache/flink/pull/16204#issuecomment-864063410 @flinkbot approve all -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] dawidwys opened a new pull request #16200: [FLINK-23037][docs] Document limitations of unaligned checkpoints

2021-06-18 Thread GitBox
dawidwys opened a new pull request #16200: URL: https://github.com/apache/flink/pull/16200 ## What is the purpose of the change Add limitations of UC. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] zentol commented on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

2021-06-18 Thread GitBox
zentol commented on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-864223124 -- 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. For queries

[GitHub] [flink] GuokuaiHuang removed a comment on pull request #16174: [FLINK-22946][runtime] Recycle floating buffer outside the lock to avoid deadlock

2021-06-18 Thread GitBox
GuokuaiHuang removed a comment on pull request #16174: URL: https://github.com/apache/flink/pull/16174#issuecomment-862898471 @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

[GitHub] [flink] dawidwys commented on pull request #16135: [FLINK-22961][streaming] firstBarrierArrivalTime is recalculated when…

2021-06-18 Thread GitBox
dawidwys commented on pull request #16135: URL: https://github.com/apache/flink/pull/16135#issuecomment-863877226 -- 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. For querie

[GitHub] [flink-statefun] igalshilman closed pull request #240: [hotfix] Correct endpoint definition in docs

2021-06-18 Thread GitBox
igalshilman closed pull request #240: URL: https://github.com/apache/flink-statefun/pull/240 -- 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. For queries about this servic

[GitHub] [flink] twalthr closed pull request #16150: [FLINK-22878][core] Allow prefix syntax for ConfigOption.mapType

2021-06-18 Thread GitBox
twalthr closed pull request #16150: URL: https://github.com/apache/flink/pull/16150 -- 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. For queries about this service, please

[GitHub] [flink] dannycranmer merged pull request #16185: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
dannycranmer merged pull request #16185: URL: https://github.com/apache/flink/pull/16185 -- 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. For queries about this service, p

[GitHub] [flink] iemre opened a new pull request #16195: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis (1.13)

2021-06-18 Thread GitBox
iemre opened a new pull request #16195: URL: https://github.com/apache/flink/pull/16195 ## What is the purpose of the change Upgrade Guava dependency for Flink Connector Kinesis. The connector was using Guava 18.0 which is quite old and has been flagged by some security tools

[GitHub] [flink] chaplinthink opened a new pull request #16198: [hotfix] Improve tuple equal code logic

2021-06-18 Thread GitBox
chaplinthink opened a new pull request #16198: URL: https://github.com/apache/flink/pull/16198 ## What is the purpose of the change *Make the tuple equals() method code logic simpler and improve readability* ## Brief change log *(for example:)* - *The TaskI

[GitHub] [flink] flinkbot edited a comment on pull request #16195: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16195: URL: https://github.com/apache/flink/pull/16195#issuecomment-863912826 -- 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. For

[GitHub] [flink] dannycranmer commented on a change in pull request #16187: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
dannycranmer commented on a change in pull request #16187: URL: https://github.com/apache/flink/pull/16187#discussion_r654255130 ## File path: flink-connectors/flink-sql-connector-kinesis/pom.xml ## @@ -35,17 +35,6 @@ under the License. jar - -

[GitHub] [flink] wenlong88 opened a new pull request #16192: [Flink-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

2021-06-18 Thread GitBox
wenlong88 opened a new pull request #16192: URL: https://github.com/apache/flink/pull/16192 ## What is the purpose of the change this pr trying to fix FLINK-22954 by rewriting join on constant table function scan to Correlate. ## Brief change log - *add a new rewrite rule

[GitHub] [flink] flinkbot edited a comment on pull request #16070: [FLINK-23028][docs] Improve documentation for pages of SQL.

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16070: URL: https://github.com/apache/flink/pull/16070#issuecomment-853843273 -- 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. For

[GitHub] [flink] rkhachatryan commented on a change in pull request #16035: [FLINK-22808][state/changelog] Log metadata

2021-06-18 Thread GitBox
rkhachatryan commented on a change in pull request #16035: URL: https://github.com/apache/flink/pull/16035#discussion_r654257598 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/StateChangeLoggerTestBase.java ## @@

[GitHub] [flink] flinkbot commented on pull request #16203: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
flinkbot commented on pull request #16203: URL: https://github.com/apache/flink/pull/16203#issuecomment-864053843 -- 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. For querie

[GitHub] [flink] flinkbot edited a comment on pull request #16135: [FLINK-22961][streaming] firstBarrierArrivalTime is recalculated when…

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16135: URL: https://github.com/apache/flink/pull/16135#issuecomment-858597022 -- 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. For

[GitHub] [flink] KarmaGYZ commented on pull request #16188: [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable

2021-06-18 Thread GitBox
KarmaGYZ commented on pull request #16188: URL: https://github.com/apache/flink/pull/16188#issuecomment-863710513 Verified in my local env. -- 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 sp

[GitHub] [flink] GuXiangFly opened a new pull request #16205: [FLINK-18464][Runtime] fix the bug voidnamespace cast to timewindow

2021-06-18 Thread GitBox
GuXiangFly opened a new pull request #16205: URL: https://github.com/apache/flink/pull/16205 ## What is the purpose of the change This PR is to fix the following two issues only RocksDB: https://issues.apache.org/jira/browse/FLINK-18464 https://issues.apache.org/jira/b

[GitHub] [flink] dannycranmer merged pull request #16187: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
dannycranmer merged pull request #16187: URL: https://github.com/apache/flink/pull/16187 -- 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. For queries about this service, p

[GitHub] [flink] flinkbot edited a comment on pull request #16204: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16204: URL: https://github.com/apache/flink/pull/16204#issuecomment-864077792 -- 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. For

[GitHub] [flink] rkhachatryan merged pull request #16035: [FLINK-22808][state/changelog] Log metadata

2021-06-18 Thread GitBox
rkhachatryan merged pull request #16035: URL: https://github.com/apache/flink/pull/16035 -- 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. For queries about this service, p

[GitHub] [flink] tillrohrmann closed pull request #16188: [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable

2021-06-18 Thread GitBox
tillrohrmann closed pull request #16188: URL: https://github.com/apache/flink/pull/16188 -- 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. For queries about this service, p

[GitHub] [flink] dannycranmer opened a new pull request #16202: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
dannycranmer opened a new pull request #16202: URL: https://github.com/apache/flink/pull/16202 ## What is the purpose of the change Update AWS SDK v1 and DynamoDB Streams Kinesis adapter to latest version ## Brief change log Bumped: - AWS SDK v1 from `1.11.754` to `1.

[jira] [Updated] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 -- 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. For

[GitHub] [flink] flinkbot edited a comment on pull request #16122: [FLINK-21195][Connectors/FileSystem]LimitableBulkFormat is invalid wh…

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16122: URL: https://github.com/apache/flink/pull/16122#issuecomment-857643170 -- 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. For

[GitHub] [flink] rkhachatryan commented on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

2021-06-18 Thread GitBox
rkhachatryan commented on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-864015793 Thanks for the review @Zakelly and @Myasuka . I've addressed your comments and rebased the PR: (#15200 was merged, #16035 not yet; please ignore the 1st commit `Log me

[GitHub] [flink] mayuehappy commented on a change in pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

2021-06-18 Thread GitBox
mayuehappy commented on a change in pull request #16171: URL: https://github.com/apache/flink/pull/16171#discussion_r654567336 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy

[GitHub] [flink] flinkbot edited a comment on pull request #16174: [FLINK-22946][runtime] Recycle floating buffer outside the lock to avoid deadlock

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16174: URL: https://github.com/apache/flink/pull/16174#issuecomment-862416996 -- 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. For

[GitHub] [flink] flinkbot commented on pull request #16195: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis (1.13)

2021-06-18 Thread GitBox
flinkbot commented on pull request #16195: URL: https://github.com/apache/flink/pull/16195#issuecomment-863884416 -- 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. For querie

[GitHub] [flink] rmetzger merged pull request #16180: [FLINK-22980][tests] Set parallelism on job vertex required by adapti…

2021-06-18 Thread GitBox
rmetzger merged pull request #16180: URL: https://github.com/apache/flink/pull/16180 -- 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. For queries about this service, pleas

[GitHub] [flink-statefun] austince edited a comment on pull request #240: [hotfix] Correct endpoint definition in docs

2021-06-18 Thread GitBox
austince edited a comment on pull request #240: URL: https://github.com/apache/flink-statefun/pull/240#issuecomment-864066963 @igalshilman ah no worries! just a teeny change :) Thanks for the merge! -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] xintongsong opened a new pull request #16197: [FLINK_22662][yarn][test] Add logs for YARNHighAvailabilityITCase

2021-06-18 Thread GitBox
xintongsong opened a new pull request #16197: URL: https://github.com/apache/flink/pull/16197 ## 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 avoid re-transferring the

[GitHub] [flink] flinkbot commented on pull request #16202: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
flinkbot commented on pull request #16202: URL: https://github.com/apache/flink/pull/16202#issuecomment-864053878 -- 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. For querie

[GitHub] [flink] iemre commented on a change in pull request #16187: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
iemre commented on a change in pull request #16187: URL: https://github.com/apache/flink/pull/16187#discussion_r654254123 ## File path: flink-connectors/flink-sql-connector-kinesis/pom.xml ## @@ -35,17 +35,6 @@ under the License. jar - - -

[GitHub] [flink] flinkbot edited a comment on pull request #16205: [FLINK-18464][Runtime] fix the bug voidnamespace cast to timewindow

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16205: URL: https://github.com/apache/flink/pull/16205#issuecomment-864129076 -- 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. For

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 -- 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. For

[GitHub] [flink] zentol merged pull request #16075: [FLINK-22873][config][docs] Add ToC

2021-06-18 Thread GitBox
zentol merged pull request #16075: URL: https://github.com/apache/flink/pull/16075 -- 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. For queries about this service, please

[GitHub] [flink] zentol merged pull request #16112: [FLINK-20891][metrics][tests] Check that thread is still alive

2021-06-18 Thread GitBox
zentol merged pull request #16112: URL: https://github.com/apache/flink/pull/16112 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 5d6da4236b40ed2a674b94dc92bebaba68a5d0f6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-861345742 ## CI report: * 6384b08bbfd45acd61033c757c1fd4dc6b04530c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-861345742 ## CI report: * 6384b08bbfd45acd61033c757c1fd4dc6b04530c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 5d6da4236b40ed2a674b94dc92bebaba68a5d0f6 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16171: URL: https://github.com/apache/flink/pull/16171#issuecomment-862067374 ## CI report: * 8c57a59392bf2c56235af42bb2847e2f34e7ad34 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22880) Remove "blink" term in code base

2021-06-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22880: --- Labels: stale-assigned (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[jira] [Updated] (FLINK-22865) Optimize state serialize/deserialize in PyFlink

2021-06-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22865: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-11425) Support of “Hash Teams” in Hybrid Hash Join

2021-06-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11425: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

2021-06-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21788: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-19380) Add support for a gRPC transport for the RequestReply protocol.

2021-06-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19380: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

2021-06-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22626: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

<    1   2   3   4   >