[jira] [Reopened] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-09-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-23525: -- new instance

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

2021-09-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416464#comment-17416464 ] Xintong Song commented on FLINK-23493: --

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17303: [FLINK-24300] SourceOperator#getAvailableFuture reuses future

2021-09-16 Thread GitBox
gaoyunhaii commented on a change in pull request #17303: URL: https://github.com/apache/flink/pull/17303#discussion_r710767054 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SourceNAryInputChainingITCase.java ## @@ -142,6 +153,26 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 2fcfaeb1a7b0fbaf8b5f65d4c4f9a7906af4e66b Azure:

[GitHub] [flink] flinkbot commented on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-16 Thread GitBox
flinkbot commented on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 2fcfaeb1a7b0fbaf8b5f65d4c4f9a7906af4e66b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

2021-09-16 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22643: - Affects Version/s: 1.14.0 > Too many TCP connections among TaskManagers for large scale jobs >

[jira] [Updated] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

2021-09-16 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22643: - Affects Version/s: (was: 1.13.0) 1.13.2 > Too many TCP connections

[jira] [Updated] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

2021-09-16 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22643: - Fix Version/s: (was: 1.14.0) > Too many TCP connections among TaskManagers for large scale

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

2021-09-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416444#comment-17416444 ] Xintong Song commented on FLINK-23493: --

[jira] [Commented] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2021-09-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416439#comment-17416439 ] godfrey he commented on FLINK-11484: blink planner is port to the flink community from v1.19, while

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * c8ea9552f00c97efc8cbb3e19fa23b89b8c69772 Azure:

[GitHub] [flink] flinkbot commented on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-16 Thread GitBox
flinkbot commented on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921452710 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] [Comment Edited] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416430#comment-17416430 ] shiwuliang edited comment on FLINK-24314 at 9/17/21, 4:18 AM: --

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Attachment: image-2021-09-17-12-16-46-277.png > Always use memory state backend with RocksDB >

[jira] [Commented] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416430#comment-17416430 ] shiwuliang commented on FLINK-24314: [~zlzhang0122] by the way, do u mean that I should config like

[jira] [Updated] (FLINK-24291) Decimal precision is lost when deserializing in test cases

2021-09-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24291: --- Fix Version/s: 1.14.1 1.13.3 > Decimal precision is lost when deserializing in

[jira] [Updated] (FLINK-24291) Decimal precision is lost when deserializing in test cases

2021-09-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24291: --- Fix Version/s: 1.15.0 > Decimal precision is lost when deserializing in test cases >

[jira] [Assigned] (FLINK-24291) Decimal precision is lost when deserializing in test cases

2021-09-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24291: -- Assignee: xuyangzhong > Decimal precision is lost when deserializing in test cases >

[jira] [Updated] (FLINK-24291) Decimal precision is lost when deserializing in test cases

2021-09-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24291: --- Labels: pull-request-available (was: ) > Decimal precision is lost when deserializing in

[GitHub] [flink] xuyangzhong opened a new pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

2021-09-16 Thread GitBox
xuyangzhong opened a new pull request #17308: URL: https://github.com/apache/flink/pull/17308 ## What is the purpose of the change Get the correct converter which is used to deserialize a decimal field by setting it the correct precision information. ## Brief change log

[jira] [Updated] (FLINK-24291) Decimal precision is lost when deserializing in test cases

