[GitHub] [flink] zentol merged pull request #18800: [FLINK-26187][docs] Chinese docs only redirect for chinese urls

2022-02-16 Thread GitBox
zentol merged pull request #18800: URL: https://github.com/apache/flink/pull/18800 -- 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 #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 69d42893d3874932d77329e758818b743c528489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 9b492093f225a63b04fd8de96adeffec551bf31c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 8dbb8256563d48a7bdb13489d6670ae6215eebe1 Azure:

[jira] [Updated] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

2022-02-16 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25585: Priority: Critical (was: Major) > JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 8dbb8256563d48a7bdb13489d6670ae6215eebe1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Supports a system time function(now() and current_timestamp) in index pattern

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 47b985560b3efeb6b084c62e67ab56c2eb2cd7a9 Azure:

[jira] [Commented] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

2022-02-16 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493730#comment-17493730 ] Yun Gao commented on FLINK-25585: -

[jira] [Updated] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

2022-02-16 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25585: Affects Version/s: 1.15.0 > JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 8dbb8256563d48a7bdb13489d6670ae6215eebe1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * c411c34c583a356d32abc7a2707161abb00ff929 Azure:

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

2022-02-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493724#comment-17493724 ] Martijn Visser commented on FLINK-16419: [~qinjunjerry]It does, according to this comment

