[GitHub] [flink] Thesharing commented on pull request #16498: [FLINK-23354][blob] Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

2021-07-28 Thread GitBox
Thesharing commented on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-21366 > Thanks for addressing all the comments @Thesharing > The change now looks good to me. Will merge it once CI gives green. Thank you for your reviewing, @zhuzhurk.

[GitHub] [flink] Thesharing commented on pull request #16624: [FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

2021-07-28 Thread GitBox
Thesharing commented on pull request #16624: URL: https://github.com/apache/flink/pull/16624#issuecomment-20649 > Can we also fix the link in "jobmanager.execution.failover-strategy" which breaks due to the same reason? Thank you for pointing this out. I get it fixed in the

[GitHub] [flink-jira-bot] knaufk commented on pull request #23: [FLINK-23206] Minor tickets are moved to Not a Priority instead of cl…

2021-07-28 Thread GitBox
knaufk commented on pull request #23: URL: https://github.com/apache/flink-jira-bot/pull/23#issuecomment-19931 @pnowojski Thanks you for the review. Good to see that more people are familiarizing themselves with the code increasing the bus factor. I addressed your comments. -- This

[GitHub] [flink-jira-bot] knaufk commented on a change in pull request #23: [FLINK-23206] Minor tickets are moved to Not a Priority instead of cl…

2021-07-28 Thread GitBox
knaufk commented on a change in pull request #23: URL: https://github.com/apache/flink-jira-bot/pull/23#discussion_r678840721 ## File path: flink_jira_bot.py ## @@ -65,14 +64,16 @@ def get_args(): stale_assigned_rule = StaleAssignedRule( jira,

[GitHub] [flink-jira-bot] knaufk commented on a change in pull request #23: [FLINK-23206] Minor tickets are moved to Not a Priority instead of cl…

2021-07-28 Thread GitBox
knaufk commented on a change in pull request #23: URL: https://github.com/apache/flink-jira-bot/pull/23#discussion_r678840585 ## File path: stale_unassigned_rule.py ## @@ -20,7 +20,7 @@ import logging -class StaleMajorOrAboveRule(FlinkJiraRule): +class

[jira] [Created] (FLINK-23537) Easy way to append metadata to deserialized row data for connector implementations

2021-07-28 Thread Jira
Ingo Bürk created FLINK-23537: - Summary: Easy way to append metadata to deserialized row data for connector implementations Key: FLINK-23537 URL: https://issues.apache.org/jira/browse/FLINK-23537

[GitHub] [flink] flinkbot commented on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread GitBox
flinkbot commented on pull request #16630: URL: https://github.com/apache/flink/pull/16630#issuecomment-17597 ## CI report: * feb601f7603dad7defb60305c1ea603ac2fc1b24 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 59644cc0b8b79495818890290190e7cf91caed7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN *

[jira] [Created] (FLINK-23536) Documentation of DeserializationSchema#deserialize is incorrect

2021-07-28 Thread Jira
Ingo Bürk created FLINK-23536: - Summary: Documentation of DeserializationSchema#deserialize is incorrect Key: FLINK-23536 URL: https://issues.apache.org/jira/browse/FLINK-23536 Project: Flink

[jira] [Assigned] (FLINK-23531) Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-23531: --- Assignee: tartarus > Allow skip all change log for row-time deduplicate mini-batch >

[jira] [Commented] (FLINK-23439) Update "Local Installation" Page

2021-07-28 Thread Zhou Jianpeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389264#comment-17389264 ] Zhou Jianpeng commented on FLINK-23439: --- Hi, [~sjwiesman] . I'm willing to translate this

[GitHub] [flink] flinkbot commented on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread GitBox
flinkbot commented on pull request #16630: URL: https://github.com/apache/flink/pull/16630#issuecomment-11698 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] Tartarus0zm commented on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread GitBox
Tartarus0zm commented on pull request #16630: URL: https://github.com/apache/flink/pull/16630#issuecomment-10284 @wuchong please take a look, if you have time. thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-23531) Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23531: --- Labels: pull-request-available (was: ) > Allow skip all change log for row-time

[GitHub] [flink] Tartarus0zm opened a new pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread GitBox
Tartarus0zm opened a new pull request #16630: URL: https://github.com/apache/flink/pull/16630 ## What is the purpose of the change current we keep all change log for row-time deduplicate mini-batch, we need buffer all record on heap. In some cases, users do not need all change

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * ed3c016be3eed47b71f31f761f2f1d7fabd186c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16498: [FLINK-23354][blob] Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880512519 ## CI report: * ea075fb62bc7853bcdbbf6d275c70048a9915f57 UNKNOWN * c80d84283688488ccced44ab20354ba3185307df UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * fb3c00456ab2db56e4cff17e8e8dc4ab86f05eff Azure:

[jira] [Commented] (FLINK-23535) The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly

2021-07-28 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389261#comment-17389261 ] tim yu commented on FLINK-23535: Hi [~jark], could you please assign this to me ? > The value of option

[GitHub] [flink] flinkbot edited a comment on pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16316: URL: https://github.com/apache/flink/pull/16316#issuecomment-870264093 ## CI report: * fd85601d44499decc5174422b07a2b239ba096fa Azure:

[jira] [Created] (FLINK-23535) The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly

2021-07-28 Thread tim yu (Jira)
tim yu created FLINK-23535: -- Summary: The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly Key: FLINK-23535 URL: https://issues.apache.org/jira/browse/FLINK-23535

[jira] [Commented] (FLINK-23534) Banned dependencies in flink-statebackend-changelog

2021-07-28 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389259#comment-17389259 ] Dawid Wysakowicz commented on FLINK-23534: -- cc [~roman_khachatryan] [~ym] > Banned

[jira] [Created] (FLINK-23534) Banned dependencies in flink-statebackend-changelog

2021-07-28 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-23534: Summary: Banned dependencies in flink-statebackend-changelog Key: FLINK-23534 URL: https://issues.apache.org/jira/browse/FLINK-23534 Project: Flink

[jira] [Updated] (FLINK-23534) Banned dependencies in flink-statebackend-changelog

2021-07-28 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23534: - Description:

[GitHub] [flink] dawidwys commented on a change in pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
dawidwys commented on a change in pull request #16589: URL: https://github.com/apache/flink/pull/16589#discussion_r678823514 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.java ## @@ -151,7 +152,11 @@

[GitHub] [flink] dawidwys commented on a change in pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
dawidwys commented on a change in pull request #16589: URL: https://github.com/apache/flink/pull/16589#discussion_r678820421 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.java ## @@ -151,7 +152,11 @@

[GitHub] [flink] dawidwys commented on a change in pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
dawidwys commented on a change in pull request #16589: URL: https://github.com/apache/flink/pull/16589#discussion_r678820360 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java ## @@ -84,8 +84,9 @@ public

[GitHub] [flink] dawidwys commented on a change in pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
dawidwys commented on a change in pull request #16589: URL: https://github.com/apache/flink/pull/16589#discussion_r678817768 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleInputSelectionHandler.java ## @@ -101,20 +114,26 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [draft] materialization for FLIP 158

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 1206a78c6480a509dceafaa81d1baaf1272fdeec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * fb3c00456ab2db56e4cff17e8e8dc4ab86f05eff Azure:

[jira] [Created] (FLINK-23533) Split InputSelection into public and internal parts

2021-07-28 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-23533: Summary: Split InputSelection into public and internal parts Key: FLINK-23533 URL: https://issues.apache.org/jira/browse/FLINK-23533 Project: Flink

[GitHub] [flink] dawidwys commented on a change in pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
dawidwys commented on a change in pull request #16589: URL: https://github.com/apache/flink/pull/16589#discussion_r678814067 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/TwoInputSelectionHandler.java ## @@ -44,18 +49,27 @@ public

[jira] [Created] (FLINK-23532) Unify stop-with-savepoint w drain and w/o drain

2021-07-28 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-23532: Summary: Unify stop-with-savepoint w drain and w/o drain Key: FLINK-23532 URL: https://issues.apache.org/jira/browse/FLINK-23532 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [draft] materialization for FLIP 158

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 1206a78c6480a509dceafaa81d1baaf1272fdeec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16316: URL: https://github.com/apache/flink/pull/16316#issuecomment-870264093 ## CI report: * eeb5a6048e69bdf7bf50a25d1c5ab2ae2f3a7c85 Azure:

