[GitHub] [flink] flinkbot commented on pull request #17148: [FLINK-24158][runtime] Remove useless collector in LimitOperator

2021-09-03 Thread GitBox
flinkbot commented on pull request #17148: URL: https://github.com/apache/flink/pull/17148#issuecomment-912915087 ## CI report: * 95e9cb3361f5477bd111a1be0a61e8073ede6a07 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17143: [release-1.14][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17143: URL: https://github.com/apache/flink/pull/17143#issuecomment-912869331 ## CI report: * 3faf6ec7a4531b97d39ec47d6f0760dc01da9459 Azure:

[jira] [Comment Edited] (FLINK-23820) Test profiling for Python user-defined functions

2021-09-03 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409833#comment-17409833 ] JING ZHANG edited comment on FLINK-23820 at 9/4/21, 5:48 AM: - Results are

[jira] [Commented] (FLINK-23820) Test profiling for Python user-defined functions

2021-09-03 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409836#comment-17409836 ] JING ZHANG commented on FLINK-23820: [~hxbks2ks] Hi xingbo, please check whether above verify method

[jira] [Commented] (FLINK-23820) Test profiling for Python user-defined functions

2021-09-03 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409833#comment-17409833 ] JING ZHANG commented on FLINK-23820: Results are expected. *Environment* Mac, python 3.8.11,

[jira] [Updated] (FLINK-23820) Test profiling for Python user-defined functions

2021-09-03 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23820: --- Attachment: image-2021-09-04-13-38-53-247.png > Test profiling for Python user-defined functions >

[jira] [Updated] (FLINK-23820) Test profiling for Python user-defined functions

2021-09-03 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23820: --- Attachment: image-2021-09-04-13-37-49-740.png > Test profiling for Python user-defined functions >

[GitHub] [flink] flinkbot commented on pull request #17148: [FLINK-24158][runtime] Remove useless collector in LimitOperator

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

[GitHub] [flink] flinkbot edited a comment on pull request #17146: [FLINK-24142]Fix Document DataStream Connectors File Sink ORC Format …

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17146: URL: https://github.com/apache/flink/pull/17146#issuecomment-912900037 ## CI report: * d3cb8742eef0401e30f30aa6e863a0f9254f6f9f Azure:

[jira] [Updated] (FLINK-24158) Remove useless collector in LimitOperator

2021-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24158: --- Labels: beginner easyfix pull-request-available (was: beginner easyfix) > Remove useless

[GitHub] [flink] TennyZhuang opened a new pull request #17148: [FLINK-24158][runtime] Remove useless collector in LimitOperator

2021-09-03 Thread GitBox
TennyZhuang opened a new pull request #17148: URL: https://github.com/apache/flink/pull/17148 Signed-off-by: TennyZhuang ## What is the purpose of the change Clean code in `LimitOperator` ## Brief change log - Remove useless collector in LimitOperator

[jira] [Updated] (FLINK-23847) [Kafka] Error msg are obscure when KafkaConsumer init, valueDeserializer is null

2021-09-03 Thread camilesing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] camilesing updated FLINK-23847: --- Priority: Minor (was: Critical) > [Kafka] Error msg are obscure when KafkaConsumer init,

[GitHub] [flink] flinkbot edited a comment on pull request #17146: [FLINK-24142]Fix Document DataStream Connectors File Sink ORC Format …

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17146: URL: https://github.com/apache/flink/pull/17146#issuecomment-912900037 ## CI report: * d3cb8742eef0401e30f30aa6e863a0f9254f6f9f Azure:

[jira] [Commented] (FLINK-24158) Remove useless collector in LimitOperator

2021-09-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409782#comment-17409782 ] Zili Chen commented on FLINK-24158: --- Sounds reasonable, go ahead! > Remove useless collector in

[jira] [Assigned] (FLINK-24158) Remove useless collector in LimitOperator

2021-09-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-24158: - Assignee: Zhuang Tianyi > Remove useless collector in LimitOperator >

[GitHub] [flink] flinkbot commented on pull request #17146: [FLINK-24142]Fix Document DataStream Connectors File Sink ORC Format …

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

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

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17145: URL: https://github.com/apache/flink/pull/17145#issuecomment-912894672 ## CI report: * cbd5815780842a5bac95d8d101a4c681c0cbb7fd Azure:

[jira] [Updated] (FLINK-23660) Hive Catalog support truncate table

2021-09-03 Thread lixu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixu updated FLINK-23660: - Component/s: Connectors / Hive > Hive Catalog support truncate table > --- > >

