[GitHub] [flink] zentol commented on a change in pull request #16546: [FLINK-23438] Bump httpclient from 4.5.3 and 4.5.9 to 4.5.13

zentol commented on a change in pull request #16546: URL: https://github.com/apache/flink/pull/16546#discussion_r674543223 ## File path: flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE ## @@ -30,7 +30,7 @@ This project bundles the following dependencies

[GitHub] [flink-web] zentol merged pull request #458: Add flink-shaded 14.0

zentol merged pull request #458: URL: https://github.com/apache/flink-web/pull/458 -- 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

[jira] [Updated] (FLINK-23354) Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-23354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23354: - Summary: Limit the size of ShuffleDescriptors in PermanentBlobCache on TaskExecutor (was: Limit

[jira] [Commented] (FLINK-23440) The "State. Backend" of "Flink-CONF.YAML" is inconsistent with the documentation

[ https://issues.apache.org/jira/browse/FLINK-23440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385291#comment-17385291 ] Yun Tang commented on FLINK-23440: -- [~yang89520] would you like to take this ticket to

[GitHub] [flink] flinkbot commented on pull request #16562: [FLINK-23190] Improve slot-sharing allocation

flinkbot commented on pull request #16562: URL: https://github.com/apache/flink/pull/16562#issuecomment-884690191 ## CI report: * 9d2ac9f7f2a869d512e1ba2193c05459b5456fc4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16552: [FLINK-23449] [Deployment/YARN] YarnTaskExecutorRunner should contains MapReduce classes

flinkbot edited a comment on pull request #16552: URL: https://github.com/apache/flink/pull/16552#issuecomment-884119711 ## CI report: * 59856a6793c6b6956879899d2a61554dc7a3 UNKNOWN * 3f6d7224e9cb4d78e17354f0d6830286e5f1c069 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16482: [FLINK-23369][docs][connector-hive][connector-kafka] Improve config options by using enums

flinkbot edited a comment on pull request #16482: URL: https://github.com/apache/flink/pull/16482#issuecomment-879006434 ## CI report: * 38cf61cf882fe89ffe941fe36b6f9291c45b351a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-23464) Benchmarks aren't compiling

[ https://issues.apache.org/jira/browse/FLINK-23464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23464. Resolution: Fixed benchmark-master: a8f7c71ecb244ef6937deb10a2555637b14da3be > Benchmarks

[GitHub] [flink] flinkbot commented on pull request #16563: [FLINK-22540][sql-client] Remove Yaml environment file in SQL Client

flinkbot commented on pull request #16563: URL: https://github.com/apache/flink/pull/16563#issuecomment-884688215 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 pro

[GitHub] [flink] flinkbot commented on pull request #16564: [FLINK-23329][build] Bump flink-shaded to 14.0

flinkbot commented on pull request #16564: URL: https://github.com/apache/flink/pull/16564#issuecomment-884688202 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 pro

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

dmvk commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-884687496 Hi @yittg, LGTM from my side 👍 -- 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 s

[jira] [Commented] (FLINK-23465) JobListener#onJobExecuted cannot be called when sql job finished

[ https://issues.apache.org/jira/browse/FLINK-23465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385283#comment-17385283 ] camilesing commented on FLINK-23465: I can do it. if we need to fix it, please assig

[jira] [Created] (FLINK-23465) JobListener#onJobExecuted cannot be called when sql job finished

camilesing created FLINK-23465: -- Summary: JobListener#onJobExecuted cannot be called when sql job finished Key: FLINK-23465 URL: https://issues.apache.org/jira/browse/FLINK-23465 Project: Flink

[jira] [Updated] (FLINK-23329) Bump flink-shaded to 14.0

[ https://issues.apache.org/jira/browse/FLINK-23329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23329: --- Labels: pull-request-available (was: ) > Bump flink-shaded to 14.0 > --

[GitHub] [flink] zentol opened a new pull request #16564: [FLINK-23329][build] Bump flink-shaded to 14.0

zentol opened a new pull request #16564: URL: https://github.com/apache/flink/pull/16564 -- 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-un

[jira] [Issue Comment Deleted] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.

[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22860: Comment: was deleted (was: Hi, [~twalthr] Could you please help me to advance this PR ? Thank you.

[jira] [Comment Edited] (FLINK-23415) Shade kryo library to reduce class conflict

[ https://issues.apache.org/jira/browse/FLINK-23415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385281#comment-17385281 ] Chesnay Schepler edited comment on FLINK-23415 at 7/22/21, 6:27 AM: --

[jira] [Commented] (FLINK-23415) Shade kryo library to reduce class conflict

[ https://issues.apache.org/jira/browse/FLINK-23415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385281#comment-17385281 ] Chesnay Schepler commented on FLINK-23415: -- No. > Shade kryo library to reduce

[jira] [Updated] (FLINK-22540) Remove YAML environment file support in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22540: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Remove YAML environ

[GitHub] [flink] fsk119 opened a new pull request #16563: [FLINK-22540][sql-client] Remove Yaml environment file in SQL Client

fsk119 opened a new pull request #16563: URL: https://github.com/apache/flink/pull/16563 ## What is the purpose of the change *Remove the usage of the Yaml file in SQL Client. We have already removed the usage of the YAML in e2e before and replace with the sql file.*

[jira] [Created] (FLINK-23464) Benchmarks aren't compiling

Chesnay Schepler created FLINK-23464: Summary: Benchmarks aren't compiling Key: FLINK-23464 URL: https://issues.apache.org/jira/browse/FLINK-23464 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #16562: [FLINK-23190] Improve slot-sharing allocation

flinkbot commented on pull request #16562: URL: https://github.com/apache/flink/pull/16562#issuecomment-884679534 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 pro

[jira] [Updated] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23190: --- Labels: pull-request-available (was: ) > Make task-slot allocation much more evenly > -

[GitHub] [flink] saddays opened a new pull request #16562: [FLINK-23190] Improve slot-sharing allocation

saddays opened a new pull request #16562: URL: https://github.com/apache/flink/pull/16562 ## 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 d

[GitHub] [flink] RocMarshal commented on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

RocMarshal commented on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-884678080 @fsk119 Hi, Could you help me to review this PR? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Comment Edited] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

[ https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385255#comment-17385255 ] Jiayi Liao edited comment on FLINK-23208 at 7/22/21, 5:35 AM:

[jira] [Comment Edited] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385188#comment-17385188 ] Aitozi edited comment on FLINK-23031 at 7/22/21, 5:21 AM: -- Hi [

[jira] [Commented] (FLINK-23415) Shade kryo library to reduce class conflict

[ https://issues.apache.org/jira/browse/FLINK-23415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385259#comment-17385259 ] Aitozi commented on FLINK-23415: Hi [~chesnay] , do you have any suggestion on this ? >

[jira] [Commented] (FLINK-21080) Identify JobVertex containing legacy source operators and abort checkpoint with legacy source operators partially finished

[ https://issues.apache.org/jira/browse/FLINK-21080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385258#comment-17385258 ] Yun Gao commented on FLINK-21080: - Hi Piotr, sorry for the rush reply, and there seems s

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * ebec5a2750a5fd510b80ae80e7a9869133f7

[jira] [Commented] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

[ https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385255#comment-17385255 ] Jiayi Liao commented on FLINK-23208: [~pnowojski] Before the change, we need to fix

[GitHub] [flink] flinkbot edited a comment on pull request #16561: [FLINK-21926][doc] Add docs for fine-grained resource management

flinkbot edited a comment on pull request #16561: URL: https://github.com/apache/flink/pull/16561#issuecomment-884644259 ## CI report: * 8cd1586026e87b278a1f3ba8db0f6a9379c91ba0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

flinkbot edited a comment on pull request #16487: URL: https://github.com/apache/flink/pull/16487#issuecomment-879414939 ## CI report: * ca29a17be6b7442c76f8160c56f0696655d7aba2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16561: [FLINK-21926][doc] Add docs for fine-grained resource management

flinkbot commented on pull request #16561: URL: https://github.com/apache/flink/pull/16561#issuecomment-884644259 ## CI report: * 8cd1586026e87b278a1f3ba8db0f6a9379c91ba0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16560: [FLINK-23434][table-planner-blink] Fix the inconsistent type in IncrementalAggregateRule when the query has one distinct agg function

flinkbot edited a comment on pull request #16560: URL: https://github.com/apache/flink/pull/16560#issuecomment-884638414 ## CI report: * 5508bcd5f06a5904e7d7f4d262eafabdebbe5334 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16560: [FLINK-23434][table-planner-blink] Fix the inconsistent type in IncrementalAggregateRule when the query has one distinct agg function and co

flinkbot commented on pull request #16560: URL: https://github.com/apache/flink/pull/16560#issuecomment-884638414 ## CI report: * 5508bcd5f06a5904e7d7f4d262eafabdebbe5334 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16552: [FLINK-23449] [Deployment/YARN] YarnTaskExecutorRunner should contains MapReduce classes

flinkbot edited a comment on pull request #16552: URL: https://github.com/apache/flink/pull/16552#issuecomment-884119711 ## CI report: * 59856a6793c6b6956879899d2a61554dc7a3 UNKNOWN * b792aa069a887ccc35bfc7e46d3f4471d8ba2557 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #16561: [FLINK-21926][doc] Add docs for fine-grained resource management

flinkbot commented on pull request #16561: URL: https://github.com/apache/flink/pull/16561#issuecomment-884636035 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 pro

[GitHub] [flink] flinkbot commented on pull request #16560: [FLINK-23434][table-planner-blink] Fix the inconsistent type in IncrementalAggregateRule when the query has one distinct agg function and co

flinkbot commented on pull request #16560: URL: https://github.com/apache/flink/pull/16560#issuecomment-884635429 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 pro

[jira] [Commented] (FLINK-23218) Distribute the ShuffleDescriptors via blob server

[ https://issues.apache.org/jira/browse/FLINK-23218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385234#comment-17385234 ] Zhu Zhu commented on FLINK-23218: - Just summarize the investigation and discussion, a co

[jira] [Updated] (FLINK-21926) Document Fine Grained Resource Management

[ https://issues.apache.org/jira/browse/FLINK-21926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21926: --- Labels: pull-request-available (was: ) > Document Fine Grained Resource Management > --

[GitHub] [flink] KarmaGYZ opened a new pull request #16561: [FLINK-21926][doc] Add docs for fine-grained resource management

KarmaGYZ opened a new pull request #16561: URL: https://github.com/apache/flink/pull/16561 ## 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 o

[GitHub] [flink] godfreyhe opened a new pull request #16560: [FLINK-23434][table-planner-blink] Fix the inconsistent type in IncrementalAggregateRule when the query has one distinct agg function and c

godfreyhe opened a new pull request #16560: URL: https://github.com/apache/flink/pull/16560 ## What is the purpose of the change *Fix the inconsistent type in IncrementalAggregateRule when the query has one distinct agg function and count star agg function. See the JIRA description

[GitHub] [flink] flinkbot edited a comment on pull request #16552: [FLINK-23449] [Deployment/YARN] YarnTaskExecutorRunner should contains MapReduce classes

flinkbot edited a comment on pull request #16552: URL: https://github.com/apache/flink/pull/16552#issuecomment-884119711 ## CI report: * 59856a6793c6b6956879899d2a61554dc7a3 UNKNOWN * b792aa069a887ccc35bfc7e46d3f4471d8ba2557 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-23463) Replace the tag with ShortCodes in document

[ https://issues.apache.org/jira/browse/FLINK-23463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385224#comment-17385224 ] Yangze Guo commented on FLINK-23463: Can someone assign this to me? > Replace the

[jira] [Created] (FLINK-23463) Replace the tag with ShortCodes in document

Yangze Guo created FLINK-23463: -- Summary: Replace the tag with ShortCodes in document Key: FLINK-23463 URL: https://issues.apache.org/jira/browse/FLINK-23463 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-23446) Refactor SQL Client end to end tests

[ https://issues.apache.org/jira/browse/FLINK-23446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23446. --- Resolution: Fixed Fixed in master: 367131670b6566d130be57d587d9437c106f636f > Refactor SQL Client end to en

[jira] [Closed] (FLINK-23455) Remove the usage of the yaml file in SQLJobSubmission

[ https://issues.apache.org/jira/browse/FLINK-23455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23455. --- Resolution: Fixed Fixed in master: 073f9f3fe66c85b26339982e48ecebbfd938a195 > Remove the usage of the yaml

[GitHub] [flink] wuchong merged pull request #16549: [FLINK-23446][e2e] Refactor SQL Client end to end tests

wuchong merged pull request #16549: URL: https://github.com/apache/flink/pull/16549 -- 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-unsubsc

[GitHub] [flink] wuchong merged pull request #16555: [FLINK-23455][e2e] Remove the usage of the yaml file in SQLJobSubmission

wuchong merged pull request #16555: URL: https://github.com/apache/flink/pull/16555 -- 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-unsubsc

[jira] [Commented] (FLINK-23204) Provide StateBackends access to MailboxExecutor

[ https://issues.apache.org/jira/browse/FLINK-23204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385216#comment-17385216 ] Yuan Mei commented on FLINK-23204: -- merged commit  [{{6709573}}|https://github.com/apac

[jira] [Resolved] (FLINK-23204) Provide StateBackends access to MailboxExecutor

[ https://issues.apache.org/jira/browse/FLINK-23204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-23204. -- Resolution: Implemented > Provide StateBackends access to MailboxExecutor > --

[GitHub] [flink] curcur merged pull request #16531: [FLINK-23204] Provide StateBackends access to MailboxExecutor

curcur merged pull request #16531: URL: https://github.com/apache/flink/pull/16531 -- 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

[GitHub] [flink] godfreyhe closed pull request #16539: [FLINK-23434][table-planner] Fix the inconsistent type in IncrementalAggregateRule when the query has one distinct agg function and count star ag

godfreyhe closed pull request #16539: URL: https://github.com/apache/flink/pull/16539 -- 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-unsub

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * ebec5a2750a5fd510b80ae80e7a9869133f7

[jira] [Comment Edited] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385188#comment-17385188 ] Aitozi edited comment on FLINK-23031 at 7/22/21, 2:02 AM: -- Hi [

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385188#comment-17385188 ] Aitozi commented on FLINK-23031: Hi [~jark] , after some offline discussion with you. I

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385184#comment-17385184 ] Jianyun Zhao commented on FLINK-20726: -- [~arvid] Hello, what do you think about Pul

[GitHub] [flink] flinkbot edited a comment on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

flinkbot edited a comment on pull request #16487: URL: https://github.com/apache/flink/pull/16487#issuecomment-879414939 ## CI report: * 41dbd2a3cca01c087d0dbf9b7aa7fbe8ba7a95c3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * ebec5a2750a5fd510b80ae80e7a9869133f7

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

yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-884598878 Hi @dmvk @tillrohrmann , i resolved the conflict again, haha. Would you give it a final pass? :) -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

flinkbot edited a comment on pull request #16487: URL: https://github.com/apache/flink/pull/16487#issuecomment-879414939 ## CI report: * 41dbd2a3cca01c087d0dbf9b7aa7fbe8ba7a95c3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23401) Separate data and timer connection into different channels for Python DataStream API operators

[ https://issues.apache.org/jira/browse/FLINK-23401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23401: Summary: Separate data and timer connection into different channels for Python DataStream API operators (

[jira] [Closed] (FLINK-23401) Separate data and timer connection into different channel

[ https://issues.apache.org/jira/browse/FLINK-23401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23401. --- Resolution: Fixed Merged to master via 1a653c5acbe6ecd347ffbe3686eb324f88c0596a ~  a123091fcd0b83a7459c9677d

[jira] [Updated] (FLINK-23401) Separate data and timer connection into different channels for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-23401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23401: Summary: Separate data and timer connection into different channels for Python DataStream API (was: Separ

[GitHub] [flink] dianfu closed pull request #16541: [FLINK-23401][python] Separate data and timer processing into different channels

dianfu closed pull request #16541: URL: https://github.com/apache/flink/pull/16541 -- 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

[GitHub] [flink] edu05 commented on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

edu05 commented on pull request #16487: URL: https://github.com/apache/flink/pull/16487#issuecomment-884589737 Hi @dmvk I've addressed most of the comments, I'm just missing something to complete the new acceptance test. If you take a look at CheckpointStoreITCase you should see I've made

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * 7b469bc680f4b104a3673b2d146d706a602e12f9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21788: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * 7b469bc680f4b104a3673b2d146d706a602e12f9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] srinipunuru commented on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

srinipunuru commented on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884517489 @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 speci

[GitHub] [flink] flinkbot commented on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

flinkbot commented on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * 7b469bc680f4b104a3673b2d146d706a602e12f9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink

[ https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385113#comment-17385113 ] Srinivasulu Punuru commented on FLINK-18568: [~rmetzger] [~trohrmann] Sorry

[jira] [Commented] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385112#comment-17385112 ] Srinivasulu Punuru commented on FLINK-18562: [~rmetzger] [~trohrmann] I open

[jira] [Created] (FLINK-23462) Translate the abfs documentation to chinese

Srinivasulu Punuru created FLINK-23462: -- Summary: Translate the abfs documentation to chinese Key: FLINK-23462 URL: https://issues.apache.org/jira/browse/FLINK-23462 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

flinkbot commented on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884503664 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 pro

[jira] [Updated] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18562: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-depriori

[GitHub] [flink] srinipunuru opened a new pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

srinipunuru opened a new pull request #16559: URL: https://github.com/apache/flink/pull/16559 ## What is the purpose of the change This pull request adds support for abfs to talk to ADLS Gen2 (Azure DataLake Gen2) storage accounts. These are newer storage account types that h

[GitHub] [flink] flinkbot edited a comment on pull request #16556: [FLINK-23452][runtime] Added the throughput meter for measurement of …

flinkbot edited a comment on pull request #16556: URL: https://github.com/apache/flink/pull/16556#issuecomment-884238774 ## CI report: * 814871decf09be535af651215adb650f678b70e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16555: [FLINK-23455][e2e] Remove the usage of the yaml file in SQLJobSubmission

flinkbot edited a comment on pull request #16555: URL: https://github.com/apache/flink/pull/16555#issuecomment-884161346 ## CI report: * e0de15e9e8987fe696c4270c77d105899dbeff51 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16558: [FLINK-22893][zookeeper] Replace NodeCache with TreeCache

flinkbot edited a comment on pull request #16558: URL: https://github.com/apache/flink/pull/16558#issuecomment-884302981 ## CI report: * 0efb1b3af1dea94429b2c70ef10cb98469cdadea Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16557: [FLINK-23460] Add a global flag for enabling/disabling final checkpoints

flinkbot edited a comment on pull request #16557: URL: https://github.com/apache/flink/pull/16557#issuecomment-884284659 ## CI report: * cf0540f68005af3c58108f0248d38f6a457de1e6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16498: [WIP][FLINK-23354][blob] Limit the size of blob cache on TaskExecutor

flinkbot edited a comment on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880512519 ## CI report: * 911cd22a5de05ab8603c7f75fc58b22b96eef2fa Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16557: [FLINK-23460] Add a global flag for enabling/disabling final checkpoints

flinkbot edited a comment on pull request #16557: URL: https://github.com/apache/flink/pull/16557#issuecomment-884284659 ## CI report: * d580c4bef88339cbe31bbdab2abf60d8de8e65b8 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 909a6a116db1fd65e8a8332f5d0e095e42df342f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16556: [FLINK-23452][runtime] Added the throughput meter for measurement of …

flinkbot edited a comment on pull request #16556: URL: https://github.com/apache/flink/pull/16556#issuecomment-884238774 ## CI report: * a7ef9c2b42f44c4ab4c1ba034a7c7f90640eef58 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16556: [FLINK-23452][runtime] Added the throughput meter for measurement of …

flinkbot edited a comment on pull request #16556: URL: https://github.com/apache/flink/pull/16556#issuecomment-884238774 ## CI report: * a7ef9c2b42f44c4ab4c1ba034a7c7f90640eef58 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16555: [FLINK-23455][e2e] Remove the usage of the yaml file in SQLJobSubmission

flinkbot edited a comment on pull request #16555: URL: https://github.com/apache/flink/pull/16555#issuecomment-884161346 ## CI report: * e0de15e9e8987fe696c4270c77d105899dbeff51 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16557: [FLINK-23460] Add a global flag for enabling/disabling final checkpoints

flinkbot edited a comment on pull request #16557: URL: https://github.com/apache/flink/pull/16557#issuecomment-884284659 ## CI report: * d580c4bef88339cbe31bbdab2abf60d8de8e65b8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16555: [FLINK-23455][e2e] Remove the usage of the yaml file in SQLJobSubmission

flinkbot edited a comment on pull request #16555: URL: https://github.com/apache/flink/pull/16555#issuecomment-884161346 ## CI report: * e0de15e9e8987fe696c4270c77d105899dbeff51 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fsk119 commented on pull request #16555: [FLINK-23455][e2e] Remove the usage of the yaml file in SQLJobSubmission

fsk119 commented on pull request #16555: URL: https://github.com/apache/flink/pull/16555#issuecomment-884339738 Meet unstable test in FLINK-23239 and FLINK-22735 because of `HiveTableSinkITCase`. @flinkbot run azure -- This is an automated message from the Apache Git Service. To r

[GitHub] [flink] flinkbot edited a comment on pull request #16558: [FLINK-22893][zookeeper] Replace NodeCache with TreeCache

flinkbot edited a comment on pull request #16558: URL: https://github.com/apache/flink/pull/16558#issuecomment-884302981 ## CI report: * 0efb1b3af1dea94429b2c70ef10cb98469cdadea Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16557: [FLINK-23460] Add a global flag for enabling/disabling final checkpoints

flinkbot edited a comment on pull request #16557: URL: https://github.com/apache/flink/pull/16557#issuecomment-884284659 ## CI report: * d580c4bef88339cbe31bbdab2abf60d8de8e65b8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16556: [FLINK-23452][runtime] Added the throughput meter for measurement of …

flinkbot edited a comment on pull request #16556: URL: https://github.com/apache/flink/pull/16556#issuecomment-884238774 ## CI report: * a7ef9c2b42f44c4ab4c1ba034a7c7f90640eef58 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16498: [WIP][FLINK-23354][blob] Limit the size of blob cache on TaskExecutor

flinkbot edited a comment on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880512519 ## CI report: * 0be481b90be72b85b8a294d9e14d08cad49ee40d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23461) Consider disallowing in-memory state handles for materialized state

[ https://issues.apache.org/jira/browse/FLINK-23461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23461: -- Description: *For non-mateialized part*, FLINK-21353 doesn't use nor FsCheckpointStre

[jira] [Updated] (FLINK-23344) State ownership: track and discard private state (materialized: rocks, heap)

[ https://issues.apache.org/jira/browse/FLINK-23344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23344: -- Description: Inject TaskStateRegistry added in FLINK-23139 into existing state backend

[jira] [Updated] (FLINK-23137) State ownership: prevent private state deletion on JM

[ https://issues.apache.org/jira/browse/FLINK-23137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23137: -- Description: Inject shared state IDs computed in StateAssignmentOperation (FLINK-23342

[jira] [Created] (FLINK-23461) Consider disallowing in-memory state handles for materialized state

Roman Khachatryan created FLINK-23461: - Summary: Consider disallowing in-memory state handles for materialized state Key: FLINK-23461 URL: https://issues.apache.org/jira/browse/FLINK-23461 Project

[GitHub] [flink] MartijnVisser commented on pull request #16546: [FLINK-23438] Bump httpclient from 4.5.3 and 4.5.9 to 4.5.13

MartijnVisser commented on pull request #16546: URL: https://github.com/apache/flink/pull/16546#issuecomment-884307460 @zentol I'm testing the other review comments now, I'll get back to you when tests have completed -- This is an automated message from the Apache Git Service. To respond

  1   2   3   4   >