[GitHub] [flink-web] dawidwys commented on a change in pull request #436: Add Apache Flink release 1.13.0

2021-04-26 Thread GitBox
dawidwys commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r620168175 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

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

2021-04-26 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] [Assigned] (FLINK-22442) Using scala api to change the TimeCharacteristic of the PatternStream is invalid

2021-04-26 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22442: Assignee: Cedric Chen > Using scala api to change the TimeCharacteristic of the

[GitHub] [flink] dawidwys commented on a change in pull request #15742: [FLINK-22442][CEP] Fix Using scala api to change the TimeCharacteristic o…

2021-04-26 Thread GitBox
dawidwys commented on a change in pull request #15742: URL: https://github.com/apache/flink/pull/15742#discussion_r620157830 ## File path: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala ## @@ -447,17 +447,17 @@ class

[jira] [Closed] (FLINK-22301) Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22301. - Fix Version/s: 1.13.1 1.14.0 Resolution: Fixed Fixed via 1.14.0:

[GitHub] [flink] tillrohrmann closed pull request #15732: [FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread GitBox
tillrohrmann closed pull request #15732: URL: https://github.com/apache/flink/pull/15732 -- 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] flinkbot commented on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

2021-04-26 Thread GitBox
flinkbot commented on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826707265 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] wuchong commented on pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

2021-04-26 Thread GitBox
wuchong commented on pull request #15755: URL: https://github.com/apache/flink/pull/15755#issuecomment-826705508 Please do not use "git merge" to rebase branches, otherwise the changes is hard to track. Please use "git rebase" instead. IntelliJ IDEA provide an easy tool to do git rebase,

[jira] [Updated] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

2021-04-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22451: --- Labels: pull-request-available (was: ) > Support (*) as parameter of table

[GitHub] [flink] yittg opened a new pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

2021-04-26 Thread GitBox
yittg opened a new pull request #15768: URL: https://github.com/apache/flink/pull/15768 ## What is the purpose of the change Support (*) as parameter of UDFs in Table API, it will be expanded as all columns of the table. ## Brief change log ## Verifying

[jira] [Commented] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

2021-04-26 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331982#comment-17331982 ] Dawid Wysakowicz commented on FLINK-22416: -- Honestly, [~TsReaper] I think what you reported is

[jira] [Commented] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

2021-04-26 Thread Johannes Moser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331975#comment-17331975 ] Johannes Moser commented on FLINK-22455: [~tartarus] which flink version are you using? >

[GitHub] [flink] flinkbot edited a comment on pull request #15732: [FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15732: URL: https://github.com/apache/flink/pull/15732#issuecomment-825560646 ## CI report: * 49750a03399c7fba398d0f619a171de26b0c1599 UNKNOWN * 292e39da3182e09c06781b5e8288d4384651ae88 Azure:

[jira] [Assigned] (FLINK-22301) Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-22301: - Assignee: Nicholas Jiang > Statebackend and CheckpointStorage type is not shown in the

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-26 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331973#comment-17331973 ] todd commented on FLINK-22318: -- [~jark]  code review   > Support RENAME column name for ALTER TABLE

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

2021-04-26 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] [Assigned] (FLINK-14393) add an option to enable/disable cancel job in web ui

2021-04-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14393: - Assignee: fangyue > add an option to enable/disable cancel job in web ui >

[jira] [Commented] (FLINK-14393) add an option to enable/disable cancel job in web ui

2021-04-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331969#comment-17331969 ] Till Rohrmann commented on FLINK-14393: --- This is great news [~fangyue]. I've assigned you to this

[jira] [Commented] (FLINK-22353) Add CPU metrics of TaskManager and JobManager into Flink WebUI

2021-04-26 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331962#comment-17331962 ] Roc Marshal commented on FLINK-22353: - [~knaufk]How about unifieding pluggable configurations of