[jira] [Updated] (FLINK-23531) Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-23531: - Summary: Allow skip all change log for row-time deduplicate mini-batch (was: Allow skip everytime

[jira] [Updated] (FLINK-23531) Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-23531: - Description: current we keep all change log for row-time deduplicate mini-batch, we need buffer all

[jira] [Commented] (FLINK-23531) Allow skip everytime change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389248#comment-17389248 ] tartarus commented on FLINK-23531: -- [~jark]  please assign to me, thanks > Allow skip everytime change

[GitHub] [flink-web] Myasuka commented on a change in pull request #455: Add release 1.12.5

2021-07-28 Thread GitBox
Myasuka commented on a change in pull request #455: URL: https://github.com/apache/flink-web/pull/455#discussion_r678800400 ## File path: _posts/2021-07-02-release-1.12.5.md ## @@ -0,0 +1,203 @@ +--- +layout: post +title: "Apache Flink 1.12.5 Released" +date: 2021-07-02

[GitHub] [flink] wuchong commented on pull request #16627: [FLINK-23427][chinese-translation] Translate the page of "Blocking Sh…

2021-07-28 Thread GitBox
wuchong commented on pull request #16627: URL: https://github.com/apache/flink/pull/16627#issuecomment-888777897 @gaoyunhaii could you help to review this? I think you should be familiar with this part as you contributed the original English docs. -- This is an automated message from

[GitHub] [flink] wangyang0918 commented on a change in pull request #16623: [FLINK-22891][test] Increase the delay of the checkResourceRequiremen…

2021-07-28 Thread GitBox
wangyang0918 commented on a change in pull request #16623: URL: https://github.com/apache/flink/pull/16623#discussion_r678796546 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManagerTestBase.java ## @@ -142,7

[GitHub] [flink] flinkbot edited a comment on pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16316: URL: https://github.com/apache/flink/pull/16316#issuecomment-870264093 ## CI report: * eeb5a6048e69bdf7bf50a25d1c5ab2ae2f3a7c85 Azure:

[jira] [Updated] (FLINK-23172) Links to Task Failure Recovery page on Configuration page are broken

2021-07-28 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23172: - Description: The links to [Task Failure

[jira] [Updated] (FLINK-23172) Links to Task Failure Recovery page on Configuration page are broken

2021-07-28 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23172: - Description: The links to [Task Failure

[jira] [Commented] (FLINK-23515) I try to specify savepoint dir in my app. However, the startup task reports an error, java.lang.unsupported operationexception: the configuration is unmodifiable; its

2021-07-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389233#comment-17389233 ] 李伟高 commented on FLINK-23515: - ok ,thank you. > I try to specify savepoint dir in my app. However, the

[jira] [Updated] (FLINK-23172) Links to Task Failure Recovery page on Configuration page are broken

2021-07-28 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23172: - Description: The links to [Task Failure

[jira] [Created] (FLINK-23531) Allow skip everytime change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
tartarus created FLINK-23531: Summary: Allow skip everytime change log for row-time deduplicate mini-batch Key: FLINK-23531 URL: https://issues.apache.org/jira/browse/FLINK-23531 Project: Flink

[jira] [Updated] (FLINK-23172) Links to Task Failure Recovery page on Configuration page are broken

2021-07-28 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23172: - Summary: Links to Task Failure Recovery page on Configuration page are broken (was: Links in

[jira] [Updated] (FLINK-23172) Links in configuration page are broken

2021-07-28 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23172: - Description: The links inside Fault Tolerance section and Advanced Fault Tolerance Options

[jira] [Closed] (FLINK-17354) Introduce range sort for batch sort operator in blink

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17354. Resolution: Duplicate > Introduce range sort for batch sort operator in blink >

[jira] [Closed] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17453. Resolution: Invalid I also think it's the problem with FLINK-13702. Feel free to re-open if you

[jira] [Updated] (FLINK-23172) Links in configuration page are broken

2021-07-28 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23172: - Summary: Links in configuration page are broken (was: Links of restart strategy in

[GitHub] [flink] flinkbot edited a comment on pull request #16629: [hotfix][connectors][kafka] improve error message when valueDeseriali…

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-888753020 ## CI report: * cabb650967f9a523bca917ae6409398e5c6ccd2a Azure:

[jira] [Closed] (FLINK-20556) Compile exception when using Scala package object as POJO

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20556. Resolution: Invalid > Compile exception when using Scala package object as POJO >

[jira] [Updated] (FLINK-23529) Add Flink 1.13 MigrationVersion

2021-07-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23529: Description: Currently the largest MigrationVersion is 1.12. We need newer versions to add more

[jira] [Commented] (FLINK-20765) ScalarOperatorGens doesn't set proper nullability for result type of generated expressions

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389214#comment-17389214 ] Jingsong Lee commented on FLINK-20765: -- FLINK-22106 is a similar issue. > ScalarOperatorGens

[jira] [Updated] (FLINK-23529) Add Flink 1.13 MigrationVersion

2021-07-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23529: Summary: Add Flink 1.13 MigrationVersion (was: Add Flink 1.13 & 1.14 MigrationVersion) > Add

[jira] [Closed] (FLINK-22591) add sub interface MapColumnVector for ColumnVector

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22591. Fix Version/s: (was: 1.14.0) Resolution: Invalid Introduced in FLINK-15390 > add sub

[jira] [Closed] (FLINK-23077) Running nexmark q5 with 1.13.1 of pipeline.object-reuse=true, the taskmanager will be killed and produce failover.

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23077. Resolution: Invalid OOM. state backend should be rocksdb. > Running nexmark q5 with 1.13.1 of

[GitHub] [flink] zhuzhurk commented on pull request #16624: [FLINK-23172][docs] Fix broken links of restart strategy in configuration page

2021-07-28 Thread GitBox
zhuzhurk commented on pull request #16624: URL: https://github.com/apache/flink/pull/16624#issuecomment-888760850 Can we also fix the link in "jobmanager.execution.failover-strategy" which breaks due to the same reason? -- This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-9673) Improve State efficiency of bounded OVER window operators

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-9673. --- Resolution: Invalid This is been optimized by projection push down. > Improve State efficiency of

[jira] [Commented] (FLINK-23172) Links of restart strategy in configuration page is broken

2021-07-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389206#comment-17389206 ] Zhu Zhu commented on FLINK-23172: - Thanks for reporting this problem! [~Thesharing] I have assigned you

[jira] [Assigned] (FLINK-23172) Links of restart strategy in configuration page is broken

2021-07-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-23172: --- Assignee: Zhilong Hong > Links of restart strategy in configuration page is broken >

[jira] [Assigned] (FLINK-22773) Optimize the construction of pipelined regions

2021-07-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22773: --- Assignee: Zhilong Hong > Optimize the construction of pipelined regions >

[jira] [Updated] (FLINK-22773) Optimize the construction of pipelined regions

2021-07-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22773: Fix Version/s: 1.14.0 > Optimize the construction of pipelined regions >

[jira] [Closed] (FLINK-12900) Refactor the class hierarchy for BinaryFormat

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-12900. Resolution: Invalid > Refactor the class hierarchy for BinaryFormat >

[GitHub] [flink] JingsongLi closed pull request #8808: [FLINK-12900][Table SQL / Runtime] Refactor the class hierarchy for BinaryFormat

2021-07-28 Thread GitBox
JingsongLi closed pull request #8808: URL: https://github.com/apache/flink/pull/8808 -- 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:

[GitHub] [flink] zjuwangg commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-07-28 Thread GitBox
zjuwangg commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r678228277 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -118,8 +145,8

[jira] [Assigned] (FLINK-23354) Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

2021-07-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-23354: --- Assignee: Zhilong Hong > Limit the size of ShuffleDescriptors in PermanentBlobCache on

[jira] [Closed] (FLINK-12922) Remove method parameter from OperatorCodeGenerator

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-12922. Resolution: Invalid > Remove method parameter from OperatorCodeGenerator >

[GitHub] [flink] JingsongLi closed pull request #8821: [FLINK-12922][Table SQL / Planner] Remove method parameter from OperatorCodeGenerator

2021-07-28 Thread GitBox
JingsongLi closed pull request #8821: URL: https://github.com/apache/flink/pull/8821 -- 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] [Updated] (FLINK-14860) Provide a new InputSplitAssigner that consider page cache utilization ratio

2021-07-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14860: - Component/s: (was: Table SQL / Runtime) Connectors / FileSystem > Provide

[GitHub] [flink] flinkbot commented on pull request #16629: [hotfix][connectors][kafka] improve error message when valueDeseriali…

2021-07-28 Thread GitBox
flinkbot commented on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-888753020 ## CI report: * cabb650967f9a523bca917ae6409398e5c6ccd2a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 59644cc0b8b79495818890290190e7cf91caed7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16575: [FLINK-23139][state] Add TaskStateRegistry

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16575: URL: https://github.com/apache/flink/pull/16575#issuecomment-885295771 ## CI report: * 727883a3a059a779286abd9550861f86b97ebb75 Azure:

[jira] [Updated] (FLINK-23529) Add Flink 1.13 & 1.14 MigrationVersion

2021-07-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23529: Labels: (was: pull-request-available) > Add Flink 1.13 & 1.14 MigrationVersion >

[GitHub] [flink] tsreaper closed pull request #16625: [FLINK-23529][core] Add 1.13 & 1.14 MigrationVersion

2021-07-28 Thread GitBox
tsreaper closed pull request #16625: URL: https://github.com/apache/flink/pull/16625 -- 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:

[GitHub] [flink] flinkbot commented on pull request #16629: [hotfix][connectors][kafka] improve error message when valueDeseriali…

2021-07-28 Thread GitBox
flinkbot commented on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-888744692 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 edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 59644cc0b8b79495818890290190e7cf91caed7d Azure:

[GitHub] [flink] camilesing opened a new pull request #16629: [hotfix][connectors][kafka] improve error message when valueDeseriali…

2021-07-28 Thread GitBox
camilesing opened a new pull request #16629: URL: https://github.com/apache/flink/pull/16629 …zer is null ## 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

[GitHub] [flink] beyond1920 commented on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-07-28 Thread GitBox
beyond1920 commented on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888737385 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * 840b0ea0a6a6237c7a16a9f5adef4f7f7276791c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16498: [FLINK-23354][blob] Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880512519 ## CI report: * ea075fb62bc7853bcdbbf6d275c70048a9915f57 UNKNOWN * c80d84283688488ccced44ab20354ba3185307df UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * 840b0ea0a6a6237c7a16a9f5adef4f7f7276791c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16498: [FLINK-23354][blob] Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880512519 ## CI report: * ea075fb62bc7853bcdbbf6d275c70048a9915f57 UNKNOWN * c80d84283688488ccced44ab20354ba3185307df UNKNOWN *

[GitHub] [flink] zhuzhurk commented on pull request #16498: [FLINK-23354][blob] Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

2021-07-28 Thread GitBox
zhuzhurk commented on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-888721980 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

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

2021-07-28 Thread GitBox
becketqin commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r67874 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -110,69

[GitHub] [flink] flinkbot edited a comment on pull request #16575: [FLINK-23139][state] Add TaskStateRegistry

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16575: URL: https://github.com/apache/flink/pull/16575#issuecomment-885295771 ## CI report: * 13507c111ae1eef509bb0f5240ca2d49a9b9380d Azure:

[jira] [Updated] (FLINK-7288) Yarn production classes contain testing code

2021-07-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7288: -- Labels: stale-minor starter (was: starter) I am the [Flink Jira

[jira] [Updated] (FLINK-20523) OffsetsInitializerTest test failed with "java.net.BindException: Address already in use"

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

[jira] [Updated] (FLINK-23140) Invalid link in Data Sources documentation

2021-07-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23140: --- Labels: stale-assigned starter trivial (was: starter trivial) I am the [Flink Jira

[jira] [Updated] (FLINK-17495) Add support for custom variables

2021-07-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17495: --- Labels: auto-deprioritized-major pull-request-available stale-assigned (was:

[GitHub] [flink] flinkbot edited a comment on pull request #16628: [FLINK-23453][streaming] Created the buffer size calculator for the ability to automatically change the buffer size based on the thro

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16628: URL: https://github.com/apache/flink/pull/16628#issuecomment-888479610 ## CI report: * 809bf812269c1e4e3c8af3e0e133cd12f048f68f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23408] Wait for a checkpoint completed after finishing a task

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16575: [FLINK-23139][state] Add TaskStateRegistry

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16575: URL: https://github.com/apache/flink/pull/16575#issuecomment-885295771 ## CI report: * 91f5e0af38235b0838b95bad8dae14134bc601e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16575: [FLINK-23139][state] Add TaskStateRegistry

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16575: URL: https://github.com/apache/flink/pull/16575#issuecomment-885295771 ## CI report: * 91f5e0af38235b0838b95bad8dae14134bc601e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16575: [FLINK-23139][state] Add TaskStateRegistry

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16575: URL: https://github.com/apache/flink/pull/16575#issuecomment-885295771 ## CI report: * 91f5e0af38235b0838b95bad8dae14134bc601e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16498: [FLINK-23354][blob] Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

2021-07-28 Thread GitBox
flinkbot edited a comment on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880512519 ## CI report: * ea075fb62bc7853bcdbbf6d275c70048a9915f57 UNKNOWN * c80d84283688488ccced44ab20354ba3185307df UNKNOWN *

  1   2   3   4   5   >