[jira] [Updated] (FLINK-23660) Hive Catalog support truncate table

2021-09-03 Thread lixu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixu updated FLINK-23660: - Fix Version/s: 1.15.0 > Hive Catalog support truncate table > --- > >

[jira] [Updated] (FLINK-24158) Remove useless collector in LimitOperator

2021-09-03 Thread Zhuang Tianyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhuang Tianyi updated FLINK-24158: -- Priority: Minor (was: Major) > Remove useless collector in LimitOperator >

[jira] [Created] (FLINK-24158) Remove useless collector in LimitOperator

2021-09-03 Thread Zhuang Tianyi (Jira)
Zhuang Tianyi created FLINK-24158: - Summary: Remove useless collector in LimitOperator Key: FLINK-24158 URL: https://issues.apache.org/jira/browse/FLINK-24158 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #17147: fix flaky test

2021-09-03 Thread GitBox
flinkbot commented on pull request #17147: URL: https://github.com/apache/flink/pull/17147#issuecomment-912896475 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] slm960323 closed pull request #17147: fix flaky test

2021-09-03 Thread GitBox
slm960323 closed pull request #17147: URL: https://github.com/apache/flink/pull/17147 -- 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] slm960323 opened a new pull request #17147: fix flaky test

2021-09-03 Thread GitBox
slm960323 opened a new pull request #17147: URL: https://github.com/apache/flink/pull/17147 Fix the flaky test testCEPOperatorComparatorEventTime. -- 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

[GitHub] [flink] flinkbot commented on pull request #17145: [FLINK-23748][tests] Testing window TVF session window

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

[GitHub] [flink] flinkbot commented on pull request #17146: [FLINK-24142]Fix Document DataStream Connectors File Sink ORC Format …

2021-09-03 Thread GitBox
flinkbot commented on pull request #17146: URL: https://github.com/apache/flink/pull/17146#issuecomment-912893660 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] MasonMa-sy opened a new pull request #17146: [FLINK-24142]Fix Document DataStream Connectors File Sink ORC Format …

2021-09-03 Thread GitBox
MasonMa-sy opened a new pull request #17146: URL: https://github.com/apache/flink/pull/17146 ## What is the purpose of the change Compared with the Java sample, batch.size in the implementation of vectorizer in scala cannot be increased. As a result, the generated Orc file has no

[GitHub] [flink] flinkbot commented on pull request #17145: [FLINK-23748][tests] Testing window TVF session window

2021-09-03 Thread GitBox
flinkbot commented on pull request #17145: URL: https://github.com/apache/flink/pull/17145#issuecomment-912888695 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] hililiwei opened a new pull request #17145: [FLINK-23748][tests] Testing window TVF session window

2021-09-03 Thread GitBox
hililiwei opened a new pull request #17145: URL: https://github.com/apache/flink/pull/17145 ## What is the purpose of the change Add the SESSION Window TVF followed by Window Aggregate test class https://issues.apache.org/jira/browse/FLINK-23748 ## Brief change log

[jira] [Created] (FLINK-24157) do you have a plan for support dotnet

2021-09-03 Thread Clement (Jira)
Clement created FLINK-24157: --- Summary: do you have a plan for support dotnet Key: FLINK-24157 URL: https://issues.apache.org/jira/browse/FLINK-24157 Project: Flink Issue Type: Improvement

[GitHub] [flink] hililiwei closed pull request #17056: [FLINK-23748][tests] Testing window TVF session window

2021-09-03 Thread GitBox
hililiwei closed pull request #17056: URL: https://github.com/apache/flink/pull/17056 -- 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 #17144: [release-1.13][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17144: URL: https://github.com/apache/flink/pull/17144#issuecomment-912869388 ## CI report: * 114fa3ed26bf0871efe70d096d6b6e1124e213e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17143: [release-1.14][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17143: URL: https://github.com/apache/flink/pull/17143#issuecomment-912869331 ## CI report: * 3faf6ec7a4531b97d39ec47d6f0760dc01da9459 Azure:

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

2021-09-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409759#comment-17409759 ] luoyuxia edited comment on FLINK-23857 at 9/4/21, 12:00 AM: {code:java}  

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

2021-09-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409759#comment-17409759 ] luoyuxia commented on FLINK-23857: -- {code:java}  insert overwrite table t1 partition(f2=1) select *

