[jira] [Created] (FLINK-21753) Cycle references between memory manager and gc cleaner action

2021-03-12 Thread Kezhu Wang (Jira)
Kezhu Wang created FLINK-21753: -- Summary: Cycle references between memory manager and gc cleaner action Key: FLINK-21753 URL: https://issues.apache.org/jira/browse/FLINK-21753 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * 38f1cea9a24f244241f6e2a9f069feb7f774652c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-797861091 ## CI report: * faa510486a60de5f71d9cf924ae47fcac04560ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * 38f1cea9a24f244241f6e2a9f069feb7f774652c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 7383416dfaf59f0aeebc77450b6c3dc9b495789a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-797861091 ## CI report: * faa510486a60de5f71d9cf924ae47fcac04560ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 7383416dfaf59f0aeebc77450b6c3dc9b495789a Azure:

[GitHub] [flink] LadyForest commented on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

2021-03-12 Thread GitBox
LadyForest commented on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-797876066 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source

2021-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21523: Fix Version/s: 1.12.3 > ArrayIndexOutOfBoundsException occurs while run a hive streaming job with >

[jira] [Comment Edited] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source

2021-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300210#comment-17300210 ] Jark Wu edited comment on FLINK-21523 at 3/13/21, 6:19 AM: --- Fixed in -

[GitHub] [flink] wuchong merged pull request #15169: [BP-1.12][FLINK-21523][hive] Fix ArrayIndexOutOfBoundsException when running hive partitioned source with projection push down

2021-03-12 Thread GitBox
wuchong merged pull request #15169: URL: https://github.com/apache/flink/pull/15169 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

[jira] [Commented] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

2021-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300736#comment-17300736 ] Jark Wu commented on FLINK-21747: - We had a discussion in FLINK-20388. > Encounter an exception that

[jira] [Assigned] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21466: --- Assignee: zck > Make "embedded" parameter optional when start sql-client.sh >

[GitHub] [flink] flinkbot edited a comment on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15175: URL: https://github.com/apache/flink/pull/15175#issuecomment-797871668 ## CI report: * 62141a2aff3348088ceb5eb6c449e9abfe5f9870 Azure:

[jira] [Assigned] (FLINK-21702) Support option `sql-client.verbose` to print the exception stack

2021-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21702: --- Assignee: zhuxiaoshang > Support option `sql-client.verbose` to print the exception stack >

[GitHub] [flink] flinkbot edited a comment on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15175: URL: https://github.com/apache/flink/pull/15175#issuecomment-797871668 ## CI report: * 62141a2aff3348088ceb5eb6c449e9abfe5f9870 Azure:

[GitHub] [flink] flinkbot commented on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

2021-03-12 Thread GitBox
flinkbot commented on pull request #15175: URL: https://github.com/apache/flink/pull/15175#issuecomment-797871668 ## CI report: * 62141a2aff3348088ceb5eb6c449e9abfe5f9870 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-797861091 ## CI report: * faa510486a60de5f71d9cf924ae47fcac04560ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 7383416dfaf59f0aeebc77450b6c3dc9b495789a Azure:

[GitHub] [flink] rionmonster commented on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

2021-03-12 Thread GitBox
rionmonster commented on pull request #15175: URL: https://github.com/apache/flink/pull/15175#issuecomment-797867198 @zentol I decided to make another, different pass at this guy since the last PR seemed to be a bit all over the place. I migrated almost all of the logic to

[GitHub] [flink] flinkbot commented on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

2021-03-12 Thread GitBox
flinkbot commented on pull request #15175: URL: https://github.com/apache/flink/pull/15175#issuecomment-797866980 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] rionmonster opened a new pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

2021-03-12 Thread GitBox
rionmonster opened a new pull request #15175: URL: https://github.com/apache/flink/pull/15175 ## What is the purpose of the change Clean-up for the initialization of the two Prometheus Metric Reporters (`PrometheusReporter` and `PrometheusPushGatewayReporter`) by explicitly passing

