[GitHub] [flink] curcur opened a new pull request #15521: [hotfix] Fix the release version for JdbcXaSinkFunction

2021-04-07 Thread GitBox
curcur opened a new pull request #15521: URL: https://github.com/apache/flink/pull/15521 -- 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. For queries about this

[GitHub] [flink-statefun] tzulitai closed pull request #221: Update README.md

2021-04-07 Thread GitBox
tzulitai closed pull request #221: URL: https://github.com/apache/flink-statefun/pull/221 -- 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. For queries about this service,

[GitHub] [flink-statefun] tzulitai closed pull request #220: [hotfix][python] fix bad interpolation

2021-04-07 Thread GitBox
tzulitai closed pull request #220: URL: https://github.com/apache/flink-statefun/pull/220 -- 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. For queries about this service,

[GitHub] [flink-statefun] tzulitai commented on pull request #221: Update README.md

2021-04-07 Thread GitBox
tzulitai commented on pull request #221: URL: https://github.com/apache/flink-statefun/pull/221#issuecomment-815460904 Thanks @SiddiqueAhmad. You are correct that the links are outdated due to the examples being moved to the `flink-statefun-playground` repo. I'll merge this now. As

[GitHub] [flink] Myasuka commented on a change in pull request #15395: [FLINK-15146][core][ttl] Fix check that incremental cleanup size must be greater than zero

2021-04-07 Thread GitBox
Myasuka commented on a change in pull request #15395: URL: https://github.com/apache/flink/pull/15395#discussion_r609310327 ## File path: flink-core/src/test/java/org/apache/flink/api/common/state/StateTtlConfigTest.java ## @@ -71,4 +74,22 @@ public void

[jira] [Commented] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

2021-04-07 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316862#comment-17316862 ] Bhagi commented on FLINK-22139: --- Hi Kenneth William Krugler , I searched in User mailing list, but did not

[GitHub] [flink] flinkbot edited a comment on pull request #15500: [FLINK-22077] Fix incorrect way to create cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15500: URL: https://github.com/apache/flink/pull/15500#issuecomment-814682075 ## CI report: * cc7b2e44ce50e610134a97146ecb59ea1502df39 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15500: [FLINK-22077] Fix incorrect way to create cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15500: URL: https://github.com/apache/flink/pull/15500#issuecomment-814682075 ## CI report: * cc7b2e44ce50e610134a97146ecb59ea1502df39 Azure:

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

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Closed] (FLINK-17957) Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

2021-04-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17957. --- Resolution: Fixed Fixed in master: 43feb550f080c4d927cebc066a68f6d177800f26 > Forbidden syntax "CREATE

[GitHub] [flink] wuchong merged pull request #15494: [FLINK-17957] [table-api][parser] Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

2021-04-07 Thread GitBox
wuchong merged pull request #15494: URL: https://github.com/apache/flink/pull/15494 -- 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. For queries about this service,

[GitHub] [flink] wuchong commented on pull request #15494: [FLINK-17957] [table-api][parser] Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

2021-04-07 Thread GitBox
wuchong commented on pull request #15494: URL: https://github.com/apache/flink/pull/15494#issuecomment-815439178 @chaozwn , thanks for the contribution. However, please note to fill in the PR description, and please do not squash commits, otherwise, it's hard to know which part is

[jira] [Updated] (FLINK-21643) JDBC sink should be able to execute statements on multiple tables

2021-04-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21643: Affects Version/s: (was: 1.13.0) > JDBC sink should be able to execute statements on multiple tables

[GitHub] [flink] Thesharing commented on pull request #15500: [FLINK-22077] Fix incorrect way to create cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

2021-04-07 Thread GitBox
Thesharing commented on pull request #15500: URL: https://github.com/apache/flink/pull/15500#issuecomment-815435726 > Thanks for creating this PR @Thesharing. I think the change looks good to me. > > Before merging this PR we should add a test which ensures the correct computation

[GitHub] [flink-statefun] SiddiqueAhmad opened a new pull request #221: Update README.md

2021-04-07 Thread GitBox
SiddiqueAhmad opened a new pull request #221: URL: https://github.com/apache/flink-statefun/pull/221 links are not updated, i feel they are moved in playground repo -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 908d66e15d486c52662d9757950f78ec682506e7 Azure:

[jira] [Updated] (FLINK-19363) Code of split method grows beyond 64 KB

2021-04-07 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-19363: --- Component/s: (was: Table SQL / Planner) Table SQL / Runtime > Code of split

