[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * 12809bb05f44589b9dde53d53397a06c3d6a03c5 Azure:

[GitHub] [flink] zentol commented on a change in pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
zentol commented on a change in pull request #17227: URL: https://github.com/apache/flink/pull/17227#discussion_r705915129 ## File path: flink-core/src/test/java/org/apache/flink/util/NetUtilsTest.java ## @@ -61,25 +56,45 @@ public void testParseHostPortAddress() { @Test

[GitHub] [flink] flinkbot edited a comment on pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

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

[jira] [Updated] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20410: - Priority: Major (was: Critical) > SQLClientSchemaRegistryITCase.testWriting failed with

[jira] [Commented] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412968#comment-17412968 ] Xintong Song commented on FLINK-20410: -- There's only one instance reported in recent nearly one

[GitHub] [flink] Huanli-Meng commented on a change in pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
Huanli-Meng commented on a change in pull request #17188: URL: https://github.com/apache/flink/pull/17188#discussion_r705164297 ## File path: docs/layouts/shortcodes/generated/pulsar_client_configuration.html ## @@ -0,0 +1,222 @@ + + + +Key +

[GitHub] [flink] Huanli-Meng commented on a change in pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
Huanli-Meng commented on a change in pull request #17188: URL: https://github.com/apache/flink/pull/17188#discussion_r704903345 ## File path: docs/content/docs/connectors/datastream/pulsar.md ## @@ -0,0 +1,409 @@ +--- +title: Pulsar +weight: 9 +type: docs +--- + + +# Apache

[GitHub] [flink] SteNicholas edited a comment on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

2021-09-09 Thread GitBox
SteNicholas edited a comment on pull request #17105: URL: https://github.com/apache/flink/pull/17105#issuecomment-915681646 > @SteNicholas , do you think we can get this into 1.14? Do you have time to finish it this week? @AHeise , of course yes. -- This is an automated message

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412967#comment-17412967 ] Xintong Song commented on FLINK-23747: -- [~liliwei], I'm not an expert in this area, thus I cannot

[jira] [Updated] (FLINK-24239) Event time temporal join should support values from array, map, row, etc. as join key

2021-09-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24239: Description: This ticket is from the [mailing

[jira] [Updated] (FLINK-24213) Java deadlock in QueryableState ClientTest

2021-09-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24213: - Fix Version/s: 1.13.3 1.12.6 > Java deadlock in QueryableState

[jira] [Comment Edited] (FLINK-24213) Java deadlock in QueryableState ClientTest

2021-09-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412550#comment-17412550 ] Chesnay Schepler edited comment on FLINK-24213 at 9/10/21, 5:30 AM:

[jira] [Updated] (FLINK-24213) Java deadlock in QueryableState ClientTest

2021-09-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24213: - Affects Version/s: (was: 1.15.0) (was: 1.12.5)

[jira] [Closed] (FLINK-24213) Java deadlock in QueryableState ClientTest

2021-09-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24213. Resolution: Fixed > Java deadlock in QueryableState ClientTest >

[jira] [Commented] (FLINK-24239) Event time temporal join should support values from array, map, row, etc. as join key

2021-09-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412962#comment-17412962 ] Caizhi Weng commented on FLINK-24239: - cc [~Leonard Xu] > Event time temporal join should support

[jira] [Created] (FLINK-24239) Event time temporal join should support values from array, map, row, etc. as join key

2021-09-09 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-24239: --- Summary: Event time temporal join should support values from array, map, row, etc. as join key Key: FLINK-24239 URL: https://issues.apache.org/jira/browse/FLINK-24239

[jira] [Commented] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412958#comment-17412958 ] Feifan Wang commented on FLINK-24149: - Hi [~yunta], [~pnowojski] , I rephrased description, please

[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * 12809bb05f44589b9dde53d53397a06c3d6a03c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17023: URL: https://github.com/apache/flink/pull/17023#issuecomment-907189438 ## CI report: * 2a25c295ad6e3fee8cb14a56c8bc1517100d938a 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-09 Thread GitBox
flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * 9e78c26b7915d68b148af6ba782e45add05123e2 Azure:

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h1. Backgroud We have many jobs with large state size in production environment.

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h1. Backgroud We have many jobs with large state size in production environment.

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h1. Backgroud We have many jobs with large state size in production environment.

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h1. Backgroud We have many job with large state size in production environment.

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

2021-09-09 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412953#comment-17412953 ] liwei li commented on FLINK-23747: -- yes, thx. How about opening an issue to track whether to uniformly

[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * 12809bb05f44589b9dde53d53397a06c3d6a03c5 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-09 Thread GitBox
flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * 9e78c26b7915d68b148af6ba782e45add05123e2 Azure:

[GitHub] [flink] syhily commented on a change in pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
syhily commented on a change in pull request #17188: URL: https://github.com/apache/flink/pull/17188#discussion_r705860316 ## File path: docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html ## @@ -0,0 +1,180 @@ + + + +Key +

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h1. Backgroud We have many job with large state size in production environment.

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h1. Backgroud We have many job with large state size in production environment.

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: # h1. Backgroud We have many job with large state size in production environment.

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-09 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: # h1. Backgroud We have many job with large state size in production environment.

[GitHub] [flink] zuston commented on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

2021-09-09 Thread GitBox
zuston commented on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-916611717 Added test cases. Thanks reply @gaborgsomogyi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Assigned] (FLINK-23316) There's no test for custom PartitionCommitPolicy

2021-09-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23316: -- Assignee: jackwangcs > There's no test for custom PartitionCommitPolicy >

[jira] [Commented] (FLINK-23316) There's no test for custom PartitionCommitPolicy

2021-09-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412942#comment-17412942 ] Rui Li commented on FLINK-23316: [~jackwangcs] Thanks for volunteering to help. Assigning to you. >

[GitHub] [flink] flinkbot edited a comment on pull request #17228: [FLINK-24236] Migrate tests to factory approach

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17228: URL: https://github.com/apache/flink/pull/17228#issuecomment-916400792 ## CI report: * 6688227d5c3120d7dc893b22892435f1c14539c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17227: URL: https://github.com/apache/flink/pull/17227#issuecomment-916400703 ## CI report: * 4d1caa7cda89a0f6df2010925d4543507cf53dbf Azure:

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

2021-09-09 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412938#comment-17412938 ] Yufan Sheng commented on FLINK-23969: - [~Jiangang] Any progress on this e2e test? > Test Pulsar

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

2021-09-09 Thread GitBox
godfreyhe commented on pull request #17089: URL: https://github.com/apache/flink/pull/17089#issuecomment-916602109 this pr can be closed, which is done in #17118 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

2021-09-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22601. -- Resolution: Fixed Resolved in FLINK-22603 > PushWatermarkIntoScan should produce digest created by

[jira] [Updated] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

2021-09-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22601: --- Fix Version/s: (was: 1.14.0) 1.15.0 > PushWatermarkIntoScan should produce

[jira] [Assigned] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

2021-09-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22601: -- Assignee: xuyangzhong > PushWatermarkIntoScan should produce digest created by Expression >

[jira] [Commented] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression

2021-09-09 Thread xuyangzhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412935#comment-17412935 ] xuyangzhong commented on FLINK-22601: - link FLINK-22603 > PushWatermarkIntoScan should produce

[jira] [Closed] (FLINK-22603) The digest can be produced by SourceAbilitySpec

2021-09-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22603. -- Resolution: Done Fixed in 1.15.0: d93682ccd9de5c83b8daed615cac96c288a44871 > The digest can be

[GitHub] [flink] godfreyhe closed pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

2021-09-09 Thread GitBox
godfreyhe closed pull request #17118: URL: https://github.com/apache/flink/pull/17118 -- 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 #17230: [FLINK-23054][table-blink] Correct upsert optimization by upsert keys

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17230: URL: https://github.com/apache/flink/pull/17230#issuecomment-916582233 ## CI report: * 414d13798addfaecc667880c39b381effb5be830 Azure:

[jira] [Closed] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23944. Resolution: Fixed Test case activated in - master (1.15):

[jira] [Closed] (FLINK-24238) Page title missing

2021-09-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24238. --- Resolution: Duplicate > Page title missing > -- > > Key: FLINK-24238 >

[jira] [Closed] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23848. Resolution: Fixed release-1.14: 4e732ad4509d719a2f0c5a81cd75ed002df25c2e > PulsarSourceITCase is

[GitHub] [flink] xintongsong closed pull request #17199: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test. [1.14]

2021-09-09 Thread GitBox
xintongsong closed pull request #17199: URL: https://github.com/apache/flink/pull/17199 -- 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] xintongsong commented on pull request #17199: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test. [1.14]

2021-09-09 Thread GitBox
xintongsong commented on pull request #17199: URL: https://github.com/apache/flink/pull/17199#issuecomment-916592298 4e732ad4509d719a2f0c5a81cd75ed002df25c2e -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] godfreyhe commented on a change in pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

2021-09-09 Thread GitBox
godfreyhe commented on a change in pull request #16192: URL: https://github.com/apache/flink/pull/16192#discussion_r705860658 ## File path:

[GitHub] [flink] xintongsong closed pull request #17201: [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure

2021-09-09 Thread GitBox
xintongsong closed pull request #17201: URL: https://github.com/apache/flink/pull/17201 -- 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-23747) Testing Window TVF offset

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23747. Resolution: Done > Testing Window TVF offset > - > > Key:

[GitHub] [flink] lzshlzsh commented on pull request #17198: [FLINK-24212][kerbernets] fix the problem that kerberos krb5.conf file is mounted as empty directory, not a expected file

2021-09-09 Thread GitBox
lzshlzsh commented on pull request #17198: URL: https://github.com/apache/flink/pull/17198#issuecomment-916586530 > Thanks for the contribution @lzshlzsh . Your fix looks good. Have you verified it in your local env? Also, it would be good to add a test for it. Yes, I have verified

[GitHub] [flink] Huanli-Meng commented on a change in pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
Huanli-Meng commented on a change in pull request #17188: URL: https://github.com/apache/flink/pull/17188#discussion_r705830866 ## File path: docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html ## @@ -0,0 +1,180 @@ + + + +Key +

[jira] [Closed] (FLINK-23345) Migrate to the next version of Python `requests` when released

2021-09-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23345. --- Fix Version/s: 1.11.5 1.10.4 Resolution: Fixed Fixed in: - master via

[GitHub] [flink] flinkbot commented on pull request #17230: [FLINK-23054][table-blink] Correct upsert optimization by upsert keys

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

[jira] [Updated] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

2021-09-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19142: Labels: pull-request-available (was: auto-unassigned pull-request-available) > Investigate slot

[jira] [Updated] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

2021-09-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19142: Fix Version/s: (was: 1.14.0) 1.15.0 > Investigate slot hijacking from preceding

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

2021-09-09 Thread GitBox
Myasuka commented on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-916581485 > I think in the end there is no harm doing so, but a the very least the javadoc must be updated. I would even suggest renaming initializeBaseLocations to

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

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

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

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22869: -- > SQLClientSchemaRegistryITCase timeouts on azure >

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

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

[jira] [Reopened] (FLINK-24213) Java deadlock in QueryableState ClientTest

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

[jira] [Updated] (FLINK-24213) Java deadlock in QueryableState ClientTest

2021-09-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24213: - Affects Version/s: 1.12.5 > Java deadlock in QueryableState ClientTest >

[jira] [Commented] (FLINK-24001) Support evaluating individual window table-valued function in runtime

2021-09-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412907#comment-17412907 ] Jingsong Lee commented on FLINK-24001: -- Never think about Operator state, it is not for big data...

[GitHub] [flink] flinkbot commented on pull request #17230: [FLINK-23054][table-blink] Correct upsert optimization by upsert keys

2021-09-09 Thread GitBox
flinkbot commented on pull request #17230: URL: https://github.com/apache/flink/pull/17230#issuecomment-916571829 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] dianfu closed pull request #17219: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

2021-09-09 Thread GitBox
dianfu closed pull request #17219: URL: https://github.com/apache/flink/pull/17219 -- 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] [Reopened] (FLINK-23054) Correct upsert optimization by upsert keys

2021-09-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-23054: -- Re-open for 1.13 > Correct upsert optimization by upsert keys >

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-09-09 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412904#comment-17412904 ] Huang Xingbo commented on FLINK-23391: --

[GitHub] [flink] JingsongLi opened a new pull request #17230: [FLINK-23054][table-blink] Correct upsert optimization by upsert keys

2021-09-09 Thread GitBox
JingsongLi opened a new pull request #17230: URL: https://github.com/apache/flink/pull/17230 Cherry-pick #16239 ## What is the purpose of the change After FLINK-22901. We can use upsert keys to fix upsert join, upsert rank, and upsert sink. - For join and rank:

[jira] [Comment Edited] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

2021-09-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412902#comment-17412902 ] Jingsong Lee edited comment on FLINK-22901 at 9/10/21, 1:35 AM:

[jira] [Closed] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

2021-09-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22901. Resolution: Fixed release-1.13: 22901 > Introduce getChangeLogUpsertKeys in

[GitHub] [flink] JingsongLi merged pull request #17207: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

2021-09-09 Thread GitBox
JingsongLi merged pull request #17207: URL: https://github.com/apache/flink/pull/17207 -- 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] [Commented] (FLINK-21647) 'Run kubernetes session test (default input)' failed on Azure

2021-09-09 Thread Kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412895#comment-17412895 ] Kevin commented on FLINK-21647: --- Hello, as I face this issue currently with Flink 1.13.2 on Amazone

[jira] [Commented] (FLINK-21687) e2e "Run kubernetes session test (default input)" timed out due to k8s issue

2021-09-09 Thread Kevin Laubis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412893#comment-17412893 ] Kevin Laubis commented on FLINK-21687: -- Hello, as I face this issue currently with Flink 1.13.2 on

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [WIP][FLINK-23381][state] Back-pressure on reaching state change to upload limit

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * 30c754d27fca90d410964a7549f53252e7b2a507 Azure:

[GitHub] [flink] flinkbot commented on pull request #17229: [WIP][FLINK-23381][state] Back-pressure on reaching state change to upload limit

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

[jira] [Updated] (FLINK-23381) Provide backpressure (currently job fails if a limit is hit)

2021-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23381: --- Labels: pull-request-available (was: ) > Provide backpressure (currently job fails if a

[GitHub] [flink] flinkbot commented on pull request #17229: [WIP][FLINK-23381][state] Back-pressure on reaching state change to upload limit

2021-09-09 Thread GitBox
flinkbot commented on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916508664 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] [Assigned] (FLINK-23381) Provide backpressure (currently job fails if a limit is hit)

2021-09-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-23381: - Assignee: Roman Khachatryan > Provide backpressure (currently job fails if a

[GitHub] [flink] flinkbot edited a comment on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17227: URL: https://github.com/apache/flink/pull/17227#issuecomment-916400703 ## CI report: * 4d1caa7cda89a0f6df2010925d4543507cf53dbf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * 12809bb05f44589b9dde53d53397a06c3d6a03c5 Azure:

[jira] [Updated] (FLINK-23016) Job client must be a Coordination Request Gateway when submit a job on web ui

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

[GitHub] [flink] flinkbot edited a comment on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17227: URL: https://github.com/apache/flink/pull/17227#issuecomment-916400703 ## CI report: * 4d1caa7cda89a0f6df2010925d4543507cf53dbf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17226: [FLINK-24222] Migrate ReporterSetupTest to ContextClassLoaderExtension

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

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 56620990c0b4f82b487fe8028e9379cc59bc9f08 UNKNOWN * c3bb93196259844291162a0fd4c10e82c3446e55 Azure:

[jira] [Created] (FLINK-24238) Page title missing

2021-09-09 Thread Jun Qin (Jira)
Jun Qin created FLINK-24238: --- Summary: Page title missing Key: FLINK-24238 URL: https://issues.apache.org/jira/browse/FLINK-24238 Project: Flink Issue Type: Bug Components: Documentation

[GitHub] [flink] scudellari commented on a change in pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
scudellari commented on a change in pull request #17227: URL: https://github.com/apache/flink/pull/17227#discussion_r705698738 ## File path: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ## @@ -116,6 +119,39 @@ private static URL validateHostPortString(String

[GitHub] [flink] zentol commented on a change in pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
zentol commented on a change in pull request #17227: URL: https://github.com/apache/flink/pull/17227#discussion_r705695170 ## File path: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ## @@ -116,6 +119,39 @@ private static URL validateHostPortString(String

[GitHub] [flink] zentol commented on a change in pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
zentol commented on a change in pull request #17227: URL: https://github.com/apache/flink/pull/17227#discussion_r705690463 ## File path: flink-core/src/test/java/org/apache/flink/util/NetUtilsTest.java ## @@ -49,6 +58,30 @@ public void testParseHostPortAddress() {

[GitHub] [flink] flinkbot edited a comment on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17227: URL: https://github.com/apache/flink/pull/17227#issuecomment-916400703 ## CI report: * 4d1caa7cda89a0f6df2010925d4543507cf53dbf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17228: [FLINK-24236] Migrate tests to factory approach

2021-09-09 Thread GitBox
flinkbot edited a comment on pull request #17228: URL: https://github.com/apache/flink/pull/17228#issuecomment-916400792 ## CI report: * 6688227d5c3120d7dc893b22892435f1c14539c0 Azure:

[GitHub] [flink] scudellari commented on a change in pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
scudellari commented on a change in pull request #17227: URL: https://github.com/apache/flink/pull/17227#discussion_r705677409 ## File path: flink-core/src/test/java/org/apache/flink/util/NetUtilsTest.java ## @@ -49,6 +58,30 @@ public void testParseHostPortAddress() {

[GitHub] [flink] scudellari commented on a change in pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
scudellari commented on a change in pull request #17227: URL: https://github.com/apache/flink/pull/17227#discussion_r705676769 ## File path: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ## @@ -116,6 +119,39 @@ private static URL validateHostPortString(String

[GitHub] [flink] flinkbot commented on pull request #17228: [FLINK-24236] Migrate tests to factory approach

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

[GitHub] [flink] flinkbot commented on pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

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

[GitHub] [flink] zentol commented on a change in pull request #17227: [FLINK-24156][runtime/network] Catch erroneous SocketTimeoutExceptions and retry

2021-09-09 Thread GitBox
zentol commented on a change in pull request #17227: URL: https://github.com/apache/flink/pull/17227#discussion_r705654583 ## File path: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ## @@ -116,6 +119,39 @@ private static URL validateHostPortString(String

[GitHub] [flink] flinkbot commented on pull request #17228: [FLINK-24236] Migrate tests to factory approach

2021-09-09 Thread GitBox
flinkbot commented on pull request #17228: URL: https://github.com/apache/flink/pull/17228#issuecomment-916392543 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

  1   2   3   4   5   >