[jira] [Closed] (FLINK-22431) AdaptiveScheduler does not log failure cause when recovering

2021-04-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22431. - Fix Version/s: (was: 1.13.0) 1.13.1 1.14.0

[jira] [Commented] (FLINK-14393) add an option to enable/disable cancel job in web ui

2021-04-26 Thread fangyue (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331955#comment-17331955 ] fangyue commented on FLINK-14393: - [~flink-jira-bot] We can control the ability to cancel a task by

[GitHub] [flink] tillrohrmann closed pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

2021-04-26 Thread GitBox
tillrohrmann closed pull request #15736: URL: https://github.com/apache/flink/pull/15736 -- 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,

[jira] [Updated] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-26 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei updated FLINK-22476: Description: the current description for `execution.target` only lists `remote`, `local`,

[jira] [Created] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-26 Thread Wei-Che Wei (Jira)
Wei-Che Wei created FLINK-22476: --- Summary: Extend the description of the config option `execution.target` Key: FLINK-22476 URL: https://issues.apache.org/jira/browse/FLINK-22476 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15763: URL: https://github.com/apache/flink/pull/15763#issuecomment-826589720 ## CI report: * 03b1c6bc999ee92a23eb0a0b84a368f2643e841d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15762: [FLINK-22469][runtime-web] Fix NoSuchFileException in HistoryServer

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15762: URL: https://github.com/apache/flink/pull/15762#issuecomment-826557889 ## CI report: * c9f47fa8e680fd94de36e1c2451b41bf46aaf531 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

2021-04-26 Thread GitBox
tillrohrmann commented on a change in pull request #15741: URL: https://github.com/apache/flink/pull/15741#discussion_r620121535 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -340,108 +319,54 @@ public void testExecute()

[jira] [Commented] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

2021-04-26 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331932#comment-17331932 ] Caizhi Weng commented on FLINK-22416: - I've reproduced this issue by running the tests repeatedly in

[jira] [Updated] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

2021-04-26 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22416: Attachment: threads_report.txt > UpsertKafkaTableITCase hangs when collecting results >

[jira] [Updated] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

2021-04-26 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22416: Attachment: idea-test.png > UpsertKafkaTableITCase hangs when collecting results >

[GitHub] [flink] tillrohrmann commented on pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

2021-04-26 Thread GitBox
tillrohrmann commented on pull request #15736: URL: https://github.com/apache/flink/pull/15736#issuecomment-826665603 Thanks for the review @zentol. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] tillrohrmann closed pull request #15740: [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

2021-04-26 Thread GitBox
tillrohrmann closed pull request #15740: URL: https://github.com/apache/flink/pull/15740 -- 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] tillrohrmann commented on pull request #15740: [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

2021-04-26 Thread GitBox
tillrohrmann commented on pull request #15740: URL: https://github.com/apache/flink/pull/15740#issuecomment-826663657 Thanks for the review @wangyang0918. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Closed] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

2021-04-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22463. -- Resolution: Fixed Fixed in 1.13.0: b813e7289b013fe077f048562ef5f4118bae4a3c Fixed in 1.14.0:

[GitHub] [flink] godfreyhe closed pull request #15759: [FLINK-22463][table-planner-blink] Fix IllegalArgumentException in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

2021-04-26 Thread GitBox
godfreyhe closed pull request #15759: URL: https://github.com/apache/flink/pull/15759 -- 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] tillrohrmann commented on a change in pull request #14012: [FLINK-17857][test] Make K8s e2e tests could run on Mac

2021-04-26 Thread GitBox
tillrohrmann commented on a change in pull request #14012: URL: https://github.com/apache/flink/pull/14012#discussion_r620113431 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -178,21 +180,9 @@ function cleanup { stop_kubernetes }

[jira] [Commented] (FLINK-22353) Add CPU metrics of TaskManager and JobManager into Flink WebUI

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331918#comment-17331918 ] Konstantin Knauf commented on FLINK-22353: -- I am not sure about this. One the one hand, we

[GitHub] [flink] tillrohrmann commented on a change in pull request #14012: [FLINK-17857][test] Make K8s e2e tests could run on Mac

2021-04-26 Thread GitBox
tillrohrmann commented on a change in pull request #14012: URL: https://github.com/apache/flink/pull/14012#discussion_r620109094 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -25,7 +25,7 @@ MINIKUBE_START_RETRIES=3 MINIKUBE_START_BACKOFF=5

[jira] [Closed] (FLINK-22445) Add more examples of row-based operations in PyFlink doc

2021-04-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22445. --- Resolution: Fixed Merged to - master via e63c342a4807b20319b31c2697df7ca974316671 - release-1.13 via

[jira] [Commented] (FLINK-22438) add numRecordsOut metric for Async IO

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331911#comment-17331911 ] Konstantin Knauf commented on FLINK-22438: -- [~Tony Giao] Thank you for opening this ticket. I

[jira] [Updated] (FLINK-22438) add numRecordsOut metric for Async IO

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22438: - Issue Type: Bug (was: Improvement) > add numRecordsOut metric for Async IO >

[jira] [Updated] (FLINK-22438) add numRecordsOut metric for Async IO

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22438: - Affects Version/s: 1.13.0 1.11.3 > add numRecordsOut metric for

[GitHub] [flink] dianfu closed pull request #15757: [FLINK-22445][python][docs] Add more examples of row-based operations in PyFlink doc

2021-04-26 Thread GitBox
dianfu closed pull request #15757: URL: https://github.com/apache/flink/pull/15757 -- 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] flinkbot edited a comment on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-826633392 ## CI report: * 0d6fd33ea7384941d5a680e024cd79293f36579f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15762: [FLINK-22469][runtime-web] Fix NoSuchFileException in HistoryServer

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15762: URL: https://github.com/apache/flink/pull/15762#issuecomment-826557889 ## CI report: * c9f47fa8e680fd94de36e1c2451b41bf46aaf531 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15732: [FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15732: URL: https://github.com/apache/flink/pull/15732#issuecomment-825560646 ## CI report: * 49750a03399c7fba398d0f619a171de26b0c1599 UNKNOWN * 292e39da3182e09c06781b5e8288d4384651ae88 Azure:

[GitHub] [flink] dianfu commented on a change in pull request #15757: [FLINK-22445][python][docs] Add more examples of row-based operations in PyFlink doc

2021-04-26 Thread GitBox
dianfu commented on a change in pull request #15757: URL: https://github.com/apache/flink/pull/15757#discussion_r620044827 ## File path: docs/content.zh/docs/dev/python/table/row_based_operations.md ## @@ -0,0 +1,275 @@ +--- +title: "Row-based Operations" +weight: 31 +type:

[jira] [Assigned] (FLINK-11103) Set a default uncaught exception handler

2021-04-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11103: - Assignee: Ashwin Kolhatkar > Set a default uncaught exception handler >

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

2021-04-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331906#comment-17331906 ] Till Rohrmann commented on FLINK-11103: --- Hi [~ashwinkolhatkar], thanks for reaching out to the

[GitHub] [flink] flinkbot edited a comment on pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15765: URL: https://github.com/apache/flink/pull/15765#issuecomment-826604275 ## CI report: * fdf685340b39330a9d37060e97a08fbad0a5 Azure:

[GitHub] [flink] flinkbot commented on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-26 Thread GitBox
flinkbot commented on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-826633392 ## CI report: * 0d6fd33ea7384941d5a680e024cd79293f36579f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15764: [FLINK-22471][flink-table][flink-connectors] Improvements to ConfigOption descriptions

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15764: URL: https://github.com/apache/flink/pull/15764#issuecomment-826589841 ## CI report: * f0ec66c153d735ef2766164aef8dac76444ef870 UNKNOWN * 99b5a1bdb1cb456489f9c85fbb0b0cd5953877b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15766: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15766: URL: https://github.com/apache/flink/pull/15766#issuecomment-826604395 ## CI report: * 9fd31b0419d6695a1ed597429057a960c5420fef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15761: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15761: URL: https://github.com/apache/flink/pull/15761#issuecomment-826546091 ## CI report: * 82a27a5093a81704448c370e7a29894b515b25fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15759: [FLINK-22463][table-planner-blink] Fix IllegalArgumentException in WindowAttachedWindowingStrategy when two phase is enabled for dist

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15759: URL: https://github.com/apache/flink/pull/15759#issuecomment-826494695 ## CI report: * 99b2ac7e2b6705a1bf3b2d087c399bce199380ee Azure:

[GitHub] [flink-jira-bot] knaufk merged pull request #8: [FLINK-22036] clarify relationship between README and Confluence page

2021-04-26 Thread GitBox
knaufk merged pull request #8: URL: https://github.com/apache/flink-jira-bot/pull/8 -- 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,

[jira] [Commented] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix.

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331897#comment-17331897 ] Konstantin Knauf commented on FLINK-22441: -- Netty 3.10.6 comes in as a transitive dependency of

[jira] [Updated] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. th

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22441: - Affects Version/s: 1.13.0 1.12.2 > In Flink v1.11.3 contains

[GitHub] [flink] SteNicholas commented on pull request #15732: [FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread GitBox
SteNicholas commented on pull request #15732: URL: https://github.com/apache/flink/pull/15732#issuecomment-826630303 @gaoyunhaii Yes, I have manually tests the changes for the statebackend name and checkpoint storage type. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] Senhongl commented on pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

2021-04-26 Thread GitBox
Senhongl commented on pull request #15763: URL: https://github.com/apache/flink/pull/15763#issuecomment-826630164 @wuchong @PatrickRen @becketqin Could you please help me review it and see if anything needs to be modified? -- This is an automated message from the Apache Git Service.

[GitHub] [flink] gaoyunhaii commented on pull request #15732: [FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread GitBox
gaoyunhaii commented on pull request #15732: URL: https://github.com/apache/flink/pull/15732#issuecomment-826627318 Very thanks @SteNicholas for opening the PR! I only have a minor issue. And have you tested it manually via starting a new cluster and check the UI ? -- This is an

[GitHub] [flink] echauchot closed pull request #15436: [FLINK-6417] Glob support for FileInputFormat

2021-04-26 Thread GitBox
echauchot closed pull request #15436: URL: https://github.com/apache/flink/pull/15436 -- 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] echauchot commented on pull request #15436: [FLINK-6417] Glob support for FileInputFormat

2021-04-26 Thread GitBox
echauchot commented on pull request #15436: URL: https://github.com/apache/flink/pull/15436#issuecomment-826626541 @zentol @AHeise I'm closing this PR because I discovered that it does not work on S3 filesystem. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-web] AHeise commented on a change in pull request #436: Add Apache Flink release 1.13.0

2021-04-26 Thread GitBox
AHeise commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r620080598 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15732: [FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown in the Web UI

2021-04-26 Thread GitBox
gaoyunhaii commented on a change in pull request #15732: URL: https://github.com/apache/flink/pull/15732#discussion_r620080063 ## File path: flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts ## @@ -115,6 +115,8 @@ export interface CheckPointConfigInterface {

[GitHub] [flink] tillrohrmann commented on a change in pull request #15687: [FLINK-22373][docs] Add Flink 1.13 release notes

2021-04-26 Thread GitBox
tillrohrmann commented on a change in pull request #15687: URL: https://github.com/apache/flink/pull/15687#discussion_r620073509 ## File path: docs/content.zh/release-notes/flink-1.13.md ## @@ -0,0 +1,227 @@ +--- +title: "Release Notes - Flink 1.13" +--- + + +# Release Notes -

[jira] [Assigned] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

2021-04-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22451: --- Assignee: Yi Tang > Support (*) as parameter of table UserDefinedFunction >

[GitHub] [flink] sv3ndk commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-04-26 Thread GitBox
sv3ndk commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-826620751 Hi all, Can I please collect your feed-back on my proposal for updating the current PR? What i suggest is simply to remove the configuration flag

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

2021-04-26 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331888#comment-17331888 ] Yi Tang commented on FLINK-22451: - Please assign it to me if no others reject this feature and nothing

[jira] [Closed] (FLINK-21247) flink iceberg table map cannot convert to datastream

2021-04-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-21247. Resolution: Fixed Fixed via: master: 033cdeae0e510a930e9975542ae0a43c4484adeb release-1.13: 

[jira] [Updated] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. th

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22441: - Affects Version/s: 1.11.3 > In Flink v1.11.3 contains netty(version:3.10.6)

[GitHub] [flink] JingsongLi merged pull request #15758: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

2021-04-26 Thread GitBox
JingsongLi merged pull request #15758: URL: https://github.com/apache/flink/pull/15758 -- 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,

[jira] [Updated] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. th

2021-04-26 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22441: - Component/s: Runtime / Coordination > In Flink v1.11.3 contains netty(version:3.10.6)

[GitHub] [flink] flinkbot commented on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-26 Thread GitBox
flinkbot commented on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-826612012 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] AHeise commented on a change in pull request #15598: [FLINK-22136][e2e] Console output changed to exception in DataStreamA…

2021-04-26 Thread GitBox
AHeise commented on a change in pull request #15598: URL: https://github.com/apache/flink/pull/15598#discussion_r620066283 ## File path: flink-end-to-end-tests/run-nightly-tests.sh ## @@ -103,15 +103,15 @@ run_test "Resuming Savepoint (rocks, scale down, rocks timers)

[jira] [Updated] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22393: --- Labels: pull-request-available (was: ) > Translate the page of "Execution Mode

[GitHub] [flink] 95chenjz opened a new pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-26 Thread GitBox
95chenjz opened a new pull request #15767: URL: https://github.com/apache/flink/pull/15767 ## What is the purpose of the change Translate the page of "Execution Mode (Batch/Streaming)" into Chinese The page url of "Execution Mode (Batch/Streaming)" is

[GitHub] [flink] flinkbot commented on pull request #15766: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

2021-04-26 Thread GitBox
flinkbot commented on pull request #15766: URL: https://github.com/apache/flink/pull/15766#issuecomment-826604395 ## CI report: * 9fd31b0419d6695a1ed597429057a960c5420fef UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

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

[GitHub] [flink] flinkbot edited a comment on pull request #15758: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15758: URL: https://github.com/apache/flink/pull/15758#issuecomment-826479500 ## CI report: * 422de5b7c373f51311b0e8f4f48a1a679e9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15763: URL: https://github.com/apache/flink/pull/15763#issuecomment-826589720 ## CI report: * 03b1c6bc999ee92a23eb0a0b84a368f2643e841d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15764: [FLINK-22471][flink-table][flink-connectors] Improvements to ConfigOption descriptions

2021-04-26 Thread GitBox
flinkbot edited a comment on pull request #15764: URL: https://github.com/apache/flink/pull/15764#issuecomment-826589841 ## CI report: * f0ec66c153d735ef2766164aef8dac76444ef870 UNKNOWN * 99b5a1bdb1cb456489f9c85fbb0b0cd5953877b7 UNKNOWN Bot commands The

[jira] [Commented] (FLINK-22456) Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

2021-04-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331876#comment-17331876 ] Jingsong Lee commented on FLINK-22456: -- [~kanata163] I think you can take a look new source API. >

[GitHub] [flink] rmetzger commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-04-26 Thread GitBox
rmetzger commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-826593416 I can not explain what's happening here with Azure. I deployed this PR do my personal Azure account, and it was able to download the dependency. Here's the run:

[jira] [Created] (FLINK-22474) Display job configuration in web-ui

2021-04-26 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22474: - Summary: Display job configuration in web-ui Key: FLINK-22474 URL: https://issues.apache.org/jira/browse/FLINK-22474 Project: Flink Issue Type:

[jira] [Closed] (FLINK-17280) Migrate existing flink-benchmarks under apache project

2021-04-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17280. -- Resolution: Fixed > Migrate existing flink-benchmarks under apache project >

[jira] [Closed] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2021-04-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16850. -- Fix Version/s: 1.13.0 Resolution: Fixed I've updated the release docs > Make

[GitHub] [flink-jira-bot] knaufk commented on a change in pull request #11: [hotfix] Make comment language friendly to contributors

2021-04-26 Thread GitBox
knaufk commented on a change in pull request #11: URL: https://github.com/apache/flink-jira-bot/pull/11#discussion_r620044745 ## File path: config.yaml ## @@ -20,38 +20,77 @@ stale_assigned: stale_days: 14 warning_days: 7 warning_label: "stale-assigned" -

[jira] [Updated] (FLINK-22471) Use formatted descriptions for connector options

2021-04-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22471: --- Labels: pull-request-available (was: ) > Use formatted descriptions for connector options

[jira] [Commented] (FLINK-22414) Consider env.hadoop.conf.dir when looking for the hadoop configuration

2021-04-26 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331869#comment-17331869 ] Flavio Pompermaier commented on FLINK-22414: Hi [~fly_in_gis], I don't actually see any

[GitHub] [flink] flinkbot commented on pull request #15764: [FLINK-22471][flink-table][flink-connectors] Improvements to ConfigOption descriptions

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

[GitHub] [flink] flinkbot commented on pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

2021-04-26 Thread GitBox
flinkbot commented on pull request #15763: URL: https://github.com/apache/flink/pull/15763#issuecomment-826589720 ## CI report: * 03b1c6bc999ee92a23eb0a0b84a368f2643e841d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-22471) Use formatted descriptions for connector options

2021-04-26 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-22471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-22471: -- Component/s: Table SQL / Planner > Use formatted descriptions for connector options >

[jira] [Created] (FLINK-22475) Datagen connector does not list its available options with placeholders

2021-04-26 Thread Jira
Ingo Bürk created FLINK-22475: - Summary: Datagen connector does not list its available options with placeholders Key: FLINK-22475 URL: https://issues.apache.org/jira/browse/FLINK-22475 Project: Flink

[jira] [Assigned] (FLINK-22471) Use formatted descriptions for connector options

2021-04-26 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-22471: Assignee: Ingo Bürk > Use formatted descriptions for connector options >

[GitHub] [flink] flinkbot commented on pull request #15766: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

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

[GitHub] [flink] flinkbot commented on pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

2021-04-26 Thread GitBox
flinkbot commented on pull request #15765: URL: https://github.com/apache/flink/pull/15765#issuecomment-826587028 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] [Created] (FLINK-22473) Kinesis connector options are not listed by its factory

2021-04-26 Thread Jira
Ingo Bürk created FLINK-22473: - Summary: Kinesis connector options are not listed by its factory Key: FLINK-22473 URL: https://issues.apache.org/jira/browse/FLINK-22473 Project: Flink Issue

[jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-04-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331864#comment-17331864 ] Leonard Xu commented on FLINK-22472: CC :[~lzljs3620320] > The real partition data produced time is

[jira] [Created] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-04-26 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-22472: -- Summary: The real partition data produced time is behind meta(_SUCCESS) file produced Key: FLINK-22472 URL: https://issues.apache.org/jira/browse/FLINK-22472 Project:

<    1   2   3   4   5   6   >