[jira] [Updated] (FLINK-19066) InnerJoinITCase.testBigForSpill failed with "java.lang.ClassCastException: org.apache.flink.table.runtime.util.ResettableExternalBuffer$BufferIterator cannot be cast to

2021-04-07 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-19066: --- Component/s: (was: Table SQL / Planner) Table SQL / Runtime >

[GitHub] [flink-web] curcur closed pull request #429: [FLINK-22004] Translate Flink Roadmap to Chinese

2021-04-07 Thread GitBox
curcur closed pull request #429: URL: https://github.com/apache/flink-web/pull/429 -- 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. For queries about this service, please

[GitHub] [flink-web] curcur commented on pull request #429: [FLINK-22004] Translate Flink Roadmap to Chinese

2021-04-07 Thread GitBox
curcur commented on pull request #429: URL: https://github.com/apache/flink-web/pull/429#issuecomment-815429333 should pull against apache:asf-site instead of apache:master, close this one. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] lindong28 edited a comment on pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
lindong28 edited a comment on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-815422325 For the context, @tillrohrmann asked in this comment[1] about the excessive INFO level logging in AZP. It appears that INFO level logging from

[GitHub] [flink-web] curcur opened a new pull request #430: [FLINK-22004] Update Flink Roadmap Chinese Version

2021-04-07 Thread GitBox
curcur opened a new pull request #430: URL: https://github.com/apache/flink-web/pull/430 1. Translate Flink Roadmap to Chinese 2. Feature Radar (Figure) may also need to be translated/updated 3. Already built locally. -- This is an automated message from the Apache Git Service. To

[jira] [Created] (FLINK-22147) Refactor Partition Discovery Logic in KafkaSourceEnumerator

2021-04-07 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-22147: - Summary: Refactor Partition Discovery Logic in KafkaSourceEnumerator Key: FLINK-22147 URL: https://issues.apache.org/jira/browse/FLINK-22147 Project: Flink

[GitHub] [flink] fsk119 commented on a change in pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
fsk119 commented on a change in pull request #15307: URL: https://github.com/apache/flink/pull/15307#discussion_r609250053 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterInCalcIntoTableSourceScanRule.java

[GitHub] [flink] flinkbot edited a comment on pull request #15520: [FLINK-22097][sql-client] CliResultView should wait RefreshThread exi…

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15520: URL: https://github.com/apache/flink/pull/15520#issuecomment-815418058 ## CI report: * 41dd8818b80689f45e6b24f5e7ad4edbe7b7ecf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 908d66e15d486c52662d9757950f78ec682506e7 Azure:

[GitHub] [flink] fsk119 commented on a change in pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
fsk119 commented on a change in pull request #15307: URL: https://github.com/apache/flink/pull/15307#discussion_r608457950 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterInCalcIntoTableSourceScanRule.java

[GitHub] [flink] yittg commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-04-07 Thread GitBox
yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-815422875 @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 specific

[GitHub] [flink] lindong28 commented on pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
lindong28 commented on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-815422325 For the context, @tillrohrmann asked in this comment about the excessive INFO level logging in AZP. It appears that INFO level logging from

[GitHub] [flink] lindong28 removed a comment on pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
lindong28 removed a comment on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-815419610 @rmetzger -- 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] lindong28 commented on pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
lindong28 commented on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-815419610 @rmetzger -- 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

[jira] [Comment Edited] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-04-07 Thread zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316842#comment-17316842 ] zhou edited comment on FLINK-20663 at 4/8/21, 3:27 AM: ---  logs in attachment,it a

[GitHub] [flink] flinkbot commented on pull request #15520: [FLINK-22097][sql-client] CliResultView should wait RefreshThread exi…

2021-04-07 Thread GitBox
flinkbot commented on pull request #15520: URL: https://github.com/apache/flink/pull/15520#issuecomment-815418058 ## CI report: * 41dd8818b80689f45e6b24f5e7ad4edbe7b7ecf7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15519: URL: https://github.com/apache/flink/pull/15519#issuecomment-815409179 ## CI report: * 41890dd12eec1ca6aa45867999a5fb6d1895cd9b Azure:

[GitHub] [flink] fsk119 commented on a change in pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
fsk119 commented on a change in pull request #15307: URL: https://github.com/apache/flink/pull/15307#discussion_r609250053 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterInCalcIntoTableSourceScanRule.java

[GitHub] [flink] flinkbot edited a comment on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824 ## CI report: * c6fc2d4fa4d1149f364432891223779d23a8f6a2 Azure:

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-04-07 Thread zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316842#comment-17316842 ] zhou commented on FLINK-20663: --  logs in attachment: [^exception] > Managed memory may not be released in

