[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

2021-08-30 Thread loyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407022#comment-17407022 ] loyi commented on FLINK-23190: -- Get it . Thanks. > Make task-slot allocation much more eve

[jira] [Resolved] (FLINK-23686) KafkaSource metric "commitsSucceeded" should count per-commit instead of per-partition

2021-08-30 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-23686. -- Resolution: Fixed Merged to master / release-1.14: 62931a1665e6a6976d088ed49375f9fdf00229d9 C

[jira] [Updated] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem

2021-08-30 Thread li wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li wei updated FLINK-23918: --- Priority: Blocker (was: Major) > FileNotFoundException when open auto-compact in filesystem > -

[GitHub] [flink] Myasuka commented on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

2021-08-30 Thread GitBox
Myasuka commented on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-908850566 Though this PR is samll, I think @wuchong is better to review this. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] Myasuka edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

2021-08-30 Thread GitBox
Myasuka edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-908850566 Though this PR is samll, I think @wuchong is better to review this SQL related documentation. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] Myasuka edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

2021-08-30 Thread GitBox
Myasuka edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-908850566 Though this PR is small, I think @wuchong is better to review this SQL related documentation. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-24060) Move ZooKeeperUtilTest to right place

2021-08-30 Thread Aitozi (Jira)
Aitozi created FLINK-24060: -- Summary: Move ZooKeeperUtilTest to right place Key: FLINK-24060 URL: https://issues.apache.org/jira/browse/FLINK-24060 Project: Flink Issue Type: Technical Debt

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

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * d632973fab7c7235a18bece90835c3c469130b7c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17010: URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888 ## CI report: * 9795ee3ba550914a119c605df84e9f5cf3eae404 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17061: URL: https://github.com/apache/flink/pull/17061#issuecomment-908742444 ## CI report: * 22b98671af59b74baa2c015edf7e941c5ef54108 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] gaoyunhaii opened a new pull request #17062: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14)

2021-08-30 Thread GitBox
gaoyunhaii opened a new pull request #17062: URL: https://github.com/apache/flink/pull/17062 This PR picks https://github.com/apache/flink/pull/16773 to release-1.14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-web] tzulitai commented on a change in pull request #463: Statefun release 3.1

2021-08-30 Thread GitBox
tzulitai commented on a change in pull request #463: URL: https://github.com/apache/flink-web/pull/463#discussion_r698939045 ## File path: _posts/2021-08-30-release-statefun-3.1.0.md ## @@ -0,0 +1,228 @@ +--- +layout: post +title: "Stateful Functions 3.1.0 Release Announcement

[GitHub] [flink] flinkbot commented on pull request #17062: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14)

2021-08-30 Thread GitBox
flinkbot commented on pull request #17062: URL: https://github.com/apache/flink/pull/17062#issuecomment-908854589 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] Aitozi opened a new pull request #17063: [FLINK-24060][Tests]Move ZooKeeperUtilTest to right class

2021-08-30 Thread GitBox
Aitozi opened a new pull request #17063: URL: https://github.com/apache/flink/pull/17063 ## What is the purpose of the change This PR removes the duplicate test case for `ZooKeeperUtils.java` and move the case to `ZooKeeperUtilsTest.java` ## Verifying this change Thi

[jira] [Updated] (FLINK-24060) Move ZooKeeperUtilTest to right place

2021-08-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24060: --- Labels: pull-request-available (was: ) > Move ZooKeeperUtilTest to right place > --

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

2021-08-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15648: -- Labels: (was: auto-deprioritized-major auto-unassigned pull-request-available) > Support to configu

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

