[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * e4f165728f6058ed0a6e1b910ed347e92f2747d9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31202) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner
flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 7a1f59c89cc282433be0c496e30275f004be7a89 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31151) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30475) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] adiaixin opened a new pull request #18719: [FLINK-22781][table-planner-blink] Fix bug that when implements the LookupFunction In SQL that indirect extends (Async)TableFunction, throw
adiaixin opened a new pull request #18719: URL: https://github.com/apache/flink/pull/18719 …ookupFunction In SQL that indirect extends (Async)TableFunction, throw exception ## What is the purpose of the change when implements the LookupFunction In SQL that indirect extends (Async)TableFunction, we extract the output type class use ExtractionUtils#extractSimpleGeneric, this method will return empty when dealing with indirect extended subclasses. We need to fix this bug. ## Brief change log - change method ExtractionUtils#extractSimpleGeneric, traverse all the super classes to the base class until find the generic parameter in pos has real class type. ## Verifying this change *(Please pick either of the following options)* This change added tests and can be verified as follows: - Added a unit Test which verified the static method result. （org.apache.flink.table.utils.ExtractionUtilsTest） ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): no - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: no - The serializers: no - The runtime per-record code paths (performance sensitive): no - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no - The S3 file system connector: no ## Documentation - Does this pull request introduce a new feature? no - If yes, how is the feature documented? no -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner
flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 7a1f59c89cc282433be0c496e30275f004be7a89 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31151) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * e4f165728f6058ed0a6e1b910ed347e92f2747d9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31202) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink-docker] autophagy opened a new pull request #103: [FLINK-24474] Bind Jobmanager/Taskmanager RPC endpoint addresses to 0.0.0.0 by default
autophagy opened a new pull request #103: URL: https://github.com/apache/flink-docker/pull/103 With FLINK-24474, we are going to bind the RPC endpoints to localhost by default as a security precaution. This PR adds to the dockerfile to update this default setting to bind to 0.0.0.0, so that Flink binds the RPC endpoints to a network interface within the container, so that it can communicate with the Docker network layer. This is done within the Dockerfile and not the docker-entrypoint.sh due to FLINK-21383. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 01046c38b403a797e9228a434d194144e6eed82b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31133) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30475) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Assigned] (FLINK-26038) Support delay message on PulsarSink
[ https://issues.apache.org/jira/browse/FLINK-26038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26038: -- Assignee: Yufan Sheng > Support delay message on PulsarSink > --- > > Key: FLINK-26038 > URL: https://issues.apache.org/jira/browse/FLINK-26038 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Pulsar >Reporter: Yufan Sheng >Assignee: Yufan Sheng >Priority: Major > > A delayed message is a type of message that would be sent to the consumer > after waiting for a fixed interval. We should support this feature in both > Pulsar sink API. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] MartijnVisser commented on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer
MartijnVisser commented on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1035955434 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] XComp commented on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner
XComp commented on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1035954454 -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 01046c38b403a797e9228a434d194144e6eed82b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31133) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] ruanhang1993 commented on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
ruanhang1993 commented on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1035954652 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] XComp edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner
XComp edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1035954454 Retriggering azureci after the e2e test issue was resolved -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit
flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5ce6dc78282c7c158ee9f06b6ddeddc1cf9a416b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31200) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] gaborgsomogyi commented on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager
gaborgsomogyi commented on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1035953090 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] gaborgsomogyi removed a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager
gaborgsomogyi removed a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1035515856 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode when recovering from non-changelog checkpoint
[ https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26079: -- Summary: Disallow combination of Changelog backend with CLAIM restore mode when recovering from non-changelog checkpoint (was: Disallow combination of Changelog backend with CLAIM restore mode ) > Disallow combination of Changelog backend with CLAIM restore mode when > recovering from non-changelog checkpoint > --- > > Key: FLINK-26079 > URL: https://issues.apache.org/jira/browse/FLINK-26079 > Project: Flink > Issue Type: Bug > Components: Runtime / Configuration, Runtime / State Backends >Reporter: Roman Khachatryan >Assignee: Roman Khachatryan >Priority: Blocker > Fix For: 1.15.0 > > > Extracted from FLINK-25872. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode
[ https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490719#comment-17490719 ] Roman Khachatryan commented on FLINK-26079: --- > Why do you want to disallow the combination? What is the problem? Because discarding an initial checkpoint will invalidate its "private" state which might be in use by future checkpoints. Normally, changelog backend wraps it and registers with tjhe SharedStateRegistry. But when recovering from non-changelog checkpoint, it is first added to the Checkpoint store, and wrapping in subsequent checkpoints doesn't help. (I mistakenly omitted "from non-changelog checkpoint" from the ticket title, sorry). > Does it mean LEGACY would be the only supported mode? Yes. > Disallow combination of Changelog backend with CLAIM restore mode > -- > > Key: FLINK-26079 > URL: https://issues.apache.org/jira/browse/FLINK-26079 > Project: Flink > Issue Type: Bug > Components: Runtime / Configuration, Runtime / State Backends >Reporter: Roman Khachatryan >Assignee: Roman Khachatryan >Priority: Blocker > Fix For: 1.15.0 > > > Extracted from FLINK-25872. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] dmvk commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration supplied
dmvk commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035950931 Also I would rather avoid switching the client implementations now, because that might require another investigation whether there is some kind of shared thread pool underneath (which might be a pattern in the SDK). Only think we have to do is to construct a separate ELG group (of reasonable size) for the test suite and for each writer. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 87199918ff2547e6002992804bf848e763fa9dd0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31210) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode
[
https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490716#comment-17490716
]
Dawid Wysakowicz commented on FLINK-26079:
--
Why do you want to disallow the combination? What is the problem? Does it mean
{{LEGACY}} would be the only supported mode?
> Disallow combination of Changelog backend with CLAIM restore mode
> --
>
> Key: FLINK-26079
> URL: https://issues.apache.org/jira/browse/FLINK-26079
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Configuration, Runtime / State Backends
>Reporter: Roman Khachatryan
>Assignee: Roman Khachatryan
>Priority: Blocker
> Fix For: 1.15.0
>
>
> Extracted from FLINK-25872.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-18356) Exit code 137 returned from process
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490714#comment-17490714
]
Piotr Nowojski commented on FLINK-18356:
Another two examples of "We stopped hearing from agent Azure " in one single
build:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31174=logs=ae4f8708-9994-57d3-c2d7-b892156e7812=af184cdd-c6d8-5084-0b69-7e9c67b35f7a
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31174=logs=bea52777-eaf8-5663-8482-18fbc3630e81
> Exit code 137 returned from process
> ---
>
> Key: FLINK-18356
> URL: https://issues.apache.org/jira/browse/FLINK-18356
> Project: Flink
> Issue Type: Bug
> Components: Build System / Azure Pipelines, Tests
>Affects Versions: 1.12.0, 1.13.0, 1.14.0, 1.15.0
>Reporter: Piotr Nowojski
>Assignee: Chesnay Schepler
>Priority: Blocker
> Labels: pull-request-available, test-stability
> Fix For: 1.15.0
>
> Attachments: 1234.jpg, app-profiling_4.gif
>
>
> {noformat}
> = test session starts
> ==
> platform linux -- Python 3.7.3, pytest-5.4.3, py-1.8.2, pluggy-0.13.1
> cachedir: .tox/py37-cython/.pytest_cache
> rootdir: /__w/3/s/flink-python
> collected 568 items
> pyflink/common/tests/test_configuration.py ..[
> 1%]
> pyflink/common/tests/test_execution_config.py ...[
> 5%]
> pyflink/dataset/tests/test_execution_environment.py .
> ##[error]Exit code 137 returned from process: file name '/bin/docker',
> arguments 'exec -i -u 1002
> 97fc4e22522d2ced1f4d23096b8929045d083dd0a99a4233a8b20d0489e9bddb
> /__a/externals/node/bin/node /__w/_temp/containerHandlerInvoker.js'.
> Finishing: Test - python
> {noformat}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3729=logs=9cada3cb-c1d3-5621-16da-0f718fb86602=8d78fe4f-d658-5c70-12f8-4921589024c3
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210
flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30986) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18558: [FLINK-25877][legal] Update the copyright year to 2022 in NOTICE files
flinkbot edited a comment on pull request #18558: URL: https://github.com/apache/flink/pull/18558#issuecomment-1024880730 ## CI report: * 258f9aaafa934ae9b25f2907e66e8c347cccf73e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30453) * 398f3168576138ac2610fc14606777a8b03d71a8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31215) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210
flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30986) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle
flinkbot edited a comment on pull request #18391: URL: https://github.com/apache/flink/pull/18391#issuecomment-1015282046 ## CI report: * 3ee629e61d2e0b52e5db2907bc4a8df5dcf263ec Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31206) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] MartijnVisser commented on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210
MartijnVisser commented on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1035940188 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18558: [FLINK-25877][legal] Update the copyright year to 2022 in NOTICE files
flinkbot edited a comment on pull request #18558: URL: https://github.com/apache/flink/pull/18558#issuecomment-1024880730 ## CI report: * 258f9aaafa934ae9b25f2907e66e8c347cccf73e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30453) * 398f3168576138ac2610fc14606777a8b03d71a8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18717: [hotfix][avro] Add comments to explain why projection pushdown works for avro bulk format
flinkbot edited a comment on pull request #18717: URL: https://github.com/apache/flink/pull/18717#issuecomment-1035885610 ## CI report: * 87ecb210b58085f19b34c734345eae63e779a610 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31208) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30475) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17943: [FLINK-24693][docs-zh] Translate "checkpoints" and "checkpointing" page to Chinese
flinkbot edited a comment on pull request #17943: URL: https://github.com/apache/flink/pull/17943#issuecomment-981516510 ## CI report: * b8d9c1bf1e3440aa330e006f53bee91bbd8489c0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31205) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Created] (FLINK-26084) Python tests exit with code 137
Yun Gao created FLINK-26084:
---
Summary: Python tests exit with code 137
Key: FLINK-26084
URL: https://issues.apache.org/jira/browse/FLINK-26084
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.13.5
Reporter: Yun Gao
{code:java}
Feb 11 02:34:00 pyflink/datastream/tests/test_check_point_config.py ...
[ 7%]
Feb 11 02:34:10 pyflink/datastream/tests/test_connectors.py ..
[ 11%]
Feb 11 02:34:56 pyflink/datastream/tests/test_data_stream.py
... [ 29%]
##[error]Exit code 137 returned from process: file name '/bin/docker',
arguments 'exec -i -u 1004 -w /home/agent03_azpcontainer
11ddaaf0f7ac9ef18618a18f4e8da30b2181bd8bd8e1d06ff78b4ffe52909319
/__a/externals/node/bin/node /__w/_temp/containerHandlerInvoker.js'.
Finishing: Test - python
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31189=logs=9cada3cb-c1d3-5621-16da-0f718fb86602=8d78fe4f-d658-5c70-12f8-4921589024c3=23704
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30475) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Created] (FLINK-26083) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed on azure due to table exists
Yun Gao created FLINK-26083:
---
Summary:
CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink
failed on azure due to table exists
Key: FLINK-26083
URL: https://issues.apache.org/jira/browse/FLINK-26083
Project: Flink
Issue Type: Bug
Components: Connectors / Cassandra
Affects Versions: 1.13.5
Reporter: Yun Gao
{code:java}
Feb 10 02:53:50 [ERROR] Tests run: 19, Failures: 0, Errors: 1, Skipped: 0, Time
elapsed: 229.573 s <<< FAILURE! - in
org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase
Feb 10 02:53:50 [ERROR]
testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink(org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase)
Time elapsed: 19.367 s <<< ERROR!
Feb 10 02:53:50 com.datastax.driver.core.exceptions.AlreadyExistsException:
Table flink.testpojonoannotatedkeyspace already exists
Feb 10 02:53:50 at
com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:111)
Feb 10 02:53:50 at
com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
Feb 10 02:53:50 at
com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
Feb 10 02:53:50 at
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:63)
Feb 10 02:53:50 at
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:39)
Feb 10 02:53:50 at
org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink(CassandraConnectorITCase.java:541)
Feb 10 02:53:50 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Feb 10 02:53:50 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Feb 10 02:53:50 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Feb 10 02:53:50 at java.lang.reflect.Method.invoke(Method.java:498)
Feb 10 02:53:50 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
Feb 10 02:53:50 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
Feb 10 02:53:50 at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
Feb 10 02:53:50 at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
Feb 10 02:53:50 at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
Feb 10 02:53:50 at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
Feb 10 02:53:50 at
org.apache.flink.testutils.junit.RetryRule$RetryOnExceptionStatement.evaluate(RetryRule.java:196)
Feb 10 02:53:50 at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
Feb 10 02:53:50 at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
Feb 10 02:53:50 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
Feb 10 02:53:50 at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
Feb 10 02:53:50 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
Feb 10 02:53:50 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
Feb 10 02:53:50 at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
Feb 10 02:53:50 at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
Feb 10 02:53:50 at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
Feb 10 02:53:50 at
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
Feb 10 02:53:50 at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
Feb 10 02:53:50 at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
Feb 10 02:53:50 at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
Feb 10 02:53:50 at
org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:30)
Feb 10 02:53:50 at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
Feb 10 02:53:50 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
Feb 10 02:53:50 at
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
Feb 10 02:53:50 at org.junit.runners.Suite.runChild(Suite.java:128)
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31070=logs=c91190b6-40ae-57b2-5999-31b869b0a7c1=43529380-51b4-5e90-5af4-2dccec0ef402=13603
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"
[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490701#comment-17490701 ] baisike commented on FLINK-25738: - [~MartijnVisser] I finish the translation sub-task 2 and commit a pr [#18718|https://github.com/apache/flink/pull/18718] , I am not sure who to review it ? can you give a help ? > Translate/fix translations for "FileSystem" connector page of "Connectors > > DataStream Connectors" > --- > > Key: FLINK-25738 > URL: https://issues.apache.org/jira/browse/FLINK-25738 > Project: Flink > Issue Type: Improvement > Components: Documentation >Reporter: Martijn Visser >Assignee: RocMarshal >Priority: Major > Labels: chinese-translation > > After the merge of https://github.com/apache/flink/pull/18288 to resolve > https://issues.apache.org/jira/browse/FLINK-20188 multiple pages needs to be > translated or changed documentation needs to be reviewed, translated and > corrected where possible. > It involves the following pages from the documentation: > * docs/content.zh/docs/connectors/datastream/filesystem.md (This has a > partial Chinese translation but since it was a complete overhaul, I've copied > the English text in) > * docs/content.zh/docs/connectors/datastream/formats/avro.md > * docs/content.zh/docs/connectors/datastream/formats/azure_table_storage.md > * docs/content.zh/docs/connectors/datastream/formats/hadoop.md > * docs/content.zh/docs/connectors/datastream/formats/mongodb.md > * docs/content.zh/docs/connectors/datastream/formats/overview.md > * docs/content.zh/docs/connectors/datastream/formats/parquet.md > * docs/content.zh/docs/connectors/datastream/formats/text_files.md > * docs/content.zh/docs/connectors/table/filesystem.md (This has a partial > Chinese translation but since it was a complete overhaul, I've copied the > English text in) > * docs/content.zh/docs/deployment/filesystems/s3.md (Just needs a check, it > should only be link updates) > * docs/content.zh/docs/dev/datastream/execution_mode.md (Just needs a check, > it should only be link updates) > * -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-26082) CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed
Yun Gao created FLINK-26082:
---
Summary: CancelPartitionRequestTest.testDuplicateCancel failed on
azure due to bind failed
Key: FLINK-26082
URL: https://issues.apache.org/jira/browse/FLINK-26082
Project: Flink
Issue Type: Bug
Components: Runtime / Network
Affects Versions: 1.13.5
Reporter: Yun Gao
{code:java}
Feb 10 01:56:01 [ERROR] Tests run: 2, Failures: 0, Errors: 1, Skipped: 0, Time
elapsed: 2.273 s <<< FAILURE! - in
org.apache.flink.runtime.io.network.netty.CancelPartitionRequestTest
Feb 10 01:56:01 [ERROR]
testDuplicateCancel(org.apache.flink.runtime.io.network.netty.CancelPartitionRequestTest)
Time elapsed: 1.877 s <<< ERROR!
Feb 10 01:56:01
org.apache.flink.shaded.netty4.io.netty.channel.unix.Errors$NativeIoException:
bind(..) failed: Address already in use
Feb 10 01:56:01
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31070=logs=f0ac5c25-1168-55a5-07ff-0e88223afed9=0dbaca5d-7c38-52e6-f4fe-2fb69ccb3ada=6768
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Closed] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation
[
https://issues.apache.org/jira/browse/FLINK-25830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-25830.
---
Fix Version/s: 1.15.0
Resolution: Fixed
> Typo mistake in "Metric Report page" of the documentation
> --
>
> Key: FLINK-25830
> URL: https://issues.apache.org/jira/browse/FLINK-25830
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: Chengkai Yang
>Assignee: Chengkai Yang
>Priority: Not a Priority
> Labels: auto-unassigned, pull-request-available
> Fix For: 1.15.0
>
>
> Hi, I think I find a typo mistake in the documentation:
> [This page:"Report
> page"|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#reporter]
> .
> In the YAML part:
> {code:java}
> ```yaml
> metrics.reporters: my_jmx_reporter,my_other_reporter
> metrics.reporter.my_jmx_reporter.factory.class:
> org.apache.flink.metrics.jmx.JMXReporterFactory
> metrics.reporter.my_jmx_reporter.port: 9020-9040
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> metrics.reporter.my_jmx_reporter.scope.variables.additional:
> cluster_name:my_test_cluster,tag_name:tag_value
> metrics.reporter.my_other_reporter.class:
> org.apache.flink.metrics.graphite.GraphiteReporter
> metrics.reporter.my_other_reporter.host: 192.168.1.1
> metrics.reporter.my_other_reporter.port: 1
> ```
> {code}
> This property:
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> If the user copies this property to the conf/flink-conf.yaml, the user will
> get a warning in the log like this:
> {code:java}
> // code placeholder
> 2022-01-26 22:45:31,642 WARN
> org.apache.flink.configuration.GlobalConfiguration [] - Error while
> trying to split key and value in configuration file
> /opt/module/flink-1.14.2/conf/flink-conf.yaml:277:
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num"
> {code}
> So there should have a space between
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:" and
> "job_id;task_attempt_num".
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18715: [FLINK-25046][runtime] Convert unspecified edge to rescale when using adapive batch scheduler
flinkbot edited a comment on pull request #18715: URL: https://github.com/apache/flink/pull/18715#issuecomment-1035853003 ## CI report: * 239445a06c2e280cc28753dfc7aa20a35e620758 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31204) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation
[
https://issues.apache.org/jira/browse/FLINK-25830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490700#comment-17490700
]
Yun Gao commented on FLINK-25830:
-
Merged on master via 0caed30f9aaa0ce9b1488000f843f9932c19ce5a
> Typo mistake in "Metric Report page" of the documentation
> --
>
> Key: FLINK-25830
> URL: https://issues.apache.org/jira/browse/FLINK-25830
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: Chengkai Yang
>Assignee: Chengkai Yang
>Priority: Not a Priority
> Labels: auto-unassigned, pull-request-available
>
> Hi, I think I find a typo mistake in the documentation:
> [This page:"Report
> page"|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#reporter]
> .
> In the YAML part:
> {code:java}
> ```yaml
> metrics.reporters: my_jmx_reporter,my_other_reporter
> metrics.reporter.my_jmx_reporter.factory.class:
> org.apache.flink.metrics.jmx.JMXReporterFactory
> metrics.reporter.my_jmx_reporter.port: 9020-9040
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> metrics.reporter.my_jmx_reporter.scope.variables.additional:
> cluster_name:my_test_cluster,tag_name:tag_value
> metrics.reporter.my_other_reporter.class:
> org.apache.flink.metrics.graphite.GraphiteReporter
> metrics.reporter.my_other_reporter.host: 192.168.1.1
> metrics.reporter.my_other_reporter.port: 1
> ```
> {code}
> This property:
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> If the user copies this property to the conf/flink-conf.yaml, the user will
> get a warning in the log like this:
> {code:java}
> // code placeholder
> 2022-01-26 22:45:31,642 WARN
> org.apache.flink.configuration.GlobalConfiguration [] - Error while
> trying to split key and value in configuration file
> /opt/module/flink-1.14.2/conf/flink-conf.yaml:277:
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num"
> {code}
> So there should have a space between
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:" and
> "job_id;task_attempt_num".
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] gaoyunhaii closed pull request #18713: [FLINK-25830][docs]Typo mistake in "Metric Report page" of the documentation
gaoyunhaii closed pull request #18713: URL: https://github.com/apache/flink/pull/18713 -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] SteNicholas edited a comment on pull request #18408: [FLINK-24865][CEP] Support MATCH_RECOGNIZE in Batch mode
SteNicholas edited a comment on pull request #18408: URL: https://github.com/apache/flink/pull/18408#issuecomment-1031313039 @twalthr @MartijnVisser, could anyone help to review this pull request? -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance
flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * a2bac72d420a2897ea8192fb3f7be684fb5048a6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31203) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Closed] (FLINK-25530) Support Pulsar source connector in Python DataStream API.
[ https://issues.apache.org/jira/browse/FLINK-25530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-25530. --- Fix Version/s: 1.15.0 Resolution: Fixed Merged to master via e44332c1b6ed5c2ce0ac0e04cd949b9bc8313fb3 > Support Pulsar source connector in Python DataStream API. > - > > Key: FLINK-25530 > URL: https://issues.apache.org/jira/browse/FLINK-25530 > Project: Flink > Issue Type: Sub-task > Components: API / Python, Connectors / Pulsar >Affects Versions: 1.14.2 >Reporter: Ada Wong >Assignee: Ada Wong >Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > Flink have supported Pulsar source connector. > https://issues.apache.org/jira/browse/FLINK-20726 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] dianfu merged pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.
dianfu merged pull request #18388: URL: https://github.com/apache/flink/pull/18388 -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance
flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * a2bac72d420a2897ea8192fb3f7be684fb5048a6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31203) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #16737: [hotfix][docs] update contents of sql create, and sql overview
flinkbot edited a comment on pull request #16737: URL: https://github.com/apache/flink/pull/16737#issuecomment-894157199 ## CI report: * 5bde9fa499110a2013309fb050fa795454e00f63 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21683) * 0ff55c17745afb476db588d2e55bebc28c2a82db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31213) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] wsry commented on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance
wsry commented on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1035920540 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #16737: [hotfix][docs] update contents of sql create, and sql overview
flinkbot edited a comment on pull request #16737: URL: https://github.com/apache/flink/pull/16737#issuecomment-894157199 ## CI report: * 5bde9fa499110a2013309fb050fa795454e00f63 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21683) * 0ff55c17745afb476db588d2e55bebc28c2a82db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink-benchmarks] wsry merged pull request #49: [FLINK-25959] Add micro-benchmarks for the sort-based blocking shuffle
wsry merged pull request #49: URL: https://github.com/apache/flink-benchmarks/pull/49 -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink-benchmarks] wsry commented on pull request #49: [FLINK-25959] Add micro-benchmarks for the sort-based blocking shuffle
wsry commented on pull request #49: URL: https://github.com/apache/flink-benchmarks/pull/49#issuecomment-1035918876 Merging. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit
flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5ce6dc78282c7c158ee9f06b6ddeddc1cf9a416b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31200) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance
flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * a2bac72d420a2897ea8192fb3f7be684fb5048a6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31203) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] tony810430 commented on pull request #16737: [hotfix][docs] update contents of sql create, and sql overview
tony810430 commented on pull request #16737: URL: https://github.com/apache/flink/pull/16737#issuecomment-1035917339 Hi @bowenli86, @wuchong could you help to review this PR, which adds the missing part for this docs PR https://github.com/apache/flink/pull/11871, when you are available. very appreciated it. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit
flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5ce6dc78282c7c158ee9f06b6ddeddc1cf9a416b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31200) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31212) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] godfreyhe commented on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit
godfreyhe commented on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1035913899 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * e4f165728f6058ed0a6e1b910ed347e92f2747d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31202) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17943: [FLINK-24693][docs-zh] Translate "checkpoints" and "checkpointing" page to Chinese
flinkbot edited a comment on pull request #17943: URL: https://github.com/apache/flink/pull/17943#issuecomment-981516510 ## CI report: * c66cf1d892a7da9e9f9e2d9c288399bbbdbe6e1a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31201) * b8d9c1bf1e3440aa330e006f53bee91bbd8489c0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31205) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] godfreyhe commented on a change in pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs
godfreyhe commented on a change in pull request #18363:
URL: https://github.com/apache/flink/pull/18363#discussion_r804331481
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java
##
@@ -98,7 +101,7 @@
import static org.apache.flink.util.Preconditions.checkState;
/** SQL CLI client. */
-public class CliClient implements AutoCloseable {
+public class CliClient implements AutoCloseable, SqlCommandParser {
Review comment:
Why CliClient needs extend from SqlCommandParser instead of holding a
parser variable?
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/delegation/ParserImplTest.java
##
@@ -121,6 +126,23 @@ public void testParseLegalStatements() {
}
}
+@Test
+public void testPartialParse() {
Review comment:
add a test for statement set
##
File path: docs/content.zh/docs/dev/table/sqlClient.md
##
@@ -459,7 +459,8 @@ of executing multiple queries.
Syntax
Review comment:
declare that `BEGIN STATEMENT SET` is deprecated.
##
File path: flink-table/flink-sql-client/src/test/resources/sql/set.q
##
@@ -48,6 +48,7 @@ set;
'pipeline.jars' = ''
'rest.port' = '$VAR_REST_PORT'
'table.exec.sink.legacy-cast-behaviour' = 'DISABLED'
+'table.optimizer.allow-partial-parse' = 'true'
Review comment:
ignore this config after it's a internal config
##
File path:
flink-table/flink-sql-client/src/test/resources/sql_multi/statement_set.q
##
@@ -0,0 +1,308 @@
+# table.q - EXECUTE/EXPLAIN STATEMENT SET BEGIN ... END
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to you under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# statement-set.q - BEGIN STATEMENT SET, END
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to you under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+SET 'sql-client.execution.result-mode' = 'tableau';
+!output
+[INFO] Session property has been set.
+!info
+
+SET 'table.dml-sync' = 'true';
+!output
+[INFO] Session property has been set.
+!info
+
+create table src (
+ id int,
+ str string
+) with (
+ 'connector' = 'values'
+);
+!output
+[INFO] Execute statement succeed.
+!info
+
+# ==
+# test statement set with streaming insert
+# ==
+
+SET 'execution.runtime-mode' = 'streaming';
+!output
+[INFO] Session property has been set.
+!info
+
+create table StreamingTable (
+ id int,
+ str string
+) with (
+ 'connector' = 'filesystem',
+ 'path' = '$VAR_STREAMING_PATH',
+ 'format' = 'csv'
+);
+!output
+[INFO] Execute statement succeed.
+!info
+
+create table StreamingTable2 (
+ id int,
+ str string
+) with (
+ 'connector' = 'filesystem',
+ 'path' = '$VAR_STREAMING_PATH2',
+ 'format' = 'csv'
+);
+!output
+[INFO] Execute statement succeed.
+!info
+
+EXPLAIN STATEMENT SET BEGIN
+INSERT INTO StreamingTable SELECT * FROM (VALUES (1, 'Hello World'), (2,
'Hi'), (2, 'Hi'), (3, 'Hello'), (3, 'World'), (4, 'ADD'), (5, 'LINE'));
+INSERT INTO StreamingTable SELECT * FROM (VALUES (1, 'Hello World'), (2,
'Hi'), (2, 'Hi'), (3, 'Hello'), (3, 'World'), (4, 'ADD'), (5, 'LINE'));
+END;
+!output
+== Abstract Syntax Tree ==
+LogicalSink(table=[default_catalog.default_database.StreamingTable],
fields=[EXPR$0, EXPR$1])
++- LogicalProject(EXPR$0=[$0], EXPR$1=[$1])
+ +- LogicalValues(tuples=[[{ 1, _UTF-16LE'Hello World' }, { 2, _UTF-16LE'Hi'
}, { 2, _UTF-16LE'Hi' }, { 3,
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] MrWhiteSike commented on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…
MrWhiteSike commented on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035909382 > 稍后和您联系！ OK！ -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Closed] (FLINK-24897) Make usrlib work for YARN application and per-job
[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-24897. - Resolution: Fixed > Make usrlib work for YARN application and per-job > - > > Key: FLINK-24897 > URL: https://issues.apache.org/jira/browse/FLINK-24897 > Project: Flink > Issue Type: Improvement > Components: Deployment / YARN >Reporter: Biao Geng >Assignee: Biao Geng >Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > Hi there, > I am working to utilize application mode to submit flink jobs to YARN cluster > but I find that currently there is no easy way to ship my user-defined > jars(e.g. some custom connectors or udf jars that would be shared by some > jobs) and ask the FlinkUserCodeClassLoader to load classes in these jars. > I checked some relevant jiras, like FLINK-21289. In k8s mode, there is a > solution that users can use `usrlib` directory to store their user-defined > jars and these jars would be loaded by FlinkUserCodeClassLoader when the job > is executed on JM/TM. > But on YARN mode, `usrlib` does not work as that: > In this method(org.apache.flink.yarn.YarnClusterDescriptor#addShipFiles), if > I want to use `yarn.ship-files` to ship `usrlib` from my flink client(in my > local machine) to remote cluster, I must not set UserJarInclusion to > DISABLED due to the checkArgument(). However, if I do not set that option to > DISABLED, the user jars to be shipped will be added into systemClassPaths. As > a result, classes in those user jars will be loaded by AppClassLoader. > But if I do not ship these jars, there is no convenient way to utilize these > jars in my flink run command. Currently, all I can do seems to use `-C` > option, which means I have to upload my jars to some shared store first and > then use these remote paths. It is not so perfect as we have already make it > possible to ship jars or files directly and we also introduce `usrlib` in > application mode on YARN. It would be more user-friendly if we can allow > shipping `usrlib` from local to remote cluster while using > FlinkUserCodeClassLoader to load classes in the jars in `usrlib`. > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-24897) Make usrlib work for YARN application and per-job
[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490683#comment-17490683 ] Yang Wang commented on FLINK-24897: --- Fixed via: master(release-1.15): 7df88e01fd547426dc8991d76557a4b7a53e37c6 > Make usrlib work for YARN application and per-job > - > > Key: FLINK-24897 > URL: https://issues.apache.org/jira/browse/FLINK-24897 > Project: Flink > Issue Type: Improvement > Components: Deployment / YARN >Reporter: Biao Geng >Assignee: Biao Geng >Priority: Major > Labels: pull-request-available > > Hi there, > I am working to utilize application mode to submit flink jobs to YARN cluster > but I find that currently there is no easy way to ship my user-defined > jars(e.g. some custom connectors or udf jars that would be shared by some > jobs) and ask the FlinkUserCodeClassLoader to load classes in these jars. > I checked some relevant jiras, like FLINK-21289. In k8s mode, there is a > solution that users can use `usrlib` directory to store their user-defined > jars and these jars would be loaded by FlinkUserCodeClassLoader when the job > is executed on JM/TM. > But on YARN mode, `usrlib` does not work as that: > In this method(org.apache.flink.yarn.YarnClusterDescriptor#addShipFiles), if > I want to use `yarn.ship-files` to ship `usrlib` from my flink client(in my > local machine) to remote cluster, I must not set UserJarInclusion to > DISABLED due to the checkArgument(). However, if I do not set that option to > DISABLED, the user jars to be shipped will be added into systemClassPaths. As > a result, classes in those user jars will be loaded by AppClassLoader. > But if I do not ship these jars, there is no convenient way to utilize these > jars in my flink run command. Currently, all I can do seems to use `-C` > option, which means I have to upload my jars to some shared store first and > then use these remote paths. It is not so perfect as we have already make it > possible to ship jars or files directly and we also introduce `usrlib` in > application mode on YARN. It would be more user-friendly if we can allow > shipping `usrlib` from local to remote cluster while using > FlinkUserCodeClassLoader to load classes in the jars in `usrlib`. > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-24897) Make usrlib work for YARN application and per-job
[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24897: -- Fix Version/s: 1.15.0 > Make usrlib work for YARN application and per-job > - > > Key: FLINK-24897 > URL: https://issues.apache.org/jira/browse/FLINK-24897 > Project: Flink > Issue Type: Improvement > Components: Deployment / YARN >Reporter: Biao Geng >Assignee: Biao Geng >Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > Hi there, > I am working to utilize application mode to submit flink jobs to YARN cluster > but I find that currently there is no easy way to ship my user-defined > jars(e.g. some custom connectors or udf jars that would be shared by some > jobs) and ask the FlinkUserCodeClassLoader to load classes in these jars. > I checked some relevant jiras, like FLINK-21289. In k8s mode, there is a > solution that users can use `usrlib` directory to store their user-defined > jars and these jars would be loaded by FlinkUserCodeClassLoader when the job > is executed on JM/TM. > But on YARN mode, `usrlib` does not work as that: > In this method(org.apache.flink.yarn.YarnClusterDescriptor#addShipFiles), if > I want to use `yarn.ship-files` to ship `usrlib` from my flink client(in my > local machine) to remote cluster, I must not set UserJarInclusion to > DISABLED due to the checkArgument(). However, if I do not set that option to > DISABLED, the user jars to be shipped will be added into systemClassPaths. As > a result, classes in those user jars will be loaded by AppClassLoader. > But if I do not ship these jars, there is no convenient way to utilize these > jars in my flink run command. Currently, all I can do seems to use `-C` > option, which means I have to upload my jars to some shared store first and > then use these remote paths. It is not so perfect as we have already make it > possible to ship jars or files directly and we also introduce `usrlib` in > application mode on YARN. It would be more user-friendly if we can allow > shipping `usrlib` from local to remote cluster while using > FlinkUserCodeClassLoader to load classes in the jars in `usrlib`. > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30475) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] wangyang0918 merged pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib
wangyang0918 merged pull request #18531: URL: https://github.com/apache/flink/pull/18531 -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] wangyang0918 commented on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib
wangyang0918 commented on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1035905689 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 use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30475) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] ruanhang1993 commented on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe
ruanhang1993 commented on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1035903673 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.
pltbkd commented on a change in pull request #18680:
URL: https://github.com/apache/flink/pull/18680#discussion_r804373669
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/FileCompactStrategy.java
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.connector.file.sink.compactor;
+
+import org.apache.flink.connector.file.sink.FileSink;
+
+import java.io.Serializable;
+
+import static org.apache.flink.util.Preconditions.checkArgument;
+
+/** Strategy for compacting the files written in {@link FileSink} before
committing. */
+public class FileCompactStrategy implements Serializable {
+
+private static final long serialVersionUID = 1L;
+
+// Compaction triggering strategies.
+private final long sizeThreshold;
+private final boolean compactOnCheckpoint;
+
+// Compaction executing strategies.
+private final int compactThread;
+
+private FileCompactStrategy(
+long sizeThreshold, boolean compactOnCheckpoint, int
compactThread) {
+this.sizeThreshold = sizeThreshold;
+this.compactOnCheckpoint = compactOnCheckpoint;
+this.compactThread = compactThread;
+}
+
+public long getSizeThreshold() {
+return sizeThreshold;
+}
+
+public boolean isCompactOnCheckpoint() {
Review comment:
I'd change the compactOnCheckpoint strategy to compactEveryNCheckpoints,
which is equals to compactOnCheckpoint when N=1, and <=0 to disable
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit
flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5ce6dc78282c7c158ee9f06b6ddeddc1cf9a416b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31200) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18675: [FLINK-25491][table-planner] Fix bug: generated code for a large IN filter can't be compiled
flinkbot edited a comment on pull request #18675: URL: https://github.com/apache/flink/pull/18675#issuecomment-1033442210 ## CI report: * 0321ee10998110bb32e81b3700f94337ae628fac Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31199) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 87199918ff2547e6002992804bf848e763fa9dd0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31210) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] adealjason commented on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…
adealjason commented on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035899345 稍后和您联系！ -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…
flinkbot commented on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898973 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 progress of the review. ## Automated Checks Last check on commit 87199918ff2547e6002992804bf848e763fa9dd0 (Fri Feb 11 05:40:15 UTC 2022) **Warnings:** * No documentation files were touched! Remember to keep the Flink docs up to date! Mention the bot in a comment to re-run the automated checks. ## Review Progress * ❓ 1. The [description] looks good. * ❓ 2. There is [consensus] that the contribution should go into to Flink. * ❓ 3. Needs [attention] from. * ❓ 4. The change fits into the overall [architecture]. * ❓ 5. Overall code [quality] is good. Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process. The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required Bot commands The @flinkbot bot supports the following commands: - `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`) - `@flinkbot approve all` to approve all aspects - `@flinkbot approve-until architecture` to approve everything until `architecture` - `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention - `@flinkbot disapprove architecture` to remove an approval you gave earlier -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…
flinkbot commented on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 87199918ff2547e6002992804bf848e763fa9dd0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-26081) Update document,becasue of add maven wrapper.
[ https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong updated FLINK-26081: --- Summary: Update document,becasue of add maven wrapper. (was: Update document,becasue of add maven wapper.) > Update document,becasue of add maven wrapper. > - > > Key: FLINK-26081 > URL: https://issues.apache.org/jira/browse/FLINK-26081 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.15.0 >Reporter: Aiden Gong >Priority: Minor > Fix For: 1.15.0 > > > Update document,becasue of add maven wapper. > Related files: README.md、project-configuration.md、building.md、ide_setup.md. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] MrWhiteSike opened a new pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…
MrWhiteSike opened a new pull request #18718: URL: https://github.com/apache/flink/pull/18718 …nese. ## 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 each deployment (during recovery).)* ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creation time as a persistent artifact* - *Deployments RPC transmits only the blob storage reference* - *TaskManagers retrieve the TaskInfo from the blob cache* ## Verifying this change Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing *(Please pick either of the following options)* This change is a trivial rework / code cleanup without any test coverage. *(or)* This change is already covered by existing tests, such as *(please describe tests)*. *(or)* This change added tests and can be verified as follows: *(example:)* - *Added integration tests for end-to-end deployment with large payloads (100MB)* - *Extended integration test for recovery after master (JobManager) failure* - *Added test that validates that TaskInfo is transferred only once across recoveries* - *Manually verified the change by running a 4 node cluser with 2 JobManagers and 4 TaskManagers, a stateful streaming program, and killing one JobManager and two TaskManagers during the execution, verifying that recovery happens correctly.* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes / no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / no) - The serializers: (yes / no / don't know) - The runtime per-record code paths (performance sensitive): (yes / no / don't know) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / no / don't know) - The S3 file system connector: (yes / no / don't know) ## Documentation - Does this pull request introduce a new feature? (yes / no) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] bgeng777 commented on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib
bgeng777 commented on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1035897139 Rerun the Flink CI in my own Azure pipeline and get a pass: https://dev.azure.com/samuelgeng7/Flink/_build/results?buildId=74=results -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18714: [hotfix][table][formats][doc] Updates to debezium, canal and maxwell format
flinkbot edited a comment on pull request #18714: URL: https://github.com/apache/flink/pull/18714#issuecomment-1035697460 ## CI report: * 1ca214c23e580641b541c56097dcef8d212542d8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31194) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17297: [FLINK-24307][docs] Some lines in Scala code example end with unneces…
flinkbot edited a comment on pull request #17297: URL: https://github.com/apache/flink/pull/17297#issuecomment-920679598 ## CI report: * 163dc3d32ef58011f4e22dcd0573f0761d940a0a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31197) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 009cec5cd2a715153bb37e126eb6890584487a57 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30945) * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 79448e696757de28ed19c3d6a6d7677b1dbdd75d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-26081) Update document,becasue of add maven wapper.
[ https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong updated FLINK-26081: --- Priority: Minor (was: Major) > Update document,becasue of add maven wapper. > > > Key: FLINK-26081 > URL: https://issues.apache.org/jira/browse/FLINK-26081 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.15.0 >Reporter: Aiden Gong >Priority: Minor > Fix For: 1.15.0 > > > Update document,becasue of add maven wapper. > Related files: README.md、project-configuration.md、building.md、ide_setup.md. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26081) Update document,becasue of add maven wapper.
[ https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490669#comment-17490669 ] Aiden Gong commented on FLINK-26081: Hi,[~trohrmann].I found some documents should be updated.Can you assign to me? Thank you! > Update document,becasue of add maven wapper. > > > Key: FLINK-26081 > URL: https://issues.apache.org/jira/browse/FLINK-26081 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.15.0 >Reporter: Aiden Gong >Priority: Major > Fix For: 1.15.0 > > > Update document,becasue of add maven wapper. > Related files: README.md、project-configuration.md、building.md、ide_setup.md. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] RocMarshal edited a comment on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.
RocMarshal edited a comment on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1024894312 Hi, @AHeise Would you mind helping me to check it ? Thanks a lot. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-26081) Update document,becasue of add maven wapper.
[ https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong updated FLINK-26081: --- Description: Update document,becasue of add maven wapper. Related files: README.md、project-configuration.md、building.md、ide_setup.md. was: Update document,becasue of add maven wapper. File List: README.md、project-configuration.md、building.md、ide_setup.md. > Update document,becasue of add maven wapper. > > > Key: FLINK-26081 > URL: https://issues.apache.org/jira/browse/FLINK-26081 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.15.0 >Reporter: Aiden Gong >Priority: Major > Fix For: 1.15.0 > > > Update document,becasue of add maven wapper. > Related files: README.md、project-configuration.md、building.md、ide_setup.md. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18668: [FLINK-25697][Runtime / Metrics] introduce port url config for prometheus push gateway a…
flinkbot edited a comment on pull request #18668: URL: https://github.com/apache/flink/pull/18668#issuecomment-1032923004 ## CI report: * 009cec5cd2a715153bb37e126eb6890584487a57 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30945) * 8dcc81aa3f858e7f2a983c4a3f8d18b36f780e02 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31209) * 7a6501cbbb0c7199c51ad198e96b2c2f7614efcb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