[GitHub] [flink] flinkbot edited a comment on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-797861091 ## CI report: * faa510486a60de5f71d9cf924ae47fcac04560ff Azure:

[GitHub] [flink] flinkbot commented on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

2021-03-12 Thread GitBox
flinkbot commented on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-797861091 ## CI report: * faa510486a60de5f71d9cf924ae47fcac04560ff UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

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

[jira] [Updated] (FLINK-21651) Migrate module-related tests in LocalExecutorITCase to new integration test framework

2021-03-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21651: --- Labels: pull-request-available (was: ) > Migrate module-related tests in

[GitHub] [flink] LadyForest opened a new pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

2021-03-12 Thread GitBox
LadyForest opened a new pull request #15174: URL: https://github.com/apache/flink/pull/15174 ## Brief change log This PR migrates the tests in`LocalExecutorITCase` to `CliClientITCase`, and removes `#listModules` and `#listFullModules` in `LocalExecutor` since they are not needed

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-12 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300669#comment-17300669 ] zck commented on FLINK-21466: - [~jark] plz assign to me > Make "embedded" parameter optional when start

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-12 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300668#comment-17300668 ] zck commented on FLINK-21466: - plz assign to me > Make "embedded" parameter optional when start

[jira] [Commented] (FLINK-21674) JDBC sink can't get valid connection after 5 minutes using Oracle JDBC driver

2021-03-12 Thread Fuyao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300667#comment-17300667 ] Fuyao commented on FLINK-21674: --- I was not aware of this earlier, finally I find someone who knows some

[jira] [Resolved] (FLINK-21674) JDBC sink can't get valid connection after 5 minutes using Oracle JDBC driver

2021-03-12 Thread Fuyao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fuyao resolved FLINK-21674. --- Resolution: Fixed > JDBC sink can't get valid connection after 5 minutes using Oracle JDBC driver >

[jira] [Updated] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

2021-03-12 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tim yu updated FLINK-21747: --- Description: I run a stream job with insert statement whose size is too long, it report metrics to

[jira] [Commented] (FLINK-21674) JDBC sink can't get valid connection after 5 minutes using Oracle JDBC driver

2021-03-12 Thread Fuyao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300666#comment-17300666 ] Fuyao commented on FLINK-21674: --- Hi Roman, thanks for your help.  I was able to figure out the root

[jira] [Comment Edited] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

2021-03-12 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300665#comment-17300665 ] tim yu edited comment on FLINK-21747 at 3/13/21, 1:10 AM: -- Hi [~chesnay],

[jira] [Commented] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

2021-03-12 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300665#comment-17300665 ] tim yu commented on FLINK-21747: Hi [~chesnay], Thanks for your suggestion, but that is not perfect way.

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 76fdf33da7a9809d4c3b5fda8164d86880a39cac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * dfe55bcf15e82fa63e85551fba2e0b415bba8dae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * dfe55bcf15e82fa63e85551fba2e0b415bba8dae Azure:

[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

2021-03-12 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300636#comment-17300636 ] Austin Cawley-Edwards commented on FLINK-21538: --- Test debug build here:

[GitHub] [flink] rionmonster commented on pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-12 Thread GitBox
rionmonster commented on pull request #15165: URL: https://github.com/apache/flink/pull/15165#issuecomment-797790797 @zentol I'll be submitting another PR once this work is done, ran into some git issues and decided to scorch the earth in the interested of keeping things clean.

[GitHub] [flink] rionmonster closed pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-12 Thread GitBox
rionmonster closed pull request #15165: URL: https://github.com/apache/flink/pull/15165 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

[GitHub] [flink] rionmonster commented on a change in pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-12 Thread GitBox
rionmonster commented on a change in pull request #15165: URL: https://github.com/apache/flink/pull/15165#discussion_r593477758 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java ## @@

[jira] [Assigned] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

2021-03-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-21743: - Assignee: Roman Khachatryan > JdbcXaSinkFunction throws XAER_RMFAIL when

[jira] [Commented] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

2021-03-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300627#comment-17300627 ] Roman Khachatryan commented on FLINK-21743: --- Works fine on postgresql (after increasing

[GitHub] [flink] flinkbot edited a comment on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-795077470 ## CI report: * 63851b4ad1d97292257cb8cb02f6bd211b503979 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * dfe55bcf15e82fa63e85551fba2e0b415bba8dae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * 38f1cea9a24f244241f6e2a9f069feb7f774652c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * dfe55bcf15e82fa63e85551fba2e0b415bba8dae Azure:

[GitHub] [flink] twalthr closed pull request #15154: [FLINK-21725][core] Name constructor arguments of Tuples like fields

2021-03-12 Thread GitBox
twalthr closed pull request #15154: URL: https://github.com/apache/flink/pull/15154 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot commented on pull request #15173: [FLINK-21367][Connectors / JDBC] Support objectReuse in JDBC sink

2021-03-12 Thread GitBox
flinkbot commented on pull request #15173: URL: https://github.com/apache/flink/pull/15173#issuecomment-797709378 ## CI report: * c2d910a15fa478f09f81913837d14aa4782601b2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15171: [FLINK-21558][coordination] Skip check if slotreport indicates no change

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15171: URL: https://github.com/apache/flink/pull/15171#issuecomment-797538070 ## CI report: * eaf04db0fc9193bb77e3ecb917f828f2adbbca14 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * dfe55bcf15e82fa63e85551fba2e0b415bba8dae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15172: [FLINK-21388] [flink-parquet] support DECIMAL parquet logical type wh…

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15172: URL: https://github.com/apache/flink/pull/15172#issuecomment-797538175 ## CI report: * 06cea2c4d6cc6724f86063ddb5974c88ae9629b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15154: [FLINK-21725][core] Name constructor arguments of Tuples like fields

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15154: URL: https://github.com/apache/flink/pull/15154#issuecomment-796737826 ## CI report: * 4572f80bab02248b8d5d1f8d2bda99f9a933e17f Azure:

[GitHub] [flink] flinkbot commented on pull request #15173: Flink-21367

2021-03-12 Thread GitBox
flinkbot commented on pull request #15173: URL: https://github.com/apache/flink/pull/15173#issuecomment-797679900 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] tillrohrmann merged pull request #15107: [BP-1.11][FLINK-21606] Reject JobManager <-> TaskManager connection if JobManager is not responsible for job

2021-03-12 Thread GitBox
tillrohrmann merged pull request #15107: URL: https://github.com/apache/flink/pull/15107 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

[GitHub] [flink] Bruschkov opened a new pull request #15173: Flink-21367

2021-03-12 Thread GitBox
Bruschkov opened a new pull request #15173: URL: https://github.com/apache/flink/pull/15173 ## What is the purpose of the change * Users should now be able to use the jdbc-sink when object reuse is enabled (or from stateful functions, where object reuse is enabled explicitly)

[jira] [Commented] (FLINK-21597) testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException"

2021-03-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300540#comment-17300540 ] Matthias commented on FLINK-21597: -- I attached the test failure's log for easier analysis. We have a

[jira] [Updated] (FLINK-21597) testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException"

2021-03-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21597: - Attachment: FLINK-21597.log > testMapAfterRepartitionHasCorrectParallelism2 Fail because of >

[jira] [Closed] (FLINK-21606) TaskManager connected to invalid JobManager leading to TaskSubmissionException

2021-03-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-21606. - Fix Version/s: 1.12.3 1.11.4 Resolution: Fixed Fixed via 1.13.0:

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

2021-03-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300526#comment-17300526 ] Till Rohrmann commented on FLINK-16908: --- Another instance:

[GitHub] [flink] tillrohrmann edited a comment on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-03-12 Thread GitBox
tillrohrmann edited a comment on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-797663142 Here is [a branch with a simple StopWithSavepoint implementation](https://github.com/tillrohrmann/flink/tree/FLINK-21333). Let me know what you think @rmetzger.

[GitHub] [flink] tillrohrmann commented on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-03-12 Thread GitBox
tillrohrmann commented on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-797663142 Here is [a branch with a simple `StopWithSavepoint` implementation](https://github.com/tillrohrmann/flink/tree/FLINK-21333). Let me know what you think. This can

[GitHub] [flink] flinkbot edited a comment on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-795077470 ## CI report: * f77abc145b06b6ef3a745ab382c1761ecae752d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15106: [BP-1.12][FLINK-21606] Reject JobManager <-> TaskManager connection if JobManager is not responsible for job

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15106: URL: https://github.com/apache/flink/pull/15106#issuecomment-792330426 ## CI report: * 8bf221d8f00686baafe48f05adc458406189dcd3 Azure:

[jira] [Closed] (FLINK-21709) Officially deprecate the legacy planner

2021-03-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-21709. Fix Version/s: 1.13.0 Release Note: The old planner of the Table & SQL API is deprecated and

[GitHub] [flink] flinkbot edited a comment on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779946654 ## CI report: * 097472900d4be5c87466bf7678aa506f6fd5d463 UNKNOWN * f13e6af735ee5c4e7917f9d8ee1e8c84208ef2ff Azure:

[GitHub] [flink] zentol commented on a change in pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-12 Thread GitBox
zentol commented on a change in pull request #15165: URL: https://github.com/apache/flink/pull/15165#discussion_r593355790 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java ## @@ -56,43

[GitHub] [flink] twalthr closed pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

2021-03-12 Thread GitBox
twalthr closed pull request #15144: URL: https://github.com/apache/flink/pull/15144 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * fce5cb5d02a79b95ceb3a5bbf41be7d186e2fb85 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-795077470 ## CI report: * f77abc145b06b6ef3a745ab382c1761ecae752d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15105: [FLINK-21606] Reject JobManager <-> TaskManager connection if JobManager is not responsible for job

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15105: URL: https://github.com/apache/flink/pull/15105#issuecomment-792330363 ## CI report: * 6d709fcabe70bf783f83d9906ae4b1550d894096 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15107: [BP-1.11][FLINK-21606] Reject JobManager <-> TaskManager connection if JobManager is not responsible for job

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15107: URL: https://github.com/apache/flink/pull/15107#issuecomment-792330475 ## CI report: * 7edd724e13616e44c5b9aeff409aecdd910dc3fe Azure:

[GitHub] [flink] XComp commented on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-12 Thread GitBox
XComp commented on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-797643595 I addressed your comments, squashed and rebased the branch This is an automated message from the Apache Git

[GitHub] [flink] XComp commented on a change in pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-12 Thread GitBox
XComp commented on a change in pull request #15049: URL: https://github.com/apache/flink/pull/15049#discussion_r593343570 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExceptionHistoryEntry.java ## @@ -0,0 +1,95 @@ +/* + * Licensed to the Apache

[GitHub] [flink] XComp commented on a change in pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-12 Thread GitBox
XComp commented on a change in pull request #15049: URL: https://github.com/apache/flink/pull/15049#discussion_r593341506 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobExceptionsHandler.java ## @@ -132,7 +142,62 @@ private static

[jira] [Updated] (FLINK-21752) NullPointerException on restore in PojoSerializer

2021-03-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21752: -- Description: As originally reported in

[jira] [Created] (FLINK-21752) NullPointerException on restore in PojoSerializer

2021-03-12 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21752: - Summary: NullPointerException on restore in PojoSerializer Key: FLINK-21752 URL: https://issues.apache.org/jira/browse/FLINK-21752 Project: Flink

[GitHub] [flink] XComp commented on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-12 Thread GitBox
XComp commented on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-797634153 I applied your comments, squashed the commits and rebased the branch. This is an automated message from the

[GitHub] [flink] XComp commented on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-12 Thread GitBox
XComp commented on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-797633919 > Thanks for creating this PR @XComp. I think the change makes sense. I had a few minor comments. > > Why is this problem only limited to when we close the `YarnTestBase`?

[GitHub] [flink] Yanikovic commented on a change in pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

2021-03-12 Thread GitBox
Yanikovic commented on a change in pull request #15140: URL: https://github.com/apache/flink/pull/15140#discussion_r593330541 ## File path: flink-connectors/flink-connector-rabbitmq2/src/main/java/org/apache/flink/connector/rabbitmq2/sink/RabbitMQSink.java ## @@ -0,0 +1,229

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * fce5cb5d02a79b95ceb3a5bbf41be7d186e2fb85 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * dfb0e42f28b809d98e5dec29e9540111e1aa7b10 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN *

[jira] [Commented] (FLINK-21702) Support option `sql-client.verbose` to print the exception stack

2021-03-12 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300429#comment-17300429 ] zhuxiaoshang commented on FLINK-21702: -- [~fsk119] [~jark] plz assign to me. > Support option

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-12 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300427#comment-17300427 ] zhuxiaoshang commented on FLINK-21466: -- [~fsk119] [~jark] plz assign to me. > Make "embedded"

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN *

[GitHub] [flink] tillrohrmann commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-03-12 Thread GitBox
tillrohrmann commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r593279092 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java ## @@ -143,6 +145,26 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #15170: [FLINK-21610][tests] Do not attempt to cancel the job

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15170: URL: https://github.com/apache/flink/pull/15170#issuecomment-797471124 ## CI report: * 8f387ae8f7bf9ef74c971efd22704d85eec8e68f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15154: [FLINK-21725][core] Name constructor arguments of Tuples like fields

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15154: URL: https://github.com/apache/flink/pull/15154#issuecomment-796737826 ## CI report: * 3040b7bdca9f57ca1a34a89cb057ff7b4d7124fe Azure:

[GitHub] [flink] rionmonster commented on a change in pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-12 Thread GitBox
rionmonster commented on a change in pull request #15165: URL: https://github.com/apache/flink/pull/15165#discussion_r593281214 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporterFactory.java ##

[GitHub] [flink] rionmonster commented on a change in pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-12 Thread GitBox
rionmonster commented on a change in pull request #15165: URL: https://github.com/apache/flink/pull/15165#discussion_r593279557 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #15163: [FLINK-21710][table-planner-blink] FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15163: URL: https://github.com/apache/flink/pull/15163#issuecomment-797203134 ## CI report: * 6563e261e69a04e6428e7cd766273e5a3967abe9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15154: [FLINK-21725][core] Name constructor arguments of Tuples like fields

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15154: URL: https://github.com/apache/flink/pull/15154#issuecomment-796737826 ## CI report: * 3040b7bdca9f57ca1a34a89cb057ff7b4d7124fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15144: URL: https://github.com/apache/flink/pull/15144#issuecomment-796504890 ## CI report: * cf09b912a5b2e94d7df1339d71f532568216e308 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

2021-03-12 Thread GitBox
flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * abab5960a130986aca48bd51aec2b897205106c9 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #15153: [FLINK-21707][runtime] Do not trigger scheduling of non-CREATED regions in PipelinedRegionSchedulingStrategy

2021-03-12 Thread GitBox
tillrohrmann commented on a change in pull request #15153: URL: https://github.com/apache/flink/pull/15153#discussion_r593272810 ## File path: flink-tests/src/test/java/org/apache/flink/test/scheduling/PipelinedRegionSchedulingITCase.java ## @@ -204,4 +248,22 @@ public void

[GitHub] [flink] knaufk commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

2021-03-12 Thread GitBox
knaufk commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r593257043 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +#

  1   2   3   4   >