[jira] [Updated] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-04-07 Thread zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhou updated FLINK-20663: - Attachment: exception > Managed memory may not be released in time when operators use managed memory >

[GitHub] [flink] flinkbot edited a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955 ## CI report: * f39c534bfa814d33dbe0646fe79c09f5b5cc32a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definition in

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15489: URL: https://github.com/apache/flink/pull/15489#issuecomment-813835360 ## CI report: * 0bd5b6f241ae6168c0abb82873f4d47448e1330c Azure:

[GitHub] [flink] fsk119 commented on a change in pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
fsk119 commented on a change in pull request #15307: URL: https://github.com/apache/flink/pull/15307#discussion_r609250053 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterInCalcIntoTableSourceScanRule.java

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN *

[GitHub] [flink] fsk119 commented on a change in pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
fsk119 commented on a change in pull request #15307: URL: https://github.com/apache/flink/pull/15307#discussion_r609247479 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterInCalcIntoTableSourceScanRule.java

[GitHub] [flink] flinkbot commented on pull request #15520: [FLINK-22097][sql-client] CliResultView should wait RefreshThread exi…

2021-04-07 Thread GitBox
flinkbot commented on pull request #15520: URL: https://github.com/apache/flink/pull/15520#issuecomment-815411465 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-22097) testChangelogResultViewClearEmptyResult fail.

2021-04-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22097: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] kezhuw commented on pull request #15507: [FLINK-21386][datastream] Postpone FromElementsFunction serialization to respect later type customization

2021-04-07 Thread GitBox
kezhuw commented on pull request #15507: URL: https://github.com/apache/flink/pull/15507#issuecomment-815410555 Test was cancelled in [kafka_gelly](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16149=logs=c5f0071e-1851-543e-9a45-9ac140befc32). -- This is an

[GitHub] [flink] fsk119 opened a new pull request #15520: [FLINK-22097][sql-client] CliResultView should wait RefreshThread exi…

2021-04-07 Thread GitBox
fsk119 opened a new pull request #15520: URL: https://github.com/apache/flink/pull/15520 …ts before exits ## What is the purpose of the change *The failed test is mainly to test the view thread has the ability to exit gracefully when users(main thread) interrupt the

[GitHub] [flink] flinkbot edited a comment on pull request #15506: [FLINK-21240][jdbc] Fix JDBC row converter doesn't support external LocalDateTime type

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15506: URL: https://github.com/apache/flink/pull/15506#issuecomment-814806856 ## CI report: * eb9027ad7da7cf563e1a051ba4301c03225f9959 Azure:

[GitHub] [flink] flinkbot commented on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

2021-04-07 Thread GitBox
flinkbot commented on pull request #15519: URL: https://github.com/apache/flink/pull/15519#issuecomment-815409179 ## CI report: * 41890dd12eec1ca6aa45867999a5fb6d1895cd9b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824 ## CI report: * c6fc2d4fa4d1149f364432891223779d23a8f6a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definition in

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15489: URL: https://github.com/apache/flink/pull/15489#issuecomment-813835360 ## CI report: * 0bd5b6f241ae6168c0abb82873f4d47448e1330c Azure:

[jira] [Created] (FLINK-22146) Migrate StateBackend related Chinese docs to latest state backend

2021-04-07 Thread Yun Tang (Jira)
Yun Tang created FLINK-22146: Summary: Migrate StateBackend related Chinese docs to latest state backend Key: FLINK-22146 URL: https://issues.apache.org/jira/browse/FLINK-22146 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15485: [FLINK-20387][table] Support TIMESTAMP_LTZ as rowtime attribute

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15485: URL: https://github.com/apache/flink/pull/15485#issuecomment-812897189 ## CI report: * ee69df73cd5a7e61efa44b704eb5d551db23d7e8 Azure:

[jira] [Commented] (FLINK-22097) testChangelogResultViewClearEmptyResult fail.

2021-04-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316830#comment-17316830 ] Shengkai Fang commented on FLINK-22097: --- The failed test is mainly to test the view thread has the

[jira] [Commented] (FLINK-21694) Increase default value of "state.backend.rocksdb.checkpoint.transfer.thread.num"

2021-04-07 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316829#comment-17316829 ] Yun Tang commented on FLINK-21694: -- This ticket has not been resolved in Flink-1.13. And from my points

[GitHub] [flink] flinkbot edited a comment on pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-815397264 ## CI report: * aa7327706869d9cfc9c3c0a5084c9c7676dba6b5 Azure:

[GitHub] [flink] flinkbot commented on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