[GitHub] [flink] MrWhiteSike commented on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-16 Thread GitBox
MrWhiteSike commented on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1042656222 [@RocMarshal](https://github.com/RocMarshal) Thanks for the suggestions and please review it again. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] twalthr closed pull request #18809: [FLINK-26199] Annotate StatementSet#compilePlan as experimental.

2022-02-16 Thread GitBox
twalthr closed pull request #18809: URL: https://github.com/apache/flink/pull/18809 -- 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-26165) SavepointFormatITCase fails on azure

2022-02-16 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493721#comment-17493721 ] Yun Gao commented on FLINK-26165: -

[jira] [Closed] (FLINK-26199) StatementSet.compilePlan doesn't pass the archiunit tests

2022-02-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-26199. Assignee: David Morávek Resolution: Fixed Fixed in master:

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * 90c1d1a155c2ebc29b92799b887b71e093a838bd Azure:

[GitHub] [flink-docker] knaufk merged pull request #104: Add GPG key for 1.13.6 release

2022-02-16 Thread GitBox
knaufk merged pull request #104: URL: https://github.com/apache/flink-docker/pull/104 -- 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 #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * 710ff5f63fe97acf8e60fe509cad8d6b121d468c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * 90c1d1a155c2ebc29b92799b887b71e093a838bd Azure:

[GitHub] [flink] deadwind4 removed a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
deadwind4 removed a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1042598533 @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

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-16 Thread GitBox
JingsongLi commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r808740283 ## File path: pom.xml ## @@ -54,20 +54,23 @@ under the License. flink-table-store-core flink-table-store-connector +

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-16 Thread GitBox
LadyForest commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r808739591 ## File path: pom.xml ## @@ -54,20 +54,23 @@ under the License. flink-table-store-core flink-table-store-connector +

[GitHub] [flink] hanpf closed pull request #18811: My/release 1.14

2022-02-16 Thread GitBox
hanpf closed pull request #18811: URL: https://github.com/apache/flink/pull/18811 -- 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-table-store] JingsongLi commented on a change in pull request #19: [FLINK-26066] Introduce FileStoreRead

2022-02-16 Thread GitBox
JingsongLi commented on a change in pull request #19: URL: https://github.com/apache/flink-table-store/pull/19#discussion_r808730677 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreReadImpl.java ## @@ -0,0 +1,58 @@ +/* +

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #19: [FLINK-26066] Introduce FileStoreRead

2022-02-16 Thread GitBox
JingsongLi commented on a change in pull request #19: URL: https://github.com/apache/flink-table-store/pull/19#discussion_r808729514 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreReadImpl.java ## @@ -0,0 +1,58 @@ +/* +

[GitHub] [flink] hanpf commented on pull request #18811: My/release 1.14

2022-02-16 Thread GitBox
hanpf commented on pull request #18811: URL: https://github.com/apache/flink/pull/18811#issuecomment-1042634671 > sorry faulty operation,please ignore -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD

2022-02-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493704#comment-17493704 ] Gyula Fora commented on FLINK-26142: I agree that the docker stuff is difficult to answer straight

[GitHub] [flink] flinkbot edited a comment on pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18797: URL: https://github.com/apache/flink/pull/18797#issuecomment-1041240844 ## CI report: * 716d8eb657299bd7243957443128ae3935cb3e31 Azure:

[GitHub] [flink] flinkbot commented on pull request #18811: My/release 1.14

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

[GitHub] [flink] flinkbot edited a comment on pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18797: URL: https://github.com/apache/flink/pull/18797#issuecomment-1041240844 ## CI report: * 716d8eb657299bd7243957443128ae3935cb3e31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18772: [FLINK-25992][Runtime/Coordination, Tests] For stability, wait until the latest restored checkpoint is not null to avoid race condit

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18772: URL: https://github.com/apache/flink/pull/18772#issuecomment-1040071363 ## CI report: * 45f15c4bae06b4c40e16ffc9ae1ebe0a72527363 Azure:

[GitHub] [flink] pltbkd commented on a change in pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

2022-02-16 Thread GitBox
pltbkd commented on a change in pull request #18797: URL: https://github.com/apache/flink/pull/18797#discussion_r808722805 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -958,6 +958,73 @@ val sink = FileSink {{< /tab >}} {{< /tabs >}} +###

[GitHub] [flink] flinkbot edited a comment on pull request #18811: My/release 1.14

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18811: URL: https://github.com/apache/flink/pull/18811#issuecomment-1042626396 ## CI report: * cce57a3e31067bdeb9ddb8f41b350b763840dbba Azure:

[jira] [Updated] (FLINK-26135) Separate job and deployment errors in FlinkDeployment status

2022-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26135: --- Labels: pull-request-available (was: ) > Separate job and deployment errors in

[GitHub] [flink] flinkbot commented on pull request #18811: My/release 1.14

2022-02-16 Thread GitBox
flinkbot commented on pull request #18811: URL: https://github.com/apache/flink/pull/18811#issuecomment-1042626396 ## CI report: * cce57a3e31067bdeb9ddb8f41b350b763840dbba UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] hanpf opened a new pull request #18811: My/release 1.14

2022-02-16 Thread GitBox
hanpf opened a new pull request #18811: URL: https://github.com/apache/flink/pull/18811 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Created] (FLINK-26209) Possibility of Command Injection attack

2022-02-16 Thread Iman Sharafaldin (Jira)
Iman Sharafaldin created FLINK-26209: Summary: Possibility of Command Injection attack Key: FLINK-26209 URL: https://issues.apache.org/jira/browse/FLINK-26209 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24677) JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread

2022-02-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493696#comment-17493696 ] 张健 commented on FLINK-24677: OK, thanks, I will do it next week. When PR is ready, I will ping you in

[GitHub] [flink] MrWhiteSike commented on a change in pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-16 Thread GitBox
MrWhiteSike commented on a change in pull request #18718: URL: https://github.com/apache/flink/pull/18718#discussion_r808717415 ## File path: docs/content.zh/docs/connectors/datastream/filesystem.md ## @@ -811,61 +809,63 @@ input.sinkTo(sink) {{< /tab >}} {{< /tabs >}}

[jira] [Assigned] (FLINK-26208) Introduce implementation of ManagedTableFactory

2022-02-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26208: Assignee: Jane Chan > Introduce implementation of ManagedTableFactory >

[jira] [Closed] (FLINK-20830) Add a type of HEADLESS_CLUSTER_IP for rest service type

2022-02-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-20830. - Resolution: Fixed > Add a type of HEADLESS_CLUSTER_IP for rest service type >

[jira] [Comment Edited] (FLINK-25877) Update the copyright year in NOTICE files

2022-02-16 Thread nyingping (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490909#comment-17490909 ] nyingping edited comment on FLINK-25877 at 2/17/22, 6:28 AM: - Could someone

[jira] [Commented] (FLINK-20830) Add a type of HEADLESS_CLUSTER_IP for rest service type

2022-02-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493687#comment-17493687 ] Yang Wang commented on FLINK-20830: --- Fixed via: master(release-1.15):

[jira] [Comment Edited] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

2022-02-16 Thread nyingping (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490908#comment-17490908 ] nyingping edited comment on FLINK-26086 at 2/17/22, 6:28 AM: - Could someone

[jira] [Updated] (FLINK-20830) Add a type of HEADLESS_CLUSTER_IP for rest service type

2022-02-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20830: -- Fix Version/s: 1.14.4 > Add a type of HEADLESS_CLUSTER_IP for rest service type >

[jira] [Created] (FLINK-26208) Introduce implementation of ManagedTableFactory

2022-02-16 Thread Jane Chan (Jira)
Jane Chan created FLINK-26208: - Summary: Introduce implementation of ManagedTableFactory Key: FLINK-26208 URL: https://issues.apache.org/jira/browse/FLINK-26208 Project: Flink Issue Type:

[GitHub] [flink] wangyang0918 merged pull request #18767: [FLINK-20830][BP 1.14][k8s] Add type of Headless_Cluster_IP for external rest …

2022-02-16 Thread GitBox
wangyang0918 merged pull request #18767: URL: https://github.com/apache/flink/pull/18767 -- 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 #18810: [FLINK-25289][hotfix] use the normal jar in flink-end-to-end-tests instead of a separate one

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18810: URL: https://github.com/apache/flink/pull/18810#issuecomment-1042612648 ## CI report: * 5ec04ad6ed6a32bb3e6b7167fbacda8511f12b48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147 ## CI report: * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure:

[jira] [Created] (FLINK-26207) refactor web ui's components to depend on module's injected config object

2022-02-16 Thread Junhan Yang (Jira)
Junhan Yang created FLINK-26207: --- Summary: refactor web ui's components to depend on module's injected config object Key: FLINK-26207 URL: https://issues.apache.org/jira/browse/FLINK-26207 Project:

[GitHub] [flink] flinkbot commented on pull request #18810: [FLINK-25289][hotfix] use the normal jar in flink-end-to-end-tests instead of a separate one

2022-02-16 Thread GitBox
flinkbot commented on pull request #18810: URL: https://github.com/apache/flink/pull/18810#issuecomment-1042613234 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] godfreyhe commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

2022-02-16 Thread GitBox
godfreyhe commented on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1042612877 @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

[GitHub] [flink] flinkbot commented on pull request #18810: [FLINK-25289][hotfix] use the normal jar in flink-end-to-end-tests instead of a separate one

2022-02-16 Thread GitBox
flinkbot commented on pull request #18810: URL: https://github.com/apache/flink/pull/18810#issuecomment-1042612648 ## CI report: * 5ec04ad6ed6a32bb3e6b7167fbacda8511f12b48 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] (FLINK-26201) FileStoreScanTest is not stable

2022-02-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26201 ] Jane Chan deleted comment on FLINK-26201: --- was (Author: qingyue): The reason is due to the dependency of flink-avro is not updated. > FileStoreScanTest is not stable >

[GitHub] [flink] ruanhang1993 opened a new pull request #18810: [FLINK-25289][hotfix] use the normal jar instead of a separate one

2022-02-16 Thread GitBox
ruanhang1993 opened a new pull request #18810: URL: https://github.com/apache/flink/pull/18810 ## What is the purpose of the change This pull request remove building a separate jar for the `flink-connector-test-utils` module. ## Brief change log - Remove building a

[jira] [Created] (FLINK-26206) refactor web ui's service layer and app config

2022-02-16 Thread Junhan Yang (Jira)
Junhan Yang created FLINK-26206: --- Summary: refactor web ui's service layer and app config Key: FLINK-26206 URL: https://issues.apache.org/jira/browse/FLINK-26206 Project: Flink Issue Type:

[jira] [Closed] (FLINK-26201) FileStoreScanTest is not stable

2022-02-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan closed FLINK-26201. - Resolution: Not A Bug The reason is due to the dependency of flink-avro is not updated. >

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * 90c1d1a155c2ebc29b92799b887b71e093a838bd Azure:

[jira] [Commented] (FLINK-26201) FileStoreScanTest is not stable

2022-02-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493678#comment-17493678 ] Jane Chan commented on FLINK-26201: --- The reason is due to the dependency of flink-avro is not being

[GitHub] [flink-ml] lindong28 merged pull request #58: [FLINK-26100][docs] Set up Flink ML Document Website

2022-02-16 Thread GitBox
lindong28 merged pull request #58: URL: https://github.com/apache/flink-ml/pull/58 -- 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-ml] lindong28 commented on pull request #58: [FLINK-26100][docs] Set up Flink ML Document Website

2022-02-16 Thread GitBox
lindong28 commented on pull request #58: URL: https://github.com/apache/flink-ml/pull/58#issuecomment-1042606550 Thanks for the PR. LGTM. -- 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 edited a comment on pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18799: URL: https://github.com/apache/flink/pull/18799#issuecomment-1041334465 ## CI report: * 73640cb14e6a68cacc27b281f8d5508a5ffa21ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18799: URL: https://github.com/apache/flink/pull/18799#issuecomment-1041334465 ## CI report: * 73640cb14e6a68cacc27b281f8d5508a5ffa21ea Azure:

[GitHub] [flink] liuyongvs commented on pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

2022-02-16 Thread GitBox
liuyongvs commented on pull request #18799: URL: https://github.com/apache/flink/pull/18799#issuecomment-1042601380 @flinkbot run azure re-run -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * Unknown: [CANCELED](TBD) * 90c1d1a155c2ebc29b92799b887b71e093a838bd Azure:

[jira] [Commented] (FLINK-26196) error when Incremental Checkpoints by RocksDb

2022-02-16 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493664#comment-17493664 ] Yue Ma commented on FLINK-26196: I think you might need to provide more information to figure out where

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * Unknown: [CANCELED](TBD) * 90c1d1a155c2ebc29b92799b887b71e093a838bd UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] deadwind4 commented on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
deadwind4 commented on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1042598533 @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

[GitHub] [flink] deadwind4 removed a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
deadwind4 removed a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1042493920 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 2830d54980890a81ca8ad4a3e3c27bebc6448bca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 2830d54980890a81ca8ad4a3e3c27bebc6448bca Azure:

[jira] [Closed] (FLINK-25876) Implement overwrite in FileStoreScanImpl

2022-02-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25876. Resolution: Fixed master: 44dfecd56695d9575e75b0b63a49aa8211ecde9f > Implement overwrite in

[jira] [Updated] (FLINK-25876) Implement overwrite in FileStoreScanImpl

2022-02-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25876: - Component/s: Table Store > Implement overwrite in FileStoreScanImpl >

[jira] [Updated] (FLINK-25876) Implement overwrite in FileStoreScanImpl

2022-02-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25876: - Fix Version/s: table-store-0.1.0 > Implement overwrite in FileStoreScanImpl >

[GitHub] [flink-table-store] JingsongLi merged pull request #16: [FLINK-25876] Implement overwrite in FlinkStoreCommitImpl

2022-02-16 Thread GitBox
JingsongLi merged pull request #16: URL: https://github.com/apache/flink-table-store/pull/16 -- 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] RocMarshal commented on a change in pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-16 Thread GitBox
RocMarshal commented on a change in pull request #18718: URL: https://github.com/apache/flink/pull/18718#discussion_r808681911 ## File path: docs/content.zh/docs/connectors/datastream/filesystem.md ## @@ -377,22 +378,23 @@ Flink comes with four built-in BulkWriter factories:

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * cf8a3915328570f8497893b3608900e46c85f69d Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #16: [FLINK-25876] Implement overwrite in FlinkStoreCommitImpl

2022-02-16 Thread GitBox
JingsongLi commented on a change in pull request #16: URL: https://github.com/apache/flink-table-store/pull/16#discussion_r808688217 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestCommittable.java ## @@ -27,26 +27,26 @@

[jira] [Closed] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator.

2022-02-16 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangMinChao closed FLINK-24855. --- Resolution: Feedback Received > Source Coordinator Thread already exists. There should never be

[jira] [Updated] (FLINK-26168) The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-26168: Component/s: Runtime / Coordination > The judgment of chainable ignores StreamExchangeMode when

[jira] [Commented] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator.

2022-02-16 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493653#comment-17493653 ] WangMinChao commented on FLINK-24855: - cdc issue trace:

[jira] [Closed] (FLINK-26168) The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-26168. --- Resolution: Done master/release-1.15: 8f3a0251d195ed2532abc31e602029dfcbf7bc77 > The judgment of chainable

[GitHub] [flink] zhuzhurk closed pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-16 Thread GitBox
zhuzhurk closed pull request #18789: URL: https://github.com/apache/flink/pull/18789 -- 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] zhuzhurk commented on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-16 Thread GitBox
zhuzhurk commented on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1042583153 The failed case is a known issue and unrelated. Merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] RocMarshal edited a comment on pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