2021-08-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15648: -- Summary: Support to configure limit for CPU and memory requirement (was: Support to configure limit f

[GitHub] [flink] flinkbot commented on pull request #17063: [FLINK-24060][Tests]Move ZooKeeperUtilTest to right class

2021-08-30 Thread GitBox
flinkbot commented on pull request #17063: URL: https://github.com/apache/flink/pull/17063#issuecomment-908856687 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

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

2021-08-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15648: -- Priority: Major (was: Minor) > Support to configure limit for CPU and memory requirement > --

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

2021-08-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15648: -- Description: Currently, the native Kubernetes mode could support same request and limit for the cpu a

[jira] [Assigned] (FLINK-24059) SourceReaderTestBase should allow NUM_SPLITS to be overridden in implementation

2021-08-30 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-24059: Assignee: Brian Zhou > SourceReaderTestBase should allow NUM_SPLITS to be overridden in

[GitHub] [flink] wuchong commented on a change in pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

2021-08-30 Thread GitBox
wuchong commented on a change in pull request #16723: URL: https://github.com/apache/flink/pull/16723#discussion_r698951705 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala ## @@ -808,6 +808,162 @@ class Table

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN * 043df6eaf3e6e69b3871edea72291a9a2266

[GitHub] [flink] Myasuka merged pull request #16992: [FLINK-23519][metrics] Expose state name as varibale if enable state latency tracking

2021-08-30 Thread GitBox
Myasuka merged pull request #16992: URL: https://github.com/apache/flink/pull/16992 -- 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: issues-unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17010: URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888 ## CI report: * 9795ee3ba550914a119c605df84e9f5cf3eae404 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cca9d287789ca6a353b7ffb8652ebc41f92fa20e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-23519) Aggregate State Backend Latency by State Level

2021-08-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23519: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 1

[GitHub] [flink] flinkbot commented on pull request #17063: [FLINK-24060][Tests]Move ZooKeeperUtilTest to right class

2021-08-30 Thread GitBox
flinkbot commented on pull request #17063: URL: https://github.com/apache/flink/pull/17063#issuecomment-908868069 ## CI report: * 07d4586f7d2427b0bb6181ca5b6122c0c44a4791 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17062: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14)

2021-08-30 Thread GitBox
flinkbot commented on pull request #17062: URL: https://github.com/apache/flink/pull/17062#issuecomment-908868024 ## CI report: * 5f49d4c824acc8c2170abceeef45bd918f674b2c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407048#comment-17407048 ] Xintong Song commented on FLINK-24038: -- I think you're correct, about option 2) and

[jira] [Commented] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407049#comment-17407049 ] Xintong Song commented on FLINK-24038: -- cc [~wangyang0918] > DispatcherResourceMan

[GitHub] [flink] wuchong merged pull request #16997: [FLINK-23287][docs][table] Create user document for Window Join in SQL

2021-08-30 Thread GitBox
wuchong merged pull request #16997: URL: https://github.com/apache/flink/pull/16997 -- 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: issues-unsubsc

[jira] [Closed] (FLINK-23287) Create user document for Window Join in SQL

2021-08-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23287. --- Resolution: Fixed Fixed in - master: ebed56ff019b9239d1323065361107d9cdc70d4f - release-1.14: 4d74822904ab

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407051#comment-17407051 ] Xintong Song commented on FLINK-23047: -- CassandraConnectorITCase.testScalingUp Cass

[jira] [Created] (FLINK-24061) RMQSourceITCase.testAckFailure fails on azure

2021-08-30 Thread Xintong Song (Jira)
Xintong Song created FLINK-24061: Summary: RMQSourceITCase.testAckFailure fails on azure Key: FLINK-24061 URL: https://issues.apache.org/jira/browse/FLINK-24061 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24061) RMQSourceITCase.testAckFailure fails on azure

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407053#comment-17407053 ] Xintong Song commented on FLINK-24061: -- cc [~cmick] [~arvid] > RMQSourceITCase.tes

[jira] [Commented] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

2021-08-30 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407055#comment-17407055 ] ming li commented on FLINK-22483: - Hi, [~trohrmann], thanks for your reply. It seems tha

[jira] [Comment Edited] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

2021-08-30 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407055#comment-17407055 ] ming li edited comment on FLINK-22483 at 8/31/21, 3:46 AM: --- Hi

[jira] [Updated] (FLINK-24023) the names of metrics are incomplete

2021-08-30 Thread linqichen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqichen updated FLINK-24023: -- Description: we cannot see the total name of metics on the page  because the selected box is too narro

[jira] [Updated] (FLINK-23834) Test StreamTableEnvironment batch mode manually

2021-08-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23834: Attachment: job_3.png job_2.png job_1.png > Test StreamTableEnvironment ba

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN * 043df6eaf3e6e69b3871edea72291a9a2266

[GitHub] [flink] RocMarshal commented on pull request #16852: [FLINK-13636][docs-zh]Translate the "Flink DataStream API Programming Guide" page into Chinese

2021-08-30 Thread GitBox
RocMarshal commented on pull request #16852: URL: https://github.com/apache/flink/pull/16852#issuecomment-908878974 @hapihu LGTM now. Hi, @wuchong , Would you please check it next ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Commented] (FLINK-23834) Test StreamTableEnvironment batch mode manually

2021-08-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407058#comment-17407058 ] Yun Gao commented on FLINK-23834: - I tested with three jobs: # [BlockedDataStreamSource

[GitHub] [flink] wuchong commented on pull request #16852: [FLINK-13636][docs-zh]Translate the "Flink DataStream API Programming Guide" page into Chinese

2021-08-30 Thread GitBox
wuchong commented on pull request #16852: URL: https://github.com/apache/flink/pull/16852#issuecomment-908881206 Thanks @RocMarshal and @hapihu . Will merge it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] wuchong merged pull request #16852: [FLINK-13636][docs-zh]Translate the "Flink DataStream API Programming Guide" page into Chinese

2021-08-30 Thread GitBox
wuchong merged pull request #16852: URL: https://github.com/apache/flink/pull/16852 -- 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: issues-unsubsc

[jira] [Closed] (FLINK-13636) Translate "Flink DataStream API Programming Guide" page into Chinese

2021-08-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13636. --- Fix Version/s: 1.15.0 1.14.0 Resolution: Fixed Fixed in - master: 9797488590d339

[GitHub] [flink] crazyzhou opened a new pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-08-30 Thread GitBox
crazyzhou opened a new pull request #17064: URL: https://github.com/apache/flink/pull/17064 ## What is the purpose of the change Make SourceReaderTestBase.NUM_SPLITS to be overridden in the implementations to help other connectors like [Pravega](https://github.com/pravega/fl

[jira] [Updated] (FLINK-24059) SourceReaderTestBase should allow NUM_SPLITS to be overridden in implementation

2021-08-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24059: --- Labels: pull-request-available (was: ) > SourceReaderTestBase should allow NUM_SPLITS to be

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * cca9d287789ca6a353b7ffb8652ebc41f92fa20e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17062: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14)

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