2021-04-07 Thread GitBox
flinkbot commented on pull request #15519: URL: https://github.com/apache/flink/pull/15519#issuecomment-815402463 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-22120) Remove duplicate code in generated code for map get

2021-04-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22120: --- Labels: pull-request-available (was: ) > Remove duplicate code in generated code for map

[jira] [Updated] (FLINK-21736) Introduce latency tracking state

2021-04-07 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21736: - Release Note: State access latency metrics are introduced to track all kinds of keyed state access to

[GitHub] [flink] zoudan opened a new pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

2021-04-07 Thread GitBox
zoudan opened a new pull request #15519: URL: https://github.com/apache/flink/pull/15519 ## What is the purpose of the change This pull request fixed a bug that there is duplicate code in generated code for map get, an it may lead to some exceptions such as 'Redefinition of local

[jira] [Updated] (FLINK-21726) Fix checkpoint stuck

2021-04-07 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21726: - Fix Version/s: (was: 1.13.0) 1.14.0 > Fix checkpoint stuck >

[jira] [Commented] (FLINK-21726) Fix checkpoint stuck

2021-04-07 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316828#comment-17316828 ] Yun Tang commented on FLINK-21726: -- Since this fix depends on releasing another FRocksDB version, and

[GitHub] [flink] flinkbot commented on pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
flinkbot commented on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-815397264 ## CI report: * aa7327706869d9cfc9c3c0a5084c9c7676dba6b5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15506: [FLINK-21240][jdbc] Fix JDBC row converter doesn't support external LocalDateTime type

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15506: URL: https://github.com/apache/flink/pull/15506#issuecomment-814806856 ## CI report: * eb9027ad7da7cf563e1a051ba4301c03225f9959 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15485: [FLINK-20387][table] Support TIMESTAMP_LTZ as rowtime attribute

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15485: URL: https://github.com/apache/flink/pull/15485#issuecomment-812897189 ## CI report: * ee69df73cd5a7e61efa44b704eb5d551db23d7e8 Azure:

[jira] [Created] (FLINK-22145) CheckStyle for scala not work

2021-04-07 Thread MaChengLong (Jira)
MaChengLong created FLINK-22145: --- Summary: CheckStyle for scala not work Key: FLINK-22145 URL: https://issues.apache.org/jira/browse/FLINK-22145 Project: Flink Issue Type: Improvement

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

2021-04-07 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316819#comment-17316819 ] Dong Lin commented on FLINK-16908: -- I think this is due to the same issue as described in

[GitHub] [flink] leonardBang commented on pull request #15506: [FLINK-21240][jdbc] Fix JDBC row converter doesn't support external LocalDateTime type

2021-04-07 Thread GitBox
leonardBang commented on pull request #15506: URL: https://github.com/apache/flink/pull/15506#issuecomment-815385594 @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

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2021-04-07 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316817#comment-17316817 ] Dong Lin commented on FLINK-18634: -- [~trohrmann] It appears that flink-tests/src/test's root logger

[jira] [Commented] (FLINK-22063) Lookup Join outputs wrong results for some scenario

2021-04-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316816#comment-17316816 ] Leonard Xu commented on FLINK-22063: Hi, [~icshuo] Do you have any progress? > Lookup Join outputs

[GitHub] [flink] flinkbot commented on pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
flinkbot commented on pull request #15518: URL: https://github.com/apache/flink/pull/15518#issuecomment-815384604 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] lindong28 opened a new pull request #15518: [hotfix][tests] Set flink-tests/src/test root logger level to OFF

2021-04-07 Thread GitBox
lindong28 opened a new pull request #15518: URL: https://github.com/apache/flink/pull/15518 ## Contribution Checklist This PR sets flink-tests/src/test root logger level to OFF. This simplifies the parsing of Azure Pipeline logs by not flooding Azure Pipeline logs with INFO/WARN

[jira] [Commented] (FLINK-19159) Using Scalafmt to format scala source code

2021-04-07 Thread MaChengLong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316811#comment-17316811 ] MaChengLong commented on FLINK-19159: - I followed this docs

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2021-04-07 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20431: - Fix Version/s: (was: 1.13.0) 1.13.1 >

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

2021-04-07 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15493: - Fix Version/s: (was: 1.13.0) 1.13.1 >

[jira] [Comment Edited] (FLINK-22075) Incorrect null outputs in left join

2021-04-07 Thread Jamie Brandon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316796#comment-17316796 ] Jamie Brandon edited comment on FLINK-22075 at 4/8/21, 12:01 AM: - In

[jira] [Commented] (FLINK-22075) Incorrect null outputs in left join