2022-02-16 Thread GitBox
RocMarshal edited a comment on pull request #18480: URL: https://github.com/apache/flink/pull/18480#issuecomment-1037264660 @leonardBang @wuchong Could you help me to merge it if there's nothing Inappropriate? Thank you very much. -- This is an automated message from the Apache Git

[GitHub] [flink] wanglijie95 commented on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-16 Thread GitBox
wanglijie95 commented on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1042564457 The CI always fails due to FLINK-26199 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-25325) Migration Flink from Junit4 to Junit5

2022-02-16 Thread Aiden Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493633#comment-17493633 ] Aiden Gong commented on FLINK-25325: Hi,[~jingge] [~renqs] .We should confirm powermock working on

[jira] [Updated] (FLINK-26205) Support Online Model Save in FlinkML

2022-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26205: --- Labels: pull-request-available (was: ) > Support Online Model Save in FlinkML >

[GitHub] [flink-ml] weibozhao opened a new pull request #60: [FLINK-26205] Support Online Model Save in FlinkML

2022-02-16 Thread GitBox
weibozhao opened a new pull request #60: URL: https://github.com/apache/flink-ml/pull/60 ## What is the purpose of the change Support Online Model Save in FlinkML. ## Brief change log Add code of online model save. ## Does this pull request potentially affect one of the

