[jira] [Updated] (FLINK-23038) Broken link in Documentation Style Guide

2021-06-18 Thread Daisy Tsang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daisy Tsang updated FLINK-23038: Component/s: Documentation > Broken link in Documentation Style Guide > --

[jira] [Created] (FLINK-23039) Support pluggable transports for HTTP endpoints

2021-06-18 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-23039: Summary: Support pluggable transports for HTTP endpoints Key: FLINK-23039 URL: https://issues.apache.org/jira/browse/FLINK-23039 Project: Flink Issue Type: I

[jira] [Updated] (FLINK-22878) Allow prefix syntax for ConfigOption.mapType

2021-06-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22878: - Summary: Allow prefix syntax for ConfigOption.mapType (was: Allow placeholder options in format

[jira] [Closed] (FLINK-22878) Allow prefix syntax for ConfigOption.mapType

2021-06-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22878. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in 1.14.0: 2b64bf4da8866b264ec031e7818460080c

[jira] [Issue Comment Deleted] (FLINK-21229) Support ssl connection with schema registry format

2021-06-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21229: - Comment: was deleted (was: This major issue is unassigned and itself and all of its Sub-Tasks ha

[jira] [Updated] (FLINK-21229) Support ssl connection with schema registry format

2021-06-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21229: - Priority: Major (was: Minor) > Support ssl connection with schema registry format > ---

[jira] [Issue Comment Deleted] (FLINK-21229) Support ssl connection with schema registry format

2021-06-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21229: - Comment: was deleted (was: This issue was labeled "stale-major" 7 ago and has not received any

[jira] [Updated] (FLINK-21229) Support ssl connection with schema registry format

2021-06-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21229: - Labels: pull-request-available (was: auto-deprioritized-major pull-request-available) > Suppor

[jira] [Updated] (FLINK-18182) Upgrade AWS SDK in flink-connector-kinesis to include new region af-south-1

2021-06-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-18182: -- Fix Version/s: 1.13.2 1.12.5 1.14.0 1.

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

2021-06-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365509#comment-17365509 ] Xintong Song commented on FLINK-22662: -- Add logs in - master (1.14): c056a954f0eaf7

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

2021-06-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22980. -- Fix Version/s: 1.13.2 1.14.0 Resolution: Fixed Merged to master in

[jira] [Assigned] (FLINK-23038) Broken link in Documentation Style Guide

2021-06-18 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-23038: -- Assignee: Daisy Tsang > Broken link in Documentation Style Guide > --

[jira] [Created] (FLINK-23040) Consider ConfigOption fallback keys in FactoryUtil

2021-06-18 Thread Timo Walther (Jira)
Timo Walther created FLINK-23040: Summary: Consider ConfigOption fallback keys in FactoryUtil Key: FLINK-23040 URL: https://issues.apache.org/jira/browse/FLINK-23040 Project: Flink Issue Type

[jira] [Updated] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-23009: -- Affects Version/s: (was: 1.13.2) (was: 1.12.5)

[jira] [Updated] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-23009: -- Fix Version/s: 1.13.2 1.12.5 1.14.0 > Bump up Guava in K

[jira] [Updated] (FLINK-22979) JobMasterExecutionDeploymentReconciliationTest error while setting up logger

2021-06-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22979: -- Priority: Critical (was: Major) > JobMasterExecutionDeploymentReconciliationTest error while

[jira] [Updated] (FLINK-23008) Upload file not exist when submit job use RestClient

2021-06-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23008: -- Priority: Minor (was: Major) > Upload file not exist when submit job use RestClient > ---

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

2021-06-18 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365545#comment-17365545 ] Aitozi commented on FLINK-23031: [~jark] I think we can avoid to register new timer in 

[jira] [Created] (FLINK-23041) Change local alignment timeout back to the global time out

2021-06-18 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23041: - Summary: Change local alignment timeout back to the global time out Key: FLINK-23041 URL: https://issues.apache.org/jira/browse/FLINK-23041 Project: Flink

[jira] [Resolved] (FLINK-22808) Log metadata

2021-06-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-22808. --- Resolution: Fixed Merged into master as b31f4bde84caa4664cfa305f7890c9a35ff43821. >

[jira] [Updated] (FLINK-23038) Broken link in Documentation Style Guide

2021-06-18 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-23038: - Component/s: (was: Documentation) Project Website > Broken link in Document

[jira] [Commented] (FLINK-23038) Broken link in Documentation Style Guide

2021-06-18 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365675#comment-17365675 ] Seth Wiesman commented on FLINK-23038: -- fixed in: ca9f1ca660c5ca79269dfd3f7a4e041aa

[jira] [Closed] (FLINK-23038) Broken link in Documentation Style Guide

2021-06-18 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-23038. Resolution: Fixed > Broken link in Documentation Style Guide > ---

[jira] [Closed] (FLINK-21085) Refactor StreamTask hierarchy to support triggering checkpoint via RPC for non-source tasks

2021-06-18 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21085. Fix Version/s: 1.14.0 Assignee: Yun Gao Resolution: Implemented Implemente

[jira] [Updated] (FLINK-20891) SystemResourcesCounterTest may caused endless loop when some error occured

2021-06-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20891: --- Component/s: Runtime / Metrics > SystemResourcesCounterTest may caused endless loop when so

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

2021-06-18 Thread GitBox
mayuehappy commented on pull request #16171: URL: https://github.com/apache/flink/pull/16171#issuecomment-863938479 @rkhachatryan Thanks again for your review . i have drop the commit (363c912) and the new `RocksDBStateUploader` was passed in TestCase (although it took some minor chang

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

2021-06-18 Thread GitBox
tweise commented on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-863950202 @AHeise @stevenzwu PTAL * Sources are now pushed dynamically to readers, this would later also allow sources to be discovered or configured dynamically (with a different enumer

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

2021-06-18 Thread GitBox
Myasuka commented on pull request #16084: URL: https://github.com/apache/flink/pull/16084#issuecomment-863797555 @movesan , thanks for your update! However, the commit message is still not full and clean, it should not be `[FLINK-22518][docs] Translate the page of "High Availability (HA)

[GitHub] [flink] jinxing64 opened a new pull request #16193: [FLINK-23030][network] PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

2021-06-18 Thread GitBox
jinxing64 opened a new pull request #16193: URL: https://github.com/apache/flink/pull/16193 ## What is the purpose of the change In current `PartitionRequestClientFactory#createPartitionRequestClient`, `ChannelFuture#await()` is invoked, thus to build a connection to remote synchron

[jira] [Updated] (FLINK-23029) Extend PluginLoader to allow closing of backing ClassLoader

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23029: --- Labels: pull-request-available (was: ) > Extend PluginLoader to allow closing of backing Cl

[jira] [Updated] (FLINK-23001) flink-avro-glue-schema-registry lacks scala suffix

2021-06-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23001: - Priority: Blocker (was: Critical) > flink-avro-glue-schema-registry lacks scala suffix

[GitHub] [flink] flinkbot edited a comment on pull request #16191: [FLINK-23029] Extend PluginLoader to allow closing ClassLoader

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

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

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

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

2021-06-18 Thread GitBox
GuokuaiHuang commented on pull request #16174: URL: https://github.com/apache/flink/pull/16174#issuecomment-863707590 -- 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 qu

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

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16188: URL: https://github.com/apache/flink/pull/16188#issuecomment-863713814 -- 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 commented on a change in pull request #16199: [FLINK-23034][runtime] Added compatibility for ExecutionState in Hist…

2021-06-18 Thread GitBox
zentol commented on a change in pull request #16199: URL: https://github.com/apache/flink/pull/16199#discussion_r654428364 ## File path: flink-runtime/src/test/resources/job-details/job-details-compatible.js ## @@ -0,0 +1,21 @@ +{ Review comment: Maybe just move this i

[GitHub] [flink] dawidwys closed pull request #14820: [FLINK-21085][runtime][checkpoint] Allows triggering checkpoint for non-source tasks

2021-06-18 Thread GitBox
dawidwys closed pull request #14820: URL: https://github.com/apache/flink/pull/14820 -- 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] rmetzger commented on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

2021-06-18 Thread GitBox
rmetzger commented on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-864238759 > I think ignoring the module now and re-enabling it later should be fine. Okay, but then let's make FLINK-23001 a blocker for 1.14 ? > A sanity check that more tha

[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 -- 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 #16191: [FLINK-23029] Extend PluginLoader to allow closing ClassLoader

2021-06-18 Thread GitBox
flinkbot commented on pull request #16191: URL: https://github.com/apache/flink/pull/16191#issuecomment-863808302 -- 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 #16201: [hotfix][docs] Merge the two Flink POJO definitions to make the definition uniform

2021-06-18 Thread GitBox
flinkbot commented on pull request #16201: URL: https://github.com/apache/flink/pull/16201#issuecomment-864040093 -- 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 #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

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

[jira] [Closed] (FLINK-20891) SystemResourcesCounterTest may caused endless loop when some error occured

2021-06-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20891. Resolution: Fixed master: 246f0db2b7410bcd534c39e1a5b93a0cba6bffc7 > SystemResourcesCount

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

2021-06-18 Thread GitBox
flinkbot commented on pull request #16190: URL: https://github.com/apache/flink/pull/16190#issuecomment-863790169 -- 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 #16196: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16196: URL: https://github.com/apache/flink/pull/16196#issuecomment-863912932 -- 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] iemre opened a new pull request #16196: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis (1.14)

2021-06-18 Thread GitBox
iemre opened a new pull request #16196: URL: https://github.com/apache/flink/pull/16196 ## 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] flinkbot edited a comment on pull request #16179: [TESTING] Try to reproduce FLINK-22891

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

[jira] [Updated] (FLINK-23027) Move chill dependency to flink-scala

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23027: --- Labels: pull-request-available (was: ) > Move chill dependency to flink-scala > ---

[jira] [Updated] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23009: --- Labels: pull-request-available (was: ) > Bump up Guava in Kinesis Connector > -

[jira] [Updated] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure

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

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

2021-06-18 Thread GitBox
iemre commented on pull request #16203: URL: https://github.com/apache/flink/pull/16203#issuecomment-864062138 @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] Myasuka commented on a change in pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-18 Thread GitBox
Myasuka commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r654247587 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java ## @@ -102,13 +102,15 @@ /** Whether to enable sta

[jira] [Updated] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21952: --- Labels: pull-request-available (was: ) > Make all the "Connection reset by peer" exception

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

2021-06-18 Thread GitBox
gaoyunhaii commented on a change in pull request #14820: URL: https://github.com/apache/flink/pull/14820#discussion_r654164209 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1012,6 +1027,35 @@ private boolean tr

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

2021-06-18 Thread GitBox
flinkbot commented on pull request #16205: URL: https://github.com/apache/flink/pull/16205#issuecomment-864117721 -- 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] movesan commented on pull request #16084: [FLINK-22518][docs] Translate the page of "High Availability (HA)" in…

2021-06-18 Thread GitBox
movesan commented on pull request #16084: URL: https://github.com/apache/flink/pull/16084#issuecomment-863777540 -- 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] Myasuka merged pull request #16084: [FLINK-22518][docs] Translate the page of "High Availability (HA)" in…

2021-06-18 Thread GitBox
Myasuka merged pull request #16084: URL: https://github.com/apache/flink/pull/16084 -- 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-benchmarks] akalash commented on a change in pull request #14: [FLINK-22973] Provide unaligned checkpoint with timeouts benchmark

2021-06-18 Thread GitBox
akalash commented on a change in pull request #14: URL: https://github.com/apache/flink-benchmarks/pull/14#discussion_r654266208 ## File path: src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java ## @@ -42,119 +43,90 @@ import java.io.IOException; i

[GitHub] [flink] akalash opened a new pull request #16199: [FLINK-23034][runtime] Added compatibility for ExecutionState in Hist…

2021-06-18 Thread GitBox
akalash opened a new pull request #16199: URL: https://github.com/apache/flink/pull/16199 …oryServer ## What is the purpose of the change *This PR adds the compatibility support for ExecutionState deserialization in History server * ## Brief change log

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

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16187: URL: https://github.com/apache/flink/pull/16187#issuecomment-863396106 -- 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] gaoyunhaii commented on pull request #14820: [FLINK-21085][runtime][checkpoint] Allows triggering checkpoint for non-source tasks

2021-06-18 Thread GitBox
gaoyunhaii commented on pull request #14820: URL: https://github.com/apache/flink/pull/14820#issuecomment-863783480 -- 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 quer

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

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

[GitHub] [flink-benchmarks] pnowojski merged pull request #14: [FLINK-22973] Provide unaligned checkpoint with timeouts benchmark

2021-06-18 Thread GitBox
pnowojski merged pull request #14: URL: https://github.com/apache/flink-benchmarks/pull/14 -- 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,

[GitHub] [flink] flinkbot edited a comment on pull request #16149: [FLINK-22884][hive] HiveCatalog should mark views as generic and stor…

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16149: URL: https://github.com/apache/flink/pull/16149#issuecomment-859601192 -- 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 #16178: [FLINK-23018][state] Enable TTL state factory to handle extended state descriptors

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16178: URL: https://github.com/apache/flink/pull/16178#issuecomment-863055788 -- 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] iemre commented on pull request #16202: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
iemre commented on pull request #16202: URL: https://github.com/apache/flink/pull/16202#issuecomment-864063631 @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] flinkbot commented on pull request #16198: [hotfix] Improve tuple equal code logic

2021-06-18 Thread GitBox
flinkbot commented on pull request #16198: URL: https://github.com/apache/flink/pull/16198#issuecomment-863944267 -- 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 #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

2021-06-18 Thread GitBox
iemre commented on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864202739 @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] echauchot opened a new pull request #16201: [hotfix][docs] Merge the two Flink POJO definitions to make the definition uniform

2021-06-18 Thread GitBox
echauchot opened a new pull request #16201: URL: https://github.com/apache/flink/pull/16201 I came by this, so I updated the javadoc. R: @zentol would you mind taking a look to that tiny PR ? -- This is an automated message from the Apache Git Service. To respond to the message

[jira] [Closed] (FLINK-22873) Add ToC to configuration documentation

2021-06-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22873. Resolution: Fixed master: fcec62fb31cedec81e0fc39efd099e9e20cef6ce 6d7e491a6003ab25ad0015f

[GitHub] [flink] AHeise commented on pull request #15725: [FLINK-21389] determine parquet schema from file instead of taking it from user

2021-06-18 Thread GitBox
AHeise commented on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-863831739 Thank you for contributing! -- 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

[jira] [Updated] (FLINK-23034) NPE in JobDetailsDeserializer during the reading old version of ExecutionState

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23034: --- Labels: pull-request-available (was: ) > NPE in JobDetailsDeserializer during the reading o

[GitHub] [flink] flinkbot edited a comment on pull request #16194: [FLINK-21952] Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

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

[jira] [Updated] (FLINK-23018) State factories should handle extended state descriptors

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23018: --- Labels: pull-request-available (was: ) > State factories should handle extended state descr

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

2021-06-18 Thread GitBox
flinkbot commented on pull request #16194: URL: https://github.com/apache/flink/pull/16194#issuecomment-863874885 -- 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 a change in pull request #16135: [FLINK-22961][streaming] firstBarrierArrivalTime is recalculated when…

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

[GitHub] [flink] SteNicholas removed a comment on pull request #16142: [FLINK-22748][connector-kafka] Allow dynamic target topic selection in SQL Kafka sinks

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

[GitHub] [flink] KarmaGYZ opened a new pull request #16188: [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable

2021-06-18 Thread GitBox
KarmaGYZ opened a new pull request #16188: URL: https://github.com/apache/flink/pull/16188 ## 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 them o

[GitHub] [flink-web] infoverload opened a new pull request #451: [FLINK-23038][docs] fix glossary link

2021-06-18 Thread GitBox
infoverload opened a new pull request #451: URL: https://github.com/apache/flink-web/pull/451 The glossary link on https://flink.apache.org/contributing/docs-style.html needs to be updated. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

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

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

[GitHub] [flink] flinkbot commented on pull request #16197: [FLINK_22662][yarn][test] Add logs for YARNHighAvailabilityITCase

2021-06-18 Thread GitBox
flinkbot commented on pull request #16197: URL: https://github.com/apache/flink/pull/16197#issuecomment-863916496 -- 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 #16198: [hotfix] Improve tuple equal code logic

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16198: URL: https://github.com/apache/flink/pull/16198#issuecomment-863969216 -- 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] RocMarshal commented on pull request #16070: [FLINK-23028][docs] Improve documentation for pages of SQL.

2021-06-18 Thread GitBox
RocMarshal commented on pull request #16070: URL: https://github.com/apache/flink/pull/16070#issuecomment-863944032 @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 specif

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

2021-06-18 Thread GitBox
tinawenqiao commented on pull request #16183: URL: https://github.com/apache/flink/pull/16183#issuecomment-863723839 > @tinawenqiao As I said in #16147, please modify your description of this PR, it's not recommended to leave the description as the default template. The pr descriptio

[jira] [Updated] (FLINK-23038) Broken link in Documentation Style Guide

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23038: --- Labels: pull-request-available (was: ) > Broken link in Documentation Style Guide > ---

[GitHub] [flink] SteNicholas commented on pull request #16142: [FLINK-22748][connector-kafka] Allow dynamic target topic selection in SQL Kafka sinks

2021-06-18 Thread GitBox
SteNicholas commented on pull request #16142: URL: https://github.com/apache/flink/pull/16142#issuecomment-863772048 @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 speci

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

2021-06-18 Thread GitBox
rkhachatryan commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r654583087 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -384,6 +358,22 @@ public static boolean stat

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

2021-06-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22974: --- Labels: pull-request-available (was: ) > No execution checkpointing config desc in flink-co

[GitHub] [flink-benchmarks] pnowojski commented on a change in pull request #14: [FLINK-22973] Provide unaligned checkpoint with timeouts benchmark

2021-06-18 Thread GitBox
pnowojski commented on a change in pull request #14: URL: https://github.com/apache/flink-benchmarks/pull/14#discussion_r654377463 ## File path: src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java ## @@ -42,119 +43,90 @@ import java.io.IOException;

[GitHub] [flink] zentol opened a new pull request #16191: [FLINK-23029] Extend PluginLoader to allow closing ClassLoader

2021-06-18 Thread GitBox
zentol opened a new pull request #16191: URL: https://github.com/apache/flink/pull/16191 With this PR it will be possibly to load a plugin temporarily, for example within a single test that uses a MiniCluster. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] Myasuka 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
Myasuka commented on a change in pull request #16183: URL: https://github.com/apache/flink/pull/16183#discussion_r654121018 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -107,7 +107,18 @@ parallelism.default: 1 #=

[GitHub] [flink] cshuo commented on pull request #14786: [FLINK-19592] [Table SQL / Runtime] MiniBatchGroupAggFunction and MiniBatchGlobalGroupAggFunction emit messages to prevent too early state evic

2021-06-18 Thread GitBox
cshuo commented on pull request #14786: URL: https://github.com/apache/flink/pull/14786#issuecomment-863917511 It better if adding some harness tests in `GroupAggregateHarnessTest` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

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

2021-06-18 Thread GitBox
dannycranmer opened a new pull request #16204: URL: https://github.com/apache/flink/pull/16204 ## 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] flinkbot commented on pull request #16204: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

2021-06-18 Thread GitBox
flinkbot commented on pull request #16204: URL: https://github.com/apache/flink/pull/16204#issuecomment-864055362 -- 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 #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

2021-06-18 Thread GitBox
flinkbot commented on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864179092 -- 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 #16201: [hotfix][docs] Merge the two Flink POJO definitions to make the definition uniform

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16201: URL: https://github.com/apache/flink/pull/16201#issuecomment-864053040 -- 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 #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 -- 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] stormy-ua commented on pull request #15221: [FLINK-17012][streaming] 'RUNNING' state split into 'RUNNING' and 'RE…

2021-06-18 Thread GitBox
stormy-ua commented on pull request #15221: URL: https://github.com/apache/flink/pull/15221#issuecomment-864015688 @zentol @akalash thanks for looking into this! -- 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] flinkbot edited a comment on pull request #16035: [FLINK-22808][state/changelog] Log metadata

2021-06-18 Thread GitBox
flinkbot edited a comment on pull request #16035: URL: https://github.com/apache/flink/pull/16035#issuecomment-851611489 -- 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 a change in pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-18 Thread GitBox
Zakelly commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r654332187 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java ## @@ -102,13 +102,15 @@ /** Whether to enable sta

<    1   2   3   4   >