[GitHub] [flink] flinkbot commented on pull request #17144: [release-1.13][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot commented on pull request #17144: URL: https://github.com/apache/flink/pull/17144#issuecomment-912869388 ## CI report: * 114fa3ed26bf0871efe70d096d6b6e1124e213e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17143: [release-1.14][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot commented on pull request #17143: URL: https://github.com/apache/flink/pull/17143#issuecomment-912869331 ## CI report: * 3faf6ec7a4531b97d39ec47d6f0760dc01da9459 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17144: [release-1.13][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot commented on pull request #17144: URL: https://github.com/apache/flink/pull/17144#issuecomment-912864427 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 #17143: [release-1.14][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot commented on pull request #17143: URL: https://github.com/apache/flink/pull/17143#issuecomment-912863947 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] tweise opened a new pull request #17144: [release-1.13][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise opened a new pull request #17144: URL: https://github.com/apache/flink/pull/17144 Backport https://github.com/apache/flink/pull/17111 -- 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] tweise opened a new pull request #17143: [release-1.14][FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise opened a new pull request #17143: URL: https://github.com/apache/flink/pull/17143 Backport https://github.com/apache/flink/pull/17111 -- 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] tweise commented on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise commented on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-912861293 @stevenzwu @AHeise @SteNicholas thanks for the review! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] tweise merged pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise merged pull request #17111: URL: https://github.com/apache/flink/pull/17111 -- 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 #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * 5690d85244d8151cfe4e10dcccbf020331d5fe30 Azure:

[jira] [Updated] (FLINK-23846) [DOCS]PushGatewayReporter config description obscure

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

[jira] [Updated] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

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

[jira] [Updated] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

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

[jira] [Updated] (FLINK-22531) Improve the support for finite streaming jobs with async operations.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17102: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17102: URL: https://github.com/apache/flink/pull/17102#issuecomment-910365614 ## CI report: * 7a88172bfdf610fe669d46a10fa62fe5db22f2b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17103: [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17103: URL: https://github.com/apache/flink/pull/17103#issuecomment-910422814 ## CI report: * 8e9b56137ccaf9a804e3e317db26096db3ef3f7c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17126: [FLINK-24090][docs] Added Troubleshooting section with ignoring in-fl…

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17126: URL: https://github.com/apache/flink/pull/17126#issuecomment-911781874 ## CI report: * 002396c2b89a35277bb192e9ec9ae00daeb0459f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17142: [FLINK-24148] Add bloom filter option in RocksDBConfiguredOptions

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17142: URL: https://github.com/apache/flink/pull/17142#issuecomment-912651118 ## CI report: * 27b71d7c937e087f515908b5575852a14c0bcdd0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * f4b4b598c81f921d1547f83c92ea12757573ad55 Azure:

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

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 2c738ac974ca8873f142279cfce6e8a8659c370f UNKNOWN * 49eba9e46aa029bffa4c8df1786e3942fae678cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17126: [FLINK-24090][docs] Added Troubleshooting section with ignoring in-fl…

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17126: URL: https://github.com/apache/flink/pull/17126#issuecomment-911781874 ## CI report: * 6675abefda4deb11e7774014f77ad2f6280cd13d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17103: [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17103: URL: https://github.com/apache/flink/pull/17103#issuecomment-910422814 ## CI report: * 15effce4e18b4b4b62b0eab352bab10a542379d5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * f4b4b598c81f921d1547f83c92ea12757573ad55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17102: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17102: URL: https://github.com/apache/flink/pull/17102#issuecomment-910365614 ## CI report: * 81402821c3377da928cbe1dea5cd3c22b24abf1b Azure:

[jira] [Created] (FLINK-24156) BlobServer crashes due to SocketTimeoutException in Java 11

2021-09-03 Thread Ryan Scudellari (Jira)
Ryan Scudellari created FLINK-24156: --- Summary: BlobServer crashes due to SocketTimeoutException in Java 11 Key: FLINK-24156 URL: https://issues.apache.org/jira/browse/FLINK-24156 Project: Flink

[GitHub] [flink] stevenzwu commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
stevenzwu commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r702108667 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceEnumeratorStateSerializer.java

[GitHub] [flink] flinkbot edited a comment on pull request #17126: [FLINK-24090][docs] Added Troubleshooting section with ignoring in-fl…

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17126: URL: https://github.com/apache/flink/pull/17126#issuecomment-911781874 ## CI report: * 6675abefda4deb11e7774014f77ad2f6280cd13d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17103: [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17103: URL: https://github.com/apache/flink/pull/17103#issuecomment-910422814 ## CI report: * 15effce4e18b4b4b62b0eab352bab10a542379d5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17102: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17102: URL: https://github.com/apache/flink/pull/17102#issuecomment-910365614 ## CI report: * 81402821c3377da928cbe1dea5cd3c22b24abf1b Azure:

[GitHub] [flink] tweise commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r702106135 ## File path: flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumeratorTest.java ##

[GitHub] [flink] tweise commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r702105580 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceEnumeratorStateSerializer.java

[GitHub] [flink] tweise commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r702102984 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplit.java ## @@ -57,38

[GitHub] [flink] tweise commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r702094970 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplit.java ## @@ -57,38

[GitHub] [flink] tweise commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r702094543 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplit.java ## @@ -19,33

[GitHub] [flink] tweise commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
tweise commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r702094188 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceEnumeratorState.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-900450716 ## CI report: * b715167d64bffd32d57db1e047faa36b76a5babe Azure:

[GitHub] [flink] akalash commented on a change in pull request #17103: [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one

2021-09-03 Thread GitBox
akalash commented on a change in pull request #17103: URL: https://github.com/apache/flink/pull/17103#discussion_r702079973 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/IgnoreInFlightDataITCase.java ## @@ -68,13 +70,15 @@

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

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 15d30aac920aebb42c8f437972f38e10dce5aa7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17140: [hotfix][docs] Try Flink Improvements

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17140: URL: https://github.com/apache/flink/pull/17140#issuecomment-912563200 ## CI report: * 206206faef5e0c5af500f92cd77b67ec181354d5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17137: URL: https://github.com/apache/flink/pull/17137#issuecomment-912545933 ## CI report: * c8c132cb9688244505ed35ad1e61a42db5c8a1ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17139: [BP-1.13][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17139: URL: https://github.com/apache/flink/pull/17139#issuecomment-912546148 ## CI report: * 777d90a47aa243f9b6fa4a5de8dcf15fc8e4fa40 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17141: Revert "[FLINK-22770][docs] Update usage of SET in docs to use quotes"

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17141: URL: https://github.com/apache/flink/pull/17141#issuecomment-912590106 ## CI report: * 35581d67069db4a2403fb37e73f2a40173b2779b Azure:

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

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 15d30aac920aebb42c8f437972f38e10dce5aa7b Azure:

[GitHub] [flink] nicolasraga1 edited a comment on pull request #16946: [FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

2021-09-03 Thread GitBox
nicolasraga1 edited a comment on pull request #16946: URL: https://github.com/apache/flink/pull/16946#issuecomment-912299502 Oh I missed that you were going to address your own comments! I have already made the changes as well : ). I'll update with changes made from your comments! --

[GitHub] [flink] nicolasraga1 edited a comment on pull request #16946: [FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

2021-09-03 Thread GitBox
nicolasraga1 edited a comment on pull request #16946: URL: https://github.com/apache/flink/pull/16946#issuecomment-912299502 Oh I missed that you were going to address your own commets! I have already made the changes already as well : ). I'll update with changes made from your comments!

[GitHub] [flink] flinkbot edited a comment on pull request #17142: [FLINK-24148] Add bloom filter option in RocksDBConfiguredOptions

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17142: URL: https://github.com/apache/flink/pull/17142#issuecomment-912651118 ## CI report: * 27b71d7c937e087f515908b5575852a14c0bcdd0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17138: [BP-1.14][FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17138: URL: https://github.com/apache/flink/pull/17138#issuecomment-912546041 ## CI report: * 2fe1214aa91b0e4016bae9d213187fcae3136f8a Azure:

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

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 15d30aac920aebb42c8f437972f38e10dce5aa7b Azure:

[GitHub] [flink] hililiwei commented on a change in pull request #17142: [FLINK-24148] Add bloom filter option in RocksDBConfiguredOptions

2021-09-03 Thread GitBox
hililiwei commented on a change in pull request #17142: URL: https://github.com/apache/flink/pull/17142#discussion_r702022015 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/DefaultConfigurableOptionsFactory.java

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

2021-09-03 Thread GitBox
dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r702022088 ## File path: flink-clients/src/test/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrapTest.java ## @@ -386,59 +385,85 @@

[GitHub] [flink] flinkbot commented on pull request #17142: [FLINK-24148] Add bloom filter option in RocksDBConfiguredOptions