[jira] [Created] (FLINK-26205) Support Online Model Save in FlinkML

2022-02-16 Thread weibo zhao (Jira)
weibo zhao created FLINK-26205: -- Summary: Support Online Model Save in FlinkML Key: FLINK-26205 URL: https://issues.apache.org/jira/browse/FLINK-26205 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD

2022-02-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493629#comment-17493629 ] Yang Wang commented on FLINK-26142: --- I am afraid we still need some discussions about how and when to

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-16 Thread GitBox
flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * ff43c28e2c5bd3a227eb6f826d7c1e5dea729479 Azure:

[jira] [Created] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is gre

2022-02-16 Thread Bo Huang (Jira)
Bo Huang created FLINK-26204: Summary: set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is greater than the value of the next step

[GitHub] [flink-ml] lindong28 commented on pull request #57: [FLINK-26100][docs] Set up Flink ML Document Website

2022-02-16 Thread GitBox
lindong28 commented on pull request #57: URL: https://github.com/apache/flink-ml/pull/57#issuecomment-1042536822 Here are some links that related to setting up the Flink ML website and determine its build health: - Wiki for setting up Flink nightly website

[GitHub] [flink-ml] lindong28 merged pull request #59: [hotfix] Fix version and branch info of docs in release 2.0

2022-02-16 Thread GitBox
lindong28 merged pull request #59: URL: https://github.com/apache/flink-ml/pull/59 -- 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] gaoyunhaii closed pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

2022-02-16 Thread GitBox
gaoyunhaii closed pull request #18797: URL: https://github.com/apache/flink/pull/18797 -- 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] gaoyunhaii commented on a change in pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

2022-02-16 Thread GitBox
gaoyunhaii commented on a change in pull request #18797: URL: https://github.com/apache/flink/pull/18797#discussion_r808637597 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -958,6 +958,73 @@ val sink = FileSink {{< /tab >}} {{< /tabs >}} +###

[jira] [Commented] (FLINK-24677) JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread

2022-02-16 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493622#comment-17493622 ] Caizhi Weng commented on FLINK-24677: - [~2011aad] thanks for your interest in contributing! Sure you

[jira] [Comment Edited] (FLINK-25409) Add cache metric to LookupFunction

2022-02-16 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493621#comment-17493621 ] Yuan Zhu edited comment on FLINK-25409 at 2/17/22, 3:08 AM: Hi, all. Sorry

  1   2   3   4   5   6   7   8   9   >