[GitHub] [flink] flinkbot edited a comment on pull request #16698: [FLINK-23602][runtime] org.codehaus.commons.compiler.CompileException…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16698: URL: https://github.com/apache/flink/pull/16698#issuecomment-892376359 ## CI report: * 7b305e3726aa946d5ac25324347e4ce0a1f9a28c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 921d56fcaebe0ea44b81d459e617de336508abcc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16640: [FLINK-22891][runtime] Using CompletableFuture to sync the scheduling…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16640: URL: https://github.com/apache/flink/pull/16640#issuecomment-889598196 ## CI report: * 81126114e90f8947dba92e4bc1bf785f6fc86ac5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 59644cc0b8b79495818890290190e7cf91caed7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * 4fb87e1eedfd547c18b9a07cc52779b6c0ac39cf Azure:

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-03 Thread Ward Harris (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392738#comment-17392738 ] Ward Harris commented on FLINK-23613: - [~jark] hi here is new issue > debezium and canal support

[jira] [Commented] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

2021-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392737#comment-17392737 ] Zhu Zhu commented on FLINK-23590: -

[GitHub] [flink] zhuzhurk commented on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-03 Thread GitBox
zhuzhurk commented on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-892383883 @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] [Created] (FLINK-23613) debezium and canal support read medata op and type

2021-08-03 Thread Ward Harris (Jira)
Ward Harris created FLINK-23613: --- Summary: debezium and canal support read medata op and type Key: FLINK-23613 URL: https://issues.apache.org/jira/browse/FLINK-23613 Project: Flink Issue Type:

[jira] [Commented] (FLINK-23096) HiveParser could not attach the sessionstate of hive

2021-08-03 Thread lixu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392733#comment-17392733 ] lixu commented on FLINK-23096: -- {code:java} //代码占位符 java.lang.IllegalArgumentException: Pathname

[GitHub] [flink] curcur edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-03 Thread GitBox
curcur edited a comment on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-892379997 @akalash I've looked through the code again, I think we should probably also keep ``` timersFinishedFuture.get();

[GitHub] [flink] curcur edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-03 Thread GitBox
curcur edited a comment on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-892379997 @akalash I've looked through the code again, I think we should probably also keep ``` timersFinishedFuture.get();

[GitHub] [flink] curcur edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-03 Thread GitBox
curcur edited a comment on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-892379997 @akalash I've looked through the code again, I think we should probably also keep ``` timersFinishedFuture.get();

[GitHub] [flink] curcur edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-03 Thread GitBox
curcur edited a comment on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-892379997 @akalash I've looked through the code again, I think we should probably also keep ``` timersFinishedFuture.get();

[GitHub] [flink] curcur commented on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-03 Thread GitBox
curcur commented on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-892379997 @akalash I've looked through the code again, I think we should probably also keep ``` timersFinishedFuture.get();

[jira] [Commented] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

2021-08-03 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392730#comment-17392730 ] Yao Zhang commented on FLINK-23609: --- Hi [~xiaojin.wy], The exception is probably caused by passing a

[GitHub] [flink] curcur edited a comment on pull request #16685: [FLINK-23279][tests] Randomly use Changelog Backend in tests

2021-08-03 Thread GitBox
curcur edited a comment on pull request #16685: URL: https://github.com/apache/flink/pull/16685#issuecomment-892362947 LGTM overall, thanks @rkhachatryan for enabling the tests! Please take a look at my inline comments. Also, before accepting it, 1. We should run the test with

[GitHub] [flink] flinkbot commented on pull request #16698: [FLINK-23602][runtime] org.codehaus.commons.compiler.CompileException…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16698: URL: https://github.com/apache/flink/pull/16698#issuecomment-892376359 ## CI report: * 7b305e3726aa946d5ac25324347e4ce0a1f9a28c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 921d56fcaebe0ea44b81d459e617de336508abcc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-753633967 ## CI report: * b1fe24bab5f3a3588e594ed41932c41cc87bd069 Azure:

[GitHub] [flink] flinkbot commented on pull request #16698: [FLINK-23602][runtime] org.codehaus.commons.compiler.CompileException…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16698: URL: https://github.com/apache/flink/pull/16698#issuecomment-892367572 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-23602) org.codehaus.commons.compiler.CompileException: Line 84, Column 78: No applicable constructor/method found for actual parameters "org.apache.flink.table.data.DecimalData

2021-08-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23602: --- Labels: pull-request-available (was: ) > org.codehaus.commons.compiler.CompileException:

[GitHub] [flink] paul8263 opened a new pull request #16698: [FLINK-23602][runtime] org.codehaus.commons.compiler.CompileException…

2021-08-03 Thread GitBox
paul8263 opened a new pull request #16698: URL: https://github.com/apache/flink/pull/16698 …: Line 84, Column 78: No applicable constructor/method found for actual parameters org.apache.flink.table.data.DecimalData ## What is the purpose of the change Fixed No applicable

[GitHub] [flink] curcur commented on pull request #16685: [FLINK-23279][tests] Randomly use Changelog Backend in tests

2021-08-03 Thread GitBox
curcur commented on pull request #16685: URL: https://github.com/apache/flink/pull/16685#issuecomment-892362947 LGTM overall, thanks @rkhachatryan for enabling the tests! Please take a look at my inline comments. Also, before accepting it, 1. We should run the test with `flag =

[GitHub] [flink] flinkbot edited a comment on pull request #16697: [FLINK-23587] Set Deployment's Annotation when using native kubernetes

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16697: URL: https://github.com/apache/flink/pull/16697#issuecomment-892340685 ## CI report: * 2039e73b02de7485b105be09146ab50b627084c0 UNKNOWN * 274516bb1510a46a87a39e207666e3cfffc9859b Azure:

[GitHub] [flink] curcur commented on a change in pull request #16685: [FLINK-23279][tests] Randomly use Changelog Backend in tests

2021-08-03 Thread GitBox
curcur commented on a change in pull request #16685: URL: https://github.com/apache/flink/pull/16685#discussion_r682282987 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -92,10 +94,18 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16697: [FLINK-23587] Set Deployment's Annotation when using native kubernetes

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16697: URL: https://github.com/apache/flink/pull/16697#issuecomment-892340685 ## CI report: * 2039e73b02de7485b105be09146ab50b627084c0 UNKNOWN * 274516bb1510a46a87a39e207666e3cfffc9859b UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-889643808 ## CI report: * cbbae90ac287c25df1d73ca53c6ece3a1032bf7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 356eac1b45f73fa1f32a9a3fe5650821015c08c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

2021-08-03 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22334: -- Description: Please run in the streaming mode. The failed statement  {code:java} // Some

[GitHub] [flink] flinkbot edited a comment on pull request #16695: [FLINK-21116][runtime] Harden DefaultDispatcherRunnerITCase#leaderCha…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16695: URL: https://github.com/apache/flink/pull/16695#issuecomment-892178848 ## CI report: * 5fdeb3228f1dc9e24d9bc2aaf77425ffc7f14e78 Azure:

[GitHub] [flink] flinkbot commented on pull request #16697: [FLINK-23587] Set Deployment's Annotation when using native kubernetes

2021-08-03 Thread GitBox
flinkbot commented on pull request #16697: URL: https://github.com/apache/flink/pull/16697#issuecomment-892340685 ## CI report: * 2039e73b02de7485b105be09146ab50b627084c0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16630: URL: https://github.com/apache/flink/pull/16630#issuecomment-17597 ## CI report: * 5b6bb3991aceb44fd454d6b4fe6665ed8298166b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16638: [FLINK-23513] Remove legacy descriptors

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16638: URL: https://github.com/apache/flink/pull/16638#issuecomment-889186834 ## CI report: * 73bacada917f02fb4f0a9b83c4c327ad0e6a7476 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 356eac1b45f73fa1f32a9a3fe5650821015c08c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 67e73451c554e31d4d9986cf08fc100248a9bc73 Azure:

[jira] [Commented] (FLINK-19276) Allow to read metadata for Debezium format

2021-08-03 Thread Ward Harris (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392694#comment-17392694 ] Ward Harris commented on FLINK-19276: - [~jark] ok > Allow to read metadata for Debezium format >

[GitHub] [flink] wangyang0918 commented on pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

2021-08-03 Thread GitBox
wangyang0918 commented on pull request #16674: URL: https://github.com/apache/flink/pull/16674#issuecomment-892337249 Closed for #16697. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot commented on pull request #16697: [FLINK-23587] Set Deployment's Annotation when using native kubernetes

2021-08-03 Thread GitBox
flinkbot commented on pull request #16697: URL: https://github.com/apache/flink/pull/16697#issuecomment-892336506 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] KarlManong opened a new pull request #16697: [FLINK-23587] Set Deployment's Annotation when using native kubernetes

2021-08-03 Thread GitBox
KarlManong opened a new pull request #16697: URL: https://github.com/apache/flink/pull/16697 What is the purpose of the change This pull requests configs the deployment's annotations as pods' used when deploying with native kubernetes. Brief change log The Jobmanager

[jira] [Closed] (FLINK-23172) Links to Task Failure Recovery page on Configuration page are broken

2021-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23172. --- Resolution: Fixed Fixed via 5183b2af9d467708725bd1454a671bc7689159a5

[GitHub] [flink] zhuzhurk closed pull request #16624: [FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

2021-08-03 Thread GitBox
zhuzhurk closed pull request #16624: URL: https://github.com/apache/flink/pull/16624 -- 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 #16696: Port FLINK-23529 to 1.13

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16696: URL: https://github.com/apache/flink/pull/16696#issuecomment-892319172 ## CI report: * 21941f92e977b4fd1df115fef1122aab4428d196 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16630: URL: https://github.com/apache/flink/pull/16630#issuecomment-17597 ## CI report: * 5b6bb3991aceb44fd454d6b4fe6665ed8298166b Azure:

[GitHub] [flink] beyond1920 commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-03 Thread GitBox
beyond1920 commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r682258760 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[GitHub] [flink] beyond1920 commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-03 Thread GitBox
beyond1920 commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r682258450 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[jira] [Commented] (FLINK-23602) org.codehaus.commons.compiler.CompileException: Line 84, Column 78: No applicable constructor/method found for actual parameters "org.apache.flink.table.data.DecimalDa

2021-08-03 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392686#comment-17392686 ] Yao Zhang commented on FLINK-23602: --- Hi [~xiaojin.wy], The type of database5_t2.c0 in your DDL is

[jira] [Created] (FLINK-23612) SELECT ROUND(CAST(1.2345 AS FLOAT), 1) cannot compile

2021-08-03 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-23612: --- Summary: SELECT ROUND(CAST(1.2345 AS FLOAT), 1) cannot compile Key: FLINK-23612 URL: https://issues.apache.org/jira/browse/FLINK-23612 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * 4fb87e1eedfd547c18b9a07cc52779b6c0ac39cf Azure:

[jira] [Comment Edited] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

2021-08-03 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392680#comment-17392680 ] Kai Chen edited comment on FLINK-23449 at 8/4/21, 3:10 AM: --- [~gaborgsomogyi]

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

2021-08-03 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392680#comment-17392680 ] Kai Chen commented on FLINK-23449: -- [~gaborgsomogyi] [~trohrmann] I'm not stick to code change. It was

[GitHub] [flink] wangyang0918 commented on pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

2021-08-03 Thread GitBox
wangyang0918 commented on pull request #16674: URL: https://github.com/apache/flink/pull/16674#issuecomment-892323911 @KarlManong It seems that I do not have permissions to push commit to the master branch of `g...@github.com:KarlManong/flink.git`. Do you have unchecked the "Allow edits

[jira] [Created] (FLINK-23611) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

2021-08-03 Thread Xintong Song (Jira)
Xintong Song created FLINK-23611: Summary: YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hangs on azure Key:

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

2021-08-03 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392665#comment-17392665 ] Roc Marshal commented on FLINK-22885: - Could someone please help me to advance this jira?  Close the

[GitHub] [flink] wangyang0918 closed pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

2021-08-03 Thread GitBox
wangyang0918 closed pull request #16674: URL: https://github.com/apache/flink/pull/16674 -- 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 commented on pull request #16696: Port FLINK-23529 to 1.13

2021-08-03 Thread GitBox
flinkbot commented on pull request #16696: URL: https://github.com/apache/flink/pull/16696#issuecomment-892319172 ## CI report: * 21941f92e977b4fd1df115fef1122aab4428d196 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16674: URL: https://github.com/apache/flink/pull/16674#issuecomment-890963322 ## CI report: * 425e513893d86249eb9efe3d380a88bb36fd2878 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * 4fb87e1eedfd547c18b9a07cc52779b6c0ac39cf Azure:

[jira] [Created] (FLINK-23610) DefaultSchedulerTest.testProducedPartitionRegistrationTimeout fails on azure

2021-08-03 Thread Xintong Song (Jira)
Xintong Song created FLINK-23610: Summary: DefaultSchedulerTest.testProducedPartitionRegistrationTimeout fails on azure Key: FLINK-23610 URL: https://issues.apache.org/jira/browse/FLINK-23610

[jira] [Commented] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

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

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

2021-08-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22342: - Affects Version/s: 1.14.0 > FlinkKafkaProducerITCase fails with producer leak >

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

2021-08-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22342: - Labels: test-stability (was: auto-deprioritized-critical auto-deprioritized-major

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

2021-08-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22342: - Priority: Major (was: Minor) > FlinkKafkaProducerITCase fails with producer leak >

[jira] [Commented] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

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

[jira] [Commented] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

2021-08-03 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392660#comment-17392660 ] 张祥兵 commented on FLINK-23608: - [~jark] I know the problem may be in the packaging, which is officially

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

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

[GitHub] [flink] flinkbot commented on pull request #16696: Port FLINK-23529 to 1.13

2021-08-03 Thread GitBox
flinkbot commented on pull request #16696: URL: https://github.com/apache/flink/pull/16696#issuecomment-892315449 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] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

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

[jira] [Commented] (FLINK-23557) 'Resuming Externalized Checkpoint (hashmap, sync, no parallelism change) end-to-end test' fails on Azure

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

[jira] [Commented] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

2021-08-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392655#comment-17392655 ] Jark Wu commented on FLINK-23608: - [~zhangxiangbing] that's why I said the problem is packaging. >

[jira] [Assigned] (FLINK-22767) Optimize the initialization of LocalInputPreferredSlotSharingStrategy

2021-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22767: --- Assignee: Zhilong Hong > Optimize the initialization of LocalInputPreferredSlotSharingStrategy >

[jira] [Closed] (FLINK-23599) Remove JobVertex#connectIdInput

2021-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23599. --- Resolution: Done Done via ec9ff1ee5e33529260d6a3adfad4b0b34efde55e > Remove JobVertex#connectIdInput >

[GitHub] [flink] zhuzhurk closed pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

2021-08-03 Thread GitBox
zhuzhurk closed pull request #16686: URL: https://github.com/apache/flink/pull/16686 -- 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 closed pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

2021-08-03 Thread GitBox
xintongsong closed pull request #16636: URL: https://github.com/apache/flink/pull/16636 -- 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-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

2021-08-03 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392651#comment-17392651 ] 张祥兵 commented on FLINK-23608: - [~jark] I use IDAE to run my job, and after packaging, report an error when I

[GitHub] [flink] xintongsong commented on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

2021-08-03 Thread GitBox
xintongsong commented on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-892309511 Thanks, @tsreaper. Merging this. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] KarlManong commented on a change in pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

2021-08-03 Thread GitBox
KarlManong commented on a change in pull request #16674: URL: https://github.com/apache/flink/pull/16674#discussion_r682237085 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesJobManagerFactoryTest.java ## @@ -170,12 +177,9

[GitHub] [flink] wangyang0918 commented on a change in pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

2021-08-03 Thread GitBox
wangyang0918 commented on a change in pull request #16674: URL: https://github.com/apache/flink/pull/16674#discussion_r682236420 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesJobManagerFactoryTest.java ## @@ -170,12

[jira] [Closed] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

2021-08-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23608. --- Resolution: Not A Problem Please use English in JIRA. Regarding your exception stack, there is no kafka

[GitHub] [flink] wsry commented on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-03 Thread GitBox
wsry commented on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-892306109 Rebased master and squashed fixup commits. -- 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

[GitHub] [flink] tsreaper commented on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

2021-08-03 Thread GitBox
tsreaper commented on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-892305767 > @flinkbot run azure It already succeeded in https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=21395=results -- This is an automated message

[jira] [Updated] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

2021-08-03 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-23609: --- Description: {code:java} CREATE TABLE database5_t2 ( `c0` DECIMAL ) WITH ( 'connector' =

[jira] [Updated] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

2021-08-03 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-23609: --- Summary: Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)" (was:

[jira] [Updated] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

2021-08-03 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-23609: --- Environment: (was: java.lang.NumberFormatException: Infinite or NaN at

[jira] [Created] (FLINK-23609) Codeine error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

2021-08-03 Thread xiaojin.wy (Jira)
xiaojin.wy created FLINK-23609: -- Summary: Codeine error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)" Key: FLINK-23609 URL: https://issues.apache.org/jira/browse/FLINK-23609

[GitHub] [flink] flinkbot edited a comment on pull request #16640: [FLINK-22891][runtime] Using CompletableFuture to sync the scheduling…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16640: URL: https://github.com/apache/flink/pull/16640#issuecomment-889598196 ## CI report: * 81126114e90f8947dba92e4bc1bf785f6fc86ac5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-889045676 ## CI report: * 46332f2c7aa2e4d4b6489f94eccdd866fbea79f1 Azure:

[jira] [Commented] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory'

2021-08-03 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392638#comment-17392638 ] 张祥兵 commented on FLINK-18184: - Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could 

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-753633967 ## CI report: * 7b92671c3ecb252643f1b27f9a9d12c8db1f0ccf Azure:

[GitHub] [flink] xintongsong commented on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

2021-08-03 Thread GitBox
xintongsong commented on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-892296492 @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-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

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

[GitHub] [flink] xintongsong commented on pull request #16640: [FLINK-22891][runtime] Using CompletableFuture to sync the scheduling…

2021-08-03 Thread GitBox
xintongsong commented on pull request #16640: URL: https://github.com/apache/flink/pull/16640#issuecomment-892296368 @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] [Created] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

2021-08-03 Thread Jira
张祥兵 created FLINK-23608: --- Summary: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory Key: FLINK-23608 URL:

[jira] [Commented] (FLINK-23096) HiveParser could not attach the sessionstate of hive

2021-08-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392631#comment-17392631 ] luoyuxia commented on FLINK-23096: -- [~leexu]  Actual, path.getFileSystem with return HdfsFileSystem or 

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-753633967 ## CI report: * 7b92671c3ecb252643f1b27f9a9d12c8db1f0ccf Azure:

[jira] [Commented] (FLINK-20845) Drop support for Scala 2.11

2021-08-03 Thread Nick Burkard (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392621#comment-17392621 ] Nick Burkard commented on FLINK-20845: -- [~eloisant] I just rebased and pushed to the same branch.

[GitHub] [flink] flinkbot edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-889643808 ## CI report: * cbbae90ac287c25df1d73ca53c6ece3a1032bf7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-889643808 ## CI report: * cbbae90ac287c25df1d73ca53c6ece3a1032bf7d Azure:

  1   2   3   4   5   6   7   >