2021-09-16 Thread xuyangzhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyangzhong updated FLINK-24291: Summary: Decimal precision is lost when deserializing in test cases (was: Decimal precision is

[jira] [Commented] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416427#comment-17416427 ] shiwuliang commented on FLINK-24314: [~zlzhang0122] hi, thanks for your reply.   But in

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Attachment: image-2021-09-17-12-04-55-009.png > Always use memory state backend with RocksDB >

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Attachment: image-2021-09-17-12-03-58-285.png > Always use memory state backend with RocksDB >

[GitHub] [flink] RocMarshal commented on pull request #17279: [Hotfix][streaming] Fix a typo.

2021-09-16 Thread GitBox
RocMarshal commented on pull request #17279: URL: https://github.com/apache/flink/pull/17279#issuecomment-921439012 Hi, @alpinegizmo . Could you help me to check it ? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] xuyangzhong closed pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

2021-09-16 Thread GitBox
xuyangzhong closed pull request #17089: URL: https://github.com/apache/flink/pull/17089 -- 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 edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * c8ea9552f00c97efc8cbb3e19fa23b89b8c69772 Azure:

[jira] [Comment Edited] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416426#comment-17416426 ] zlzhang0122 edited comment on FLINK-24314 at 9/17/21, 3:54 AM: --- In Flink

[jira] [Commented] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416426#comment-17416426 ] zlzhang0122 commented on FLINK-24314: - In Flink 1.13, the storage of the state and checkpoint was

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-09-16 Thread GitBox
RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-920520153 Hi, @wuchong @twalthr @zhuzhurk @leonardBang . I made some changes in the ITCase part of the PR. Could you help me to review this PR if you have free time? Thank

[GitHub] [flink] flinkbot edited a comment on pull request #17306: [BP-1.13][FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not speci

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17306: URL: https://github.com/apache/flink/pull/17306#issuecomment-921415622 ## CI report: * 67cc66fea096aae34129fb36bfff203e2b96b3eb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17307: [BP-1.12][FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not speci

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17307: URL: https://github.com/apache/flink/pull/17307#issuecomment-921415679 ## CI report: * 2d451af80e6af332a6f0d336e47244e59a790d75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * c8ea9552f00c97efc8cbb3e19fa23b89b8c69772 Azure:

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

2021-09-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416421#comment-17416421 ] Xintong Song commented on FLINK-15493: --

[GitHub] [flink] flinkbot edited a comment on pull request #16792: [FLINK-23739][table]BlackHoleSink & PrintSink implement SupportsParti…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #16792: URL: https://github.com/apache/flink/pull/16792#issuecomment-897629413 ## CI report: * 7c7c6b78520a4daa62d0844c063fd68e9bcc9387 Azure:

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Description: When I config to use `RocksDBStatebackend`,    {code:java} //代码占位符

[jira] [Commented] (FLINK-23271) RuntimeException: while resolving method 'booleanValue' in class class java.math.BigDecimal

2021-09-16 Thread xuyangzhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416419#comment-17416419 ] xuyangzhong commented on FLINK-23271: - link: https://issues.apache.org/jira/browse/CALCITE-4777 >

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Description: When I config to use `RocksDBStatebackend`,    ``` RocksDBStateBackend

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Description: When I config to use `RocksDBStatebackend`,    there are some exception like this:

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Attachment: (was: image-2021-09-17-11-05-16-662.png) > Always use memory state backend with

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Attachment: image-2021-09-17-11-05-16-662.png Description: When I config to use

[jira] [Updated] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shiwuliang updated FLINK-24314: --- Description: !image-2021-09-17-10-59-50-094.png|width=1446,height=420! (was:

[jira] [Created] (FLINK-24314) Always use memory state backend with RocksDB

2021-09-16 Thread shiwuliang (Jira)
shiwuliang created FLINK-24314: -- Summary: Always use memory state backend with RocksDB Key: FLINK-24314 URL: https://issues.apache.org/jira/browse/FLINK-24314 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #17307: [BP-1.12][FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not specified

2021-09-16 Thread GitBox
flinkbot commented on pull request #17307: URL: https://github.com/apache/flink/pull/17307#issuecomment-921415679 ## CI report: * 2d451af80e6af332a6f0d336e47244e59a790d75 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17306: [BP-1.13][FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not specified

2021-09-16 Thread GitBox
flinkbot commented on pull request #17306: URL: https://github.com/apache/flink/pull/17306#issuecomment-921415622 ## CI report: * 67cc66fea096aae34129fb36bfff203e2b96b3eb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * c8ea9552f00c97efc8cbb3e19fa23b89b8c69772 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-900037847 ## CI report: * 0cc6f3f9235ffe069ca7eb7feac3e641cbe3cb22 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16792: [FLINK-23739][table]BlackHoleSink & PrintSink implement SupportsParti…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #16792: URL: https://github.com/apache/flink/pull/16792#issuecomment-897629413 ## CI report: * 7c7c6b78520a4daa62d0844c063fd68e9bcc9387 Azure:

[GitHub] [flink] beyond1920 commented on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

2021-09-16 Thread GitBox
beyond1920 commented on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-921409748 @godfreyhe Thanks very much for review. I've updated the pr, please have a look. Thanks. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-900037847 ## CI report: * 0cc6f3f9235ffe069ca7eb7feac3e641cbe3cb22 Azure:

[GitHub] [flink] godfreyhe commented on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

2021-09-16 Thread GitBox
godfreyhe commented on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-921406598 @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 commented on pull request #17306: [BP-1.13][FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

2021-09-16 Thread GitBox
flinkbot commented on pull request #17306: URL: https://github.com/apache/flink/pull/17306#issuecomment-921406362 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 commented on pull request #17307: [BP-1.12][FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

2021-09-16 Thread GitBox
flinkbot commented on pull request #17307: URL: https://github.com/apache/flink/pull/17307#issuecomment-921406349 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] PatrickRen opened a new pull request #17307: [BP-1.12][FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

2021-09-16 Thread GitBox
PatrickRen opened a new pull request #17307: URL: https://github.com/apache/flink/pull/17307 Unchanged back-port of #17276 on release-1.12 -- 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] PatrickRen opened a new pull request #17306: [BP-1.13][FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

2021-09-16 Thread GitBox
PatrickRen opened a new pull request #17306: URL: https://github.com/apache/flink/pull/17306 Unchanged back-port of #17276 on release-1.13 -- 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

[jira] [Issue Comment Deleted] (FLINK-11250) fix thread leaked when StreamTask switched from DEPLOYING to CANCELING

2021-09-16 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-11250: - Comment: was deleted (was: merged commit 

[jira] [Resolved] (FLINK-11250) fix thread leaked when StreamTask switched from DEPLOYING to CANCELING

2021-09-16 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-11250. -- Resolution: Fixed merged commit 

[jira] [Commented] (FLINK-11250) fix thread leaked when StreamTask switched from DEPLOYING to CANCELING

2021-09-16 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416394#comment-17416394 ] Yuan Mei commented on FLINK-11250: -- merged commit 

[GitHub] [flink] curcur merged pull request #17187: [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor

2021-09-16 Thread GitBox
curcur merged pull request #17187: URL: https://github.com/apache/flink/pull/17187 -- 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] curcur commented on pull request #17187: [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor

2021-09-16 Thread GitBox
curcur commented on pull request #17187: URL: https://github.com/apache/flink/pull/17187#issuecomment-921401303 Thanks @akalash for fixing The failure does not seem to be related. merged. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

2021-09-16 Thread GitBox
Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r710671588 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/restore/ChangelogBackendRestoreOperation.java

[jira] [Updated] (FLINK-23180) Initialize checkpoint location lazily in DataStream Batch Jobs

2021-09-16 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23180: - Fix Version/s: 1.15.0 > Initialize checkpoint location lazily in DataStream Batch Jobs >

[jira] [Resolved] (FLINK-23180) Initialize checkpoint location lazily in DataStream Batch Jobs

2021-09-16 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23180. -- Release Note: merged in master: 164a59ac1bb4dd39e6532478c30234eeafd76cd0 Resolution: Fixed >

[GitHub] [flink] Myasuka merged pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

2021-09-16 Thread GitBox
Myasuka merged pull request #17151: URL: https://github.com/apache/flink/pull/17151 -- 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] JingsongLi closed pull request #11281: [FLINK-16203][sql] Support JSON_OBJECT for blink planner

2021-09-16 Thread GitBox
JingsongLi closed pull request #11281: URL: https://github.com/apache/flink/pull/11281 -- 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] [Closed] (FLINK-16203) Support JSON_OBJECT

2021-09-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16203. Fix Version/s: 1.15.0 Resolution: Fixed Implemented via master:

[GitHub] [flink] JingsongLi closed pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

2021-09-16 Thread GitBox
JingsongLi closed pull request #17186: URL: https://github.com/apache/flink/pull/17186 -- 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-24313) JdbcCatalogFactoryTest fails due to "Gave up waiting for server to start after 10000ms"

2021-09-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24313: - Labels: test-stability (was: ) > JdbcCatalogFactoryTest fails due to "Gave up waiting for

[jira] [Created] (FLINK-24313) JdbcCatalogFactoryTest fails due to "Gave up waiting for server to start after 10000ms"

2021-09-16 Thread Xintong Song (Jira)
Xintong Song created FLINK-24313: Summary: JdbcCatalogFactoryTest fails due to "Gave up waiting for server to start after 1ms" Key: FLINK-24313 URL: https://issues.apache.org/jira/browse/FLINK-24313

[jira] [Created] (FLINK-24312) 'New File Sink s3 end-to-end test' fails due to timeout

2021-09-16 Thread Xintong Song (Jira)
Xintong Song created FLINK-24312: Summary: 'New File Sink s3 end-to-end test' fails due to timeout Key: FLINK-24312 URL: https://issues.apache.org/jira/browse/FLINK-24312 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17305: [hotfix][flink-avro] Removed unused variable

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17305: URL: https://github.com/apache/flink/pull/17305#issuecomment-921331062 ## CI report: * 278a30ff968c3d10a7f202395a52e4a3536679a1 Azure:

[GitHub] [flink] flinkbot commented on pull request #17305: [hotfix][flink-avro] Removed unused variable

2021-09-16 Thread GitBox
flinkbot commented on pull request #17305: URL: https://github.com/apache/flink/pull/17305#issuecomment-921331062 ## CI report: * 278a30ff968c3d10a7f202395a52e4a3536679a1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17159: [FLINK-24129][connectors-pulsar] Harden TopicRangeTest.rangeCreationH…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17159: URL: https://github.com/apache/flink/pull/17159#issuecomment-913532879 ## CI report: * ea9955b8eea862e516f4f420f4ea58d4745d6180 Azure:

[GitHub] [flink] flinkbot commented on pull request #17305: [hotfix][flink-avro] Removed unused variable

2021-09-16 Thread GitBox
flinkbot commented on pull request #17305: URL: https://github.com/apache/flink/pull/17305#issuecomment-921312448 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] mans2singh opened a new pull request #17305: [hotfix][flink-avro] Removed unused variable

2021-09-16 Thread GitBox
mans2singh opened a new pull request #17305: URL: https://github.com/apache/flink/pull/17305 ## What is the purpose of the change * The variable is actualSchema declared but not used. ## Brief change log * Removed unused variable. ## Verifying this change

[jira] [Updated] (FLINK-20661) Elasticsearch6DynamicSinkITCase.testWritingDocuments test failed with ConnectException

2021-09-16 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20661: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

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

[jira] [Updated] (FLINK-23739) PrintTableSink do not implement SupportsPartitioning interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #17159: [FLINK-24129][connectors-pulsar] Harden TopicRangeTest.rangeCreationH…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17159: URL: https://github.com/apache/flink/pull/17159#issuecomment-913532879 ## CI report: * ea9955b8eea862e516f4f420f4ea58d4745d6180 Azure:

[GitHub] [flink] dmvk commented on a change in pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

2021-09-16 Thread GitBox
dmvk commented on a change in pull request #17137: URL: https://github.com/apache/flink/pull/17137#discussion_r702880423 ## File path: flink-end-to-end-tests/test-scripts/common_ha.sh ## @@ -127,6 +127,18 @@ function kill_single { echo "Killed JM @ ${PID}" } +function

[GitHub] [flink] dmvk commented on pull request #17159: [FLINK-24129][connectors-pulsar] Harden TopicRangeTest.rangeCreationH…

2021-09-16 Thread GitBox
dmvk commented on pull request #17159: URL: https://github.com/apache/flink/pull/17159#issuecomment-921280507 @XComp Thanks for the review, I've addressed your comments, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #17304: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector. [1.14]

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17304: URL: https://github.com/apache/flink/pull/17304#issuecomment-921026449 ## CI report: * 22b0273f342094db631be2361a53b7c81b853f6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17264: [FLINK-24253][JDBC] Load JdbcDialects via Service Loaders

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17264: URL: https://github.com/apache/flink/pull/17264#issuecomment-918259683 ## CI report: * 40850458353ee9014c1e9b28c1a6907c97896fc6 Azure:

[jira] [Commented] (FLINK-24301) use Async transport on all statefun playground examples

2021-09-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416329#comment-17416329 ] Seth Wiesman commented on FLINK-24301: -- fixed in dev: dffc59428a91853332a038e9d13970108d2302e9

[jira] [Closed] (FLINK-24301) use Async transport on all statefun playground examples

2021-09-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24301. Resolution: Fixed > use Async transport on all statefun playground examples >

[jira] [Closed] (FLINK-24284) Add a greeter and a showcase for the JavaScript SDK

2021-09-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24284. Resolution: Done > Add a greeter and a showcase for the JavaScript SDK >

[jira] [Commented] (FLINK-24284) Add a greeter and a showcase for the JavaScript SDK

2021-09-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416327#comment-17416327 ] Seth Wiesman commented on FLINK-24284: -- fixed in dev: 3b52dfc554540c03dbd4b2acfa4440ceb8914e38 >

[jira] [Updated] (FLINK-24301) use Async transport on all statefun playground examples

2021-09-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24301: --- Labels: pull-request-available (was: ) > use Async transport on all statefun playground

[GitHub] [flink-statefun-playground] sjwiesman closed pull request #14: [FLINK-24301] use Async transport on all statefun playground examples

2021-09-16 Thread GitBox
sjwiesman closed pull request #14: URL: https://github.com/apache/flink-statefun-playground/pull/14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe,

[GitHub] [flink] flinkbot edited a comment on pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-913110826 ## CI report: * 4b431b9e8b67caf75739a39180715e0fcc23279e UNKNOWN * 04ed85a5788c897214f073694f8a3196688b0c7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17294: [BP-1.14][FLINK-24281][connectors/kafka] Migrate all format tests from FlinkKafkaProducer to KafkaSink

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17294: URL: https://github.com/apache/flink/pull/17294#issuecomment-920662267 ## CI report: * 3f048d3f5981814b9c0967e7efc760a06ee0e72a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17187: [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17187: URL: https://github.com/apache/flink/pull/17187#issuecomment-914504554 ## CI report: * 9295f1fa3a30daa92b0efef34a61f073acf10151 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-913110826 ## CI report: * 4b431b9e8b67caf75739a39180715e0fcc23279e UNKNOWN * 04ed85a5788c897214f073694f8a3196688b0c7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * aed2811ee91a0d21c1c3af54b7c2a84a48142ce6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17304: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector. [1.14]

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17304: URL: https://github.com/apache/flink/pull/17304#issuecomment-921026449 ## CI report: * ccbe0fd32d2b00f085e073a5ea0e2d3dfc863ac5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17264: [FLINK-24253][JDBC] Load JdbcDialects via Service Loaders

2021-09-16 Thread GitBox
flinkbot edited a comment on pull request #17264: URL: https://github.com/apache/flink/pull/17264#issuecomment-918259683 ## CI report: * 37bbf283bb26fd04ee6aae33578ba81ec7223e73 Azure:

[jira] [Updated] (FLINK-24300) MultipleInputOperator is running much more slowly in TPCDS

2021-09-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24300: - Fix Version/s: (was: 1.15.0) > MultipleInputOperator is running much more slowly in

[GitHub] [flink] dawidwys edited a comment on pull request #17303: [FLINK-24300] SourceOperator#getAvailableFuture reuses future

2021-09-16 Thread GitBox
dawidwys edited a comment on pull request #17303: URL: https://github.com/apache/flink/pull/17303#issuecomment-921137756 I triggered a benchmark request: http://codespeed.dak8s.net:8080/job/flink-benchmark-request/494/ -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] dawidwys commented on pull request #17303: [FLINK-24300] SourceOperator#getAvailableFuture reuses future

2021-09-16 Thread GitBox
dawidwys commented on pull request #17303: URL: https://github.com/apache/flink/pull/17303#issuecomment-921137756 I triggered benchmark request: http://codespeed.dak8s.net:8080/job/flink-benchmark-request/494/ -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] dawidwys commented on a change in pull request #17303: [FLINK-24300] SourceOperator#getAvailableFuture reuses future

2021-09-16 Thread GitBox
dawidwys commented on a change in pull request #17303: URL: https://github.com/apache/flink/pull/17303#discussion_r710365769 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SourceNAryInputChainingITCase.java ## @@ -142,6 +153,26 @@ public void

  1   2   3   4   >