2021-04-07 Thread Jamie Brandon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316796#comment-17316796 ] Jamie Brandon commented on FLINK-22075: --- In batch mode with a file source the results are actually

[GitHub] [flink] zentol commented on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
zentol commented on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815341717 > While it fixes the RescalingITCase , it also introduces the issue that we may use a smaller maxParallelism than we initially used for requesting resources, when the

[GitHub] [flink] austince edited a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
austince edited a comment on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815329177 > Unless I'm missing anything, then here is an example where this happens: > > ``` > P1= 80 => MP1=128 > P2=100 => MP2=256 > ``` > > So similarly

[GitHub] [flink] austince edited a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
austince edited a comment on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815329177 > Unless I'm missing anything, then here is an example where this happens: > > ``` > P1= 80 => MP1=128 > P2=100 => MP2=256 > ``` > > So similarly

[GitHub] [flink] flinkbot edited a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-814453955 ## CI report: * eaf1f344b8e82f4afc1a0d96c3a5602011f05ff1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15496: URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240 ## CI report: * c756b734d8117d19d9b825b70e6475cd3bcfa4d5 Azure:

[GitHub] [flink] austince edited a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
austince edited a comment on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815329177 > Unless I'm missing anything, then here is an example where this happens: > > ``` > P1= 80 => MP1=128 > P2=100 => MP2=256 > ``` > > So similarly

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN *

[GitHub] [flink] austince commented on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
austince commented on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815329177 > Unless I'm missing anything, then here is an example where this happens: > > ``` > P1= 80 => MP1=128 > P2=100 => MP2=256 > ``` > > So similarly to

[GitHub] [flink] zentol closed pull request #15514: [hot fix]remove the semicolon

2021-04-07 Thread GitBox
zentol closed pull request #15514: URL: https://github.com/apache/flink/pull/15514 -- 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. For queries about this service, please

[GitHub] [flink] zentol commented on pull request #15514: [hot fix]remove the semicolon

2021-04-07 Thread GitBox
zentol commented on pull request #15514: URL: https://github.com/apache/flink/pull/15514#issuecomment-815328675 This change is incorrect; the semi-colon is required because the class is an enum; without it the class no longer compiles. -- This is an automated message from the Apache Git

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

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Updated] (FLINK-21643) JDBC sink should be able to execute statements on multiple tables

2021-04-07 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Obuchowski updated FLINK-21643: -- Affects Version/s: (was: 1.12.2) 1.13.0 > JDBC sink should

[GitHub] [flink] zentol edited a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
zentol edited a comment on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815303500 > We could also add the invariant that is currently defined for reactive mode, where the savepoint can set the max parallelism as long it is at least what has been

[GitHub] [flink] zentol commented on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

2021-04-07 Thread GitBox
zentol commented on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815303500 > We could also add the invariant that is currently defined for reactive mode, where the savepoint can set the max parallelism as long it is at least what has been

[GitHub] [flink] flinkbot edited a comment on pull request #15507: [FLINK-21386][datastream] Postpone FromElementsFunction serialization to respect later type customization

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15507: URL: https://github.com/apache/flink/pull/15507#issuecomment-814806931 ## CI report: * 493e7604c1bfd5b5eae8df1c9db4624c89839efe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN *

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

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 46b4644a2a5d473b01dfb4e2a6e4b1ec3cc483d1 Azure:

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

2021-04-07 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 46b4644a2a5d473b01dfb4e2a6e4b1ec3cc483d1 Azure:

[jira] [Commented] (FLINK-21873) CoordinatedSourceRescaleITCase.testUpscaling fails on AZP

2021-04-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316684#comment-17316684 ] Arvid Heise commented on FLINK-21873: - Merged into master as

[jira] [Resolved] (FLINK-21873) CoordinatedSourceRescaleITCase.testUpscaling fails on AZP

2021-04-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21873. - Fix Version/s: (was: 1.14.0) 1.13.0 Resolution: Fixed >

[GitHub] [flink] AHeise merged pull request #15503: [FLINK-21873][connector/common] Harden CoordinatedSourceRescaleITCase by checking exceptions more leniently.

2021-04-07 Thread GitBox
AHeise merged pull request #15503: URL: https://github.com/apache/flink/pull/15503 -- 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. For queries about this service, please

[GitHub] [flink] AHeise merged pull request #15504: [FLINK-21873][connector/common] Harden CoordinatedSourceRescaleITCase by checking exceptions more leniently.

2021-04-07 Thread GitBox
AHeise merged pull request #15504: URL: https://github.com/apache/flink/pull/15504 -- 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. For queries about this service, please

  1   2   3   4   5   6   >