2021-09-03 Thread GitBox
flinkbot commented on pull request #17142: URL: https://github.com/apache/flink/pull/17142#issuecomment-912651118 ## CI report: * 27b71d7c937e087f515908b5575852a14c0bcdd0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17123: [FLINK-24096][checkpoint] Skip the complete notification for checkpoints before task startup

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17123: URL: https://github.com/apache/flink/pull/17123#issuecomment-911684941 ## CI report: * 9fb75a2cb7ee8b79e49b2ca23a1ddd5a71866f64 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-900450716 ## CI report: * cdc22b558456e9aec9691352768440ca594994d9 Azure:

[jira] [Resolved] (FLINK-23822) Test config state ttl in Python DataStream API

2021-09-03 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23822. -- Resolution: Fixed > Test config state ttl in Python DataStream API >

[jira] [Commented] (FLINK-23822) Test config state ttl in Python DataStream API

2021-09-03 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409585#comment-17409585 ] Yun Tang commented on FLINK-23822: -- Verify the state TTL in python API via docs. Found two problems

[GitHub] [flink] stevenzwu commented on a change in pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-03 Thread GitBox
stevenzwu commented on a change in pull request #17111: URL: https://github.com/apache/flink/pull/17111#discussion_r70270 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/SwitchedSources.java ## @@ -0,0 +1,48

[GitHub] [flink] flinkbot edited a comment on pull request #17136: [FLINK-24149][runtime][checkpoint] Make checkpoint relocatable

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17136: URL: https://github.com/apache/flink/pull/17136#issuecomment-912480698 ## CI report: * 1a599eb022078bc22dc3d8369f8f63e79b632bda Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-900450716 ## CI report: * cdc22b558456e9aec9691352768440ca594994d9 Azure:

[GitHub] [flink] flinkbot commented on pull request #17142: [FLINK-24148] Add bloom filter option in RocksDBConfiguredOptions

2021-09-03 Thread GitBox
flinkbot commented on pull request #17142: URL: https://github.com/apache/flink/pull/17142#issuecomment-912625103 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-24148) Add bloom filter policy option in RocksDBConfiguredOptions

2021-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24148: --- Labels: pull-request-available (was: ) > Add bloom filter policy option in

[GitHub] [flink] Jiayi-Liao opened a new pull request #17142: [FLINK-24148] Add bloom filter option in RocksDBConfiguredOptions

2021-09-03 Thread GitBox
Jiayi-Liao opened a new pull request #17142: URL: https://github.com/apache/flink/pull/17142 ## What is the purpose of the change This change provides bloom filter option in `RocksDBConfigurableOptions`. (more details see

[GitHub] [flink] hapihu commented on a change in pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-09-03 Thread GitBox
hapihu commented on a change in pull request #16865: URL: https://github.com/apache/flink/pull/16865#discussion_r701969182 ## File path: docs/content.zh/docs/dev/datastream/execution/execution_configuration.md ## @@ -45,46 +45,45 @@ var executionConfig = env.getConfig {{<

[jira] [Comment Edited] (FLINK-24152) Exactly-once semantics should be configurable through Flink configuration only

2021-09-03 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409546#comment-17409546 ] Seth Wiesman edited comment on FLINK-24152 at 9/3/21, 3:12 PM: --- +1  

[GitHub] [flink] hapihu commented on a change in pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-09-03 Thread GitBox
hapihu commented on a change in pull request #16865: URL: https://github.com/apache/flink/pull/16865#discussion_r701966309 ## File path: docs/content.zh/docs/dev/datastream/execution/execution_configuration.md ## @@ -45,46 +45,45 @@ var executionConfig = env.getConfig {{<

[GitHub] [flink] infoverload commented on a change in pull request #16871: [FLINK-23832][docs] Update DataStream API Integration page

2021-09-03 Thread GitBox
infoverload commented on a change in pull request #16871: URL: https://github.com/apache/flink/pull/16871#discussion_r701960875 ## File path: docs/content/docs/dev/table/data_stream_api.md ## @@ -725,11 +732,17 @@ to an insert-only changelog stream. {{< hint info >}} Since

[GitHub] [flink] flinkbot edited a comment on pull request #17141: Revert "[FLINK-22770][docs] Update usage of SET in docs to use quotes"

2021-09-03 Thread GitBox
flinkbot edited a comment on pull request #17141: URL: https://github.com/apache/flink/pull/17141#issuecomment-912590106 ## CI report: * 35581d67069db4a2403fb37e73f2a40173b2779b Azure:

  1   2   3   4   5   >