[GitHub] [flink] flinkbot edited a comment on pull request #17063: [FLINK-24060][Tests]Move ZooKeeperUtilTest to right class

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17063: URL: https://github.com/apache/flink/pull/17063#issuecomment-908868069 ## CI report: * 07d4586f7d2427b0bb6181ca5b6122c0c44a4791 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-08-30 Thread GitBox
flinkbot commented on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908886277 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] flinkbot commented on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-08-30 Thread GitBox
flinkbot commented on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945 ## CI report: * 167a600021ec50d0fa82e8806593391fe57a545a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

2021-08-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407071#comment-17407071 ] Yang Wang commented on FLINK-24031: --- Could you please verify that the akka address Job

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

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

[jira] [Created] (FLINK-24062) Exception encountered during timer serialization in Python DataStream API

2021-08-30 Thread Dian Fu (Jira)
Dian Fu created FLINK-24062: --- Summary: Exception encountered during timer serialization in Python DataStream API Key: FLINK-24062 URL: https://issues.apache.org/jira/browse/FLINK-24062 Project: Flink

[jira] [Updated] (FLINK-24062) Exception encountered during timer serialization in Python DataStream API

2021-08-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24062: Labels: release-testing (was: ) > Exception encountered during timer serialization in Python DataStream A

[GitHub] [flink] dianfu opened a new pull request #17065: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially

2021-08-30 Thread GitBox
dianfu opened a new pull request #17065: URL: https://github.com/apache/flink/pull/17065 ## What is the purpose of the change *This pull request fixes the serialization of timer to avoid serializing timer data partially* ## Verifying this change This change is t

[jira] [Updated] (FLINK-24062) Exception encountered during timer serialization in Python DataStream API

2021-08-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24062: --- Labels: pull-request-available release-testing (was: release-testing) > Exception encounter

[GitHub] [flink] flinkbot edited a comment on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945 ## CI report: * 167a600021ec50d0fa82e8806593391fe57a545a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17065: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially

2021-08-30 Thread GitBox
flinkbot commented on pull request #17065: URL: https://github.com/apache/flink/pull/17065#issuecomment-908909475 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Created] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler

2021-08-30 Thread Aitozi (Jira)
Aitozi created FLINK-24063: -- Summary: Reconsider the behavior of ClusterEntrypoint#startCluster failure handler Key: FLINK-24063 URL: https://issues.apache.org/jira/browse/FLINK-24063 Project: Flink

[jira] [Updated] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler

2021-08-30 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-24063: --- Description: If the job runCluster failed, it will trigger the STOP_APPLICATION behavior. But if we conside

[jira] [Commented] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler

2021-08-30 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407082#comment-17407082 ] Aitozi commented on FLINK-24063: Looking forward to your opinion on this [~trohrmann] >

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

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

[jira] [Comment Edited] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler

2021-08-30 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407082#comment-17407082 ] Aitozi edited comment on FLINK-24063 at 8/31/21, 5:40 AM: -- Look

[GitHub] [flink] gaoyunhaii commented on pull request #17062: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14)

2021-08-30 Thread GitBox
gaoyunhaii commented on pull request #17062: URL: https://github.com/apache/flink/pull/17062#issuecomment-908916557 @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] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * 60655804ce59530d485c1ae939f9b005b1ef5ede Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17062: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14)

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

[GitHub] [flink] flinkbot commented on pull request #17065: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially

2021-08-30 Thread GitBox
flinkbot commented on pull request #17065: URL: https://github.com/apache/flink/pull/17065#issuecomment-908917839 ## CI report: * d6889e3f8c9ee40c9dcce7b1691b85001371420a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407084#comment-17407084 ] Xintong Song commented on FLINK-23828: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Resolved] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

2021-08-30 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23857. Fix Version/s: (was: 1.13.3) 1.15.0 Resolution: Fixed Fixed in master: 6f599

[jira] [Assigned] (FLINK-23817) Write documentation for standardized operator metrics

2021-08-30 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23817: --- Assignee: Arvid Heise > Write documentation for standardized operator metrics > ---

[GitHub] [flink] pnowojski merged pull request #17037: [FLINK-24035][network] Guarantee that the LocalBufferPool is initialized with one buffer

2021-08-30 Thread GitBox
pnowojski merged pull request #17037: URL: https://github.com/apache/flink/pull/17037 -- 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: issues-unsub

[jira] [Created] (FLINK-24064) HybridSource recovery from savepoint fails

2021-08-30 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-24064: Summary: HybridSource recovery from savepoint fails Key: FLINK-24064 URL: https://issues.apache.org/jira/browse/FLINK-24064 Project: Flink Issue Type: Bug

[GitHub] [flink] HuangXingBo closed pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

2021-08-30 Thread GitBox
HuangXingBo closed pull request #17010: URL: https://github.com/apache/flink/pull/17010 -- 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: issues-uns

[jira] [Resolved] (FLINK-24003) Lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

2021-08-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-24003. -- Resolution: Fixed Merged into master via cf08de4db65e0f224abf07673f8bffecda0013fb Merged into

[GitHub] [flink] gaborgsomogyi commented on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

2021-08-30 Thread GitBox
gaborgsomogyi commented on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-908934469 -- 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 un

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

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

[jira] [Commented] (FLINK-24035) Fix the deadlock issue caused by buffer listeners may not be notified

2021-08-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407102#comment-17407102 ] Piotr Nowojski commented on FLINK-24035: Merged to master as d82b69ef5db Merged

[GitHub] [flink-web] xintongsong commented on a change in pull request #464: announcing the rc0 for 1.14. and asking for help

2021-08-30 Thread GitBox
xintongsong commented on a change in pull request #464: URL: https://github.com/apache/flink-web/pull/464#discussion_r699006432 ## File path: _posts/2021-08-31-release-1.14.0-rc0.md ## @@ -0,0 +1,44 @@ +--- +layout: post +title: "Help us harden Apache Flink 1.14.0 RC0" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-907158087 ## CI report: * dd573c4bb1475210822d64e5df8b659f7ecc3546 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17056: [FLINK-23748][tests] Testing window TVF session window

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

[GitHub] [flink] flinkbot edited a comment on pull request #17065: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially

2021-08-30 Thread GitBox
flinkbot edited a comment on pull request #17065: URL: https://github.com/apache/flink/pull/17065#issuecomment-908917839 ## CI report: * d6889e3f8c9ee40c9dcce7b1691b85001371420a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-24065) Upgrade the TwoPhaseCommitSink to support empty transaction after finished

2021-08-30 Thread Yun Gao (Jira)
Yun Gao created FLINK-24065: --- Summary: Upgrade the TwoPhaseCommitSink to support empty transaction after finished Key: FLINK-24065 URL: https://issues.apache.org/jira/browse/FLINK-24065 Project: Flink

[GitHub] [flink] ruanhang1993 commented on pull request #17049: [FLINK-23971][tests] fix connector testing framework error when compare records in different splits

2021-08-30 Thread GitBox
ruanhang1993 commented on pull request #17049: URL: https://github.com/apache/flink/pull/17049#issuecomment-908939038 @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 spec

[jira] [Assigned] (FLINK-24065) Upgrade the TwoPhaseCommitSink to support empty transaction after finished

2021-08-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24065: -- Assignee: Yun Gao > Upgrade the TwoPhaseCommitSink to support empty transaction after

[GitHub] [flink] fapaul commented on a change in pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

2021-08-30 Thread GitBox
fapaul commented on a change in pull request #17058: URL: https://github.com/apache/flink/pull/17058#discussion_r699022014 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -613,134 +613,89 @@ Otherwise, the watermarks of the whole application cannot advance

[jira] [Created] (FLINK-24066) Provides a new stop entry for Kubernetes session mode

2021-08-30 Thread liuzhuo (Jira)
liuzhuo created FLINK-24066: --- Summary: Provides a new stop entry for Kubernetes session mode Key: FLINK-24066 URL: https://issues.apache.org/jira/browse/FLINK-24066 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-24067) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

2021-08-30 Thread Yun Gao (Jira)
Yun Gao created FLINK-24067: --- Summary: CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint Key: FLINK-24067 URL: https://issues.apache.org/jira/browse/FLINK-24067

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407114#comment-17407114 ] Xintong Song commented on FLINK-23556: -- It has been about one week without new inst

[jira] [Closed] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23556. Resolution: Fixed > SQLClientSchemaRegistryITCase fails with " Subject ... not found" > --

[jira] [Created] (FLINK-24068) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

2021-08-30 Thread Yun Gao (Jira)
Yun Gao created FLINK-24068: --- Summary: CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint Key: FLINK-24068 URL: https://issues.apache.org/jira/browse/FLINK-24068

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

2021-08-30 Thread GitBox
Airblader commented on a change in pull request #16805: URL: https://github.com/apache/flink/pull/16805#discussion_r688288352 ## File path: docs/data/sql_functions.yml ## @@ -83,7 +83,7 @@ logical: table: BOOLEAN1 && BOOLEAN2 description: Returns TRUE if BOOLEAN1 and

[jira] [Updated] (FLINK-24068) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

2021-08-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24068: Description: {code:java} 04:51:11,727 [Flat Map -> Sink: Unnamed (10/12)#1] WARN org.apache.flink.runtime

[GitHub] [flink] mas-chen commented on a change in pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

2021-08-30 Thread GitBox
mas-chen commented on a change in pull request #17007: URL: https://github.com/apache/flink/pull/17007#discussion_r699029340 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/FrontMetricGroup.java ## @@ -72,8 +74,15 @@ public MetricGroup getWrap

[jira] [Resolved] (FLINK-24035) Fix the deadlock issue caused by buffer listeners may not be notified

2021-08-30 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao resolved FLINK-24035. - Resolution: Fixed > Fix the deadlock issue caused by buffer listeners may not be notified >

[GitHub] [flink] mas-chen commented on a change in pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

2021-08-30 Thread GitBox
mas-chen commented on a change in pull request #17007: URL: https://github.com/apache/flink/pull/17007#discussion_r699029498 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java ## @@ -116,6 +117,34 @@ public ReporterSetup( }

[jira] [Updated] (FLINK-24035) Fix the deadlock issue caused by buffer listeners may not be notified

2021-08-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24035: --- Description: The buffer listeners are not notified when the the local buffer pool receives

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-08-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407117#comment-17407117 ] Xintong Song commented on FLINK-23493: -- https://dev.azure.com/apache-flink/apache-f

<    1   2   3   4   5   6   >