[
https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502546#comment-17502546
]
Martijn Visser commented on FLINK-25694:
Looking forward, I can help you wheneve
flinkbot edited a comment on pull request #18999:
URL: https://github.com/apache/flink/pull/18999#issuecomment-1060667154
## CI report:
* 3efe3aca7418b930005e826c31ce1d9f5b48cc5a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18998:
URL: https://github.com/apache/flink/pull/18998#issuecomment-1060662174
## CI report:
* 7492f053c89d952644294066b4b305a29d1a4b0d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #19001:
URL: https://github.com/apache/flink/pull/19001#issuecomment-1060869402
## CI report:
* 9e700e2c34b9aafc76f87799b6d1ee65fa5833f3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502536#comment-17502536
]
David Perkins commented on FLINK-25694:
---
Sure. It'll be my first commit to Flink.
flinkbot edited a comment on pull request #18979:
URL: https://github.com/apache/flink/pull/18979#issuecomment-1059179598
## CI report:
* 574fc91bc2ef7d5d57d557b25e81e5be6276b955 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18878:
URL: https://github.com/apache/flink/pull/18878#issuecomment-1047824955
## CI report:
* 71825e2b8a39f6fb41c9a4c891c7fa7e1909678a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502523#comment-17502523
]
Martijn Visser commented on FLINK-25694:
[~davidnperkins] Do you think you could
flinkbot edited a comment on pull request #18976:
URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391
## CI report:
* 293f37d1c954a8a5088f67b59245e3ffe5ebf2ed Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18976:
URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391
## CI report:
* 293f37d1c954a8a5088f67b59245e3ffe5ebf2ed Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502509#comment-17502509
]
David Perkins commented on FLINK-25694:
---
The presto library has been updated and r
flinkbot edited a comment on pull request #18976:
URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391
## CI report:
* 293f37d1c954a8a5088f67b59245e3ffe5ebf2ed Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* 7ae6c2649a2a7b3162b504f532ce540ace7595a3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18805:
URL: https://github.com/apache/flink/pull/18805#issuecomment-1041554745
## CI report:
* e0cc9d1d2036b964077a274f7425cab180404583 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18963:
URL: https://github.com/apache/flink/pull/18963#issuecomment-1057183349
## CI report:
* 2c4b296a1bb88c2fd33877a8c1ad3362af9d93ed Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18949:
URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167
## CI report:
* 1b79cb2b344c08ac1eccd13254e55c02f83064ad Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502478#comment-17502478
]
Martijn Visser edited comment on FLINK-26524 at 3/7/22, 6:15 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502478#comment-17502478
]
Martijn Visser commented on FLINK-26524:
[~mapohl] I don't really understand how
flinkbot edited a comment on pull request #19002:
URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183
## CI report:
* a7efad2153427eeb07dcdede96c89f6db1ec5b7f Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #19002:
URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183
## CI report:
* a7efad2153427eeb07dcdede96c89f6db1ec5b7f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-26462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502469#comment-17502469
]
Galen Warren commented on FLINK-26462:
--
I just ran through the testing steps and ev
[
https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26501:
---
Labels: pull-request-available test-stability (was: test-stability)
> Quickstarts Scala nig
akalash opened a new pull request #19002:
URL: https://github.com/apache/flink/pull/19002
## What is the purpose of the change
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (yes /
MartijnVisser merged pull request #19000:
URL: https://github.com/apache/flink/pull/19000
--
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-u
flinkbot edited a comment on pull request #19000:
URL: https://github.com/apache/flink/pull/19000#issuecomment-1060677163
## CI report:
* 385e222ba69232fdefb9b7d15a3672bf97f000ef Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-25143.
---
Resolution: Fixed
Merged into master as b7107efe9e9cda2bd8cf35e3c0ef645beb5a.
>
rkhachatryan commented on pull request #18224:
URL: https://github.com/apache/flink/pull/18224#issuecomment-1060928370
I've merged the PR, thanks a lot @masteryhx !
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
JingGe commented on a change in pull request #18838:
URL: https://github.com/apache/flink/pull/18838#discussion_r820924113
##
File path:
flink-connectors/flink-connector-pulsar/archunit-violations/stored.rules
##
@@ -0,0 +1,4 @@
+#
+#Thu Mar 03 12:42:13 CST 2022
+Tests\ inheri
rkhachatryan merged pull request #18224:
URL: https://github.com/apache/flink/pull/18224
--
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
[
https://issues.apache.org/jira/browse/FLINK-26525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-26525:
Description:
Rule 1: Concrete tests(not abstract) inheriting from SourceTestSuiteBase or
SinkTestSuiteBas
[
https://issues.apache.org/jira/browse/FLINK-26525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-26525:
Description:
Rule 1: Concrete tests(not abstract) inheriting from SourceTestSuiteBase or
SinkTestSuiteBas
Jing Ge created FLINK-26525:
---
Summary: new ArchUnit rules for SourceTestSuiteBase and
SinkTestSuiteBase
Key: FLINK-26525
URL: https://issues.apache.org/jira/browse/FLINK-26525
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-26525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-26525:
---
Assignee: Jing Ge
> new ArchUnit rules for SourceTestSuiteBase and SinkTestSuiteBase
>
rkhachatryan commented on pull request #18989:
URL: https://github.com/apache/flink/pull/18989#issuecomment-1060912214
The requirements for keyBy partitioning are a bit different: distribute keys
across groups as evenly as possible (and there are much more keys than key
groups).
For mat
[
https://issues.apache.org/jira/browse/FLINK-26468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502429#comment-17502429
]
Gabor Somogyi commented on FLINK-26468:
---
Now I've seen the mail and seems like the
smattheis commented on a change in pull request #18991:
URL: https://github.com/apache/flink/pull/18991#discussion_r820893233
##
File path: docs/content.zh/docs/ops/metrics.md
##
@@ -1428,6 +1428,16 @@ Note that the metrics are only available via reporters.
Maximum recor
flinkbot edited a comment on pull request #18224:
URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830
## CI report:
* 9a7b254785d11c4e50a937c3943b2e65e2ed3aa8 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502395#comment-17502395
]
Matthias Pohl commented on FLINK-24960:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26524:
--
Priority: Critical (was: Major)
> Elasticsearch (v5.3.3) sink end-to-end test
> -
[
https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26524:
--
Labels: test-stability (was: )
> Elasticsearch (v5.3.3) sink end-to-end test
> --
[
https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26524:
--
Fix Version/s: 1.15.0
> Elasticsearch (v5.3.3) sink end-to-end test
>
Matthias Pohl created FLINK-26524:
-
Summary: Elasticsearch (v5.3.3) sink end-to-end test
Key: FLINK-26524
URL: https://issues.apache.org/jira/browse/FLINK-26524
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #19001:
URL: https://github.com/apache/flink/pull/19001#issuecomment-1060869402
## CI report:
* 9e700e2c34b9aafc76f87799b6d1ee65fa5833f3 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18994:
URL: https://github.com/apache/flink/pull/18994#issuecomment-1060435366
## CI report:
* 36be61b629fd27f9d78425040f55c2eeeb94a833 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #19001:
URL: https://github.com/apache/flink/pull/19001#issuecomment-1060869402
## CI report:
* 9e700e2c34b9aafc76f87799b6d1ee65fa5833f3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov reassigned FLINK-26501:
-
Assignee: Anton Kalashnikov
> Quickstarts Scala nightly end-to-end test failed
[
https://issues.apache.org/jira/browse/FLINK-26520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26520:
---
Labels: pull-request-available (was: )
> Implement SEARCH operator
> --
slinkydeveloper opened a new pull request #19001:
URL: https://github.com/apache/flink/pull/19001
## What is the purpose of the change
This PR implements the `SEARCH` operator in the codegen, and removes the
scalar implementation of `IN` and `NOT_IN`. Now every scalar `IN`/`NOT_IN`
[
https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502383#comment-17502383
]
Matthias Pohl commented on FLINK-22040:
---
https://dev.azure.com/mapohl/flink/_build
[
https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-22040:
--
Priority: Blocker (was: Major)
> Maven: Entry has not been leased from this pool / fix for e2
pnowojski merged pull request #18984:
URL: https://github.com/apache/flink/pull/18984
--
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
[
https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502382#comment-17502382
]
Matthias Pohl commented on FLINK-22040:
---
I'm going to update the priority because
[
https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502382#comment-17502382
]
Matthias Pohl edited comment on FLINK-22040 at 3/7/22, 4:05 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-26523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-26523.
-
Resolution: Duplicate
> Flink : E2E Tests : Kinesis SQL tests
>
[
https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-22040:
--
Affects Version/s: 1.15.0
> Maven: Entry has not been leased from this pool / fix for e2e test
pnowojski commented on pull request #18989:
URL: https://github.com/apache/flink/pull/18989#issuecomment-1060843905
I believe that would contradict the idea of hashing or in other words, it
would mean somewhere bad hashing function has been used. I would be surprised
if the built in hash f
[
https://issues.apache.org/jira/browse/FLINK-26523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26523:
--
Labels: test-stability (was: )
> Flink : E2E Tests : Kinesis SQL tests
>
[
https://issues.apache.org/jira/browse/FLINK-26523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26523:
--
Fix Version/s: 1.15.0
> Flink : E2E Tests : Kinesis SQL tests
> --
Matthias Pohl created FLINK-26523:
-
Summary: Flink : E2E Tests : Kinesis SQL tests
Key: FLINK-26523
URL: https://issues.apache.org/jira/browse/FLINK-26523
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #18979:
URL: https://github.com/apache/flink/pull/18979#issuecomment-1059179598
## CI report:
* 07c30b4397a4242604b75f8ce9ab353c4672 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18996:
URL: https://github.com/apache/flink/pull/18996#issuecomment-1060587342
## CI report:
* 473e98ad1d65e474a9b1841931d71ced4d11e62a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18979:
URL: https://github.com/apache/flink/pull/18979#issuecomment-1059179598
## CI report:
* 07c30b4397a4242604b75f8ce9ab353c4672 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18878:
URL: https://github.com/apache/flink/pull/18878#issuecomment-1047824955
## CI report:
* d7329d746d05bc5ca97a612cb459f6e4204cc8ea Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-21321:
-
Fix Version/s: 1.16.0
(was: 1.15.0)
> Change RocksDB incremental checkpoint re-sc
[
https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502368#comment-17502368
]
Yuan Mei commented on FLINK-21321:
--
Since this ticket hasn't been worked on for several
[
https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-21321:
Assignee: yanfei lei
> Change RocksDB incremental checkpoint re-scaling to use deleteRange
>
echauchot commented on pull request #18610:
URL: https://github.com/apache/flink/pull/18610#issuecomment-1060821253
@XComp thanks for 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 th
flinkbot edited a comment on pull request #18999:
URL: https://github.com/apache/flink/pull/18999#issuecomment-1060667154
## CI report:
* 575bc529c5ec4ce86bad79193acef69398288c9d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18998:
URL: https://github.com/apache/flink/pull/18998#issuecomment-1060662174
## CI report:
* 5e93f2149ee5e620d33164b4b5ba031cfe2b7296 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18997:
URL: https://github.com/apache/flink/pull/18997#issuecomment-1060622309
## CI report:
* 0fb567c085303e835ef03851a241ecade6276837 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18987:
URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435
## CI report:
* 1ba1816cfb7266ee178e8bf815aa79daac42a026 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18976:
URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391
## CI report:
* c49435efc6af8ef87747f64c81008db72f91e748 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu
flinkbot edited a comment on pull request #18963:
URL: https://github.com/apache/flink/pull/18963#issuecomment-1057183349
## CI report:
* 5fba698adb6fbe58d8446281b3aa61825fce7e7a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
smattheis commented on pull request #18984:
URL: https://github.com/apache/flink/pull/18984#issuecomment-1060816754
> By locally I meant building the docs locally (described in the readme I
think: https://github.com/apache/flink/tree/master/docs ), just to be sure it's
working fine.
flinkbot edited a comment on pull request #18878:
URL: https://github.com/apache/flink/pull/18878#issuecomment-1047824955
## CI report:
* d7329d746d05bc5ca97a612cb459f6e4204cc8ea Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18949:
URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167
## CI report:
* 193175d59ea80d8652f28e15d6b89ee1888535ef Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* 0675e590348283e696d1352d588e3cadfddd421b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
smattheis commented on pull request #18984:
URL: https://github.com/apache/flink/pull/18984#issuecomment-1060810788
> By locally I meant building the docs locally (described in the readme I
think: https://github.com/apache/flink/tree/master/docs ), just to be sure it's
working fine.
rkhachatryan commented on pull request #18989:
URL: https://github.com/apache/flink/pull/18989#issuecomment-1060809002
I think with this approach only a small fraction of hash code will be used
(because of %) if the interval is small enough.
And depending on the hash function and task
[
https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502345#comment-17502345
]
Niklas Semmler commented on FLINK-26330:
Now I understand. This makes a lot of s
XComp edited a comment on pull request #18979:
URL: https://github.com/apache/flink/pull/18979#issuecomment-1060801170
@zentol I added the presto-specific filesystem and created bug reports in
TrinioDB and PrestoDB (see the PR description). I also added instruction on how
to run the `FileS
XComp commented on pull request #18979:
URL: https://github.com/apache/flink/pull/18979#issuecomment-1060801170
@zentol I added the presto-specific filesystem and created bug reports in
TrinioDB and PrestoDB (see the PR description). PTAL
--
This is an automated message from the Apache G
smattheis commented on a change in pull request #18991:
URL: https://github.com/apache/flink/pull/18991#discussion_r820800932
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java
##
@@ -175,6 +199,7 @@ public v
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niklas Semmler updated FLINK-26522:
---
Component/s: Runtime / Coordination
> Refactoring code for multiple component leader electio
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niklas Semmler updated FLINK-26522:
---
Affects Version/s: 1.16.0
> Refactoring code for multiple component leader election
> --
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niklas Semmler updated FLINK-26522:
---
Description:
The current implementation of the multiple component leader election faces a
n
smattheis commented on a change in pull request #18991:
URL: https://github.com/apache/flink/pull/18991#discussion_r820765598
##
File path: docs/content.zh/docs/ops/metrics.md
##
@@ -1428,6 +1428,16 @@ Note that the metrics are only available via reporters.
Maximum recor
smattheis commented on a change in pull request #18991:
URL: https://github.com/apache/flink/pull/18991#discussion_r820793763
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java
##
@@ -175,6 +199,7 @@ public v
Niklas Semmler created FLINK-26522:
--
Summary: Refactoring code for multiple component leader election
Key: FLINK-26522
URL: https://issues.apache.org/jira/browse/FLINK-26522
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niklas Semmler updated FLINK-26522:
---
Description:
The current implementation of the multiple component leader election faces a
n
pnowojski commented on pull request #18984:
URL: https://github.com/apache/flink/pull/18984#issuecomment-1060778366
By locally I meant building the docs locally (described in the readme I
think: https://github.com/apache/flink/tree/master/docs ), just to be sure it's
working fine.
--
Th
[
https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26517:
Affects Version/s: 1.15.0
> Normalize the decided parallelism to power of 2 when using adaptive batch
> s
pnowojski commented on a change in pull request #18989:
URL: https://github.com/apache/flink/pull/18989#discussion_r820784463
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@
[
https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-26517:
---
Assignee: Lijie Wang
> Normalize the decided parallelism to power of 2 when using adaptive batch
>
flinkbot edited a comment on pull request #18999:
URL: https://github.com/apache/flink/pull/18999#issuecomment-1060667154
## CI report:
* 575bc529c5ec4ce86bad79193acef69398288c9d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
pnowojski commented on a change in pull request #18989:
URL: https://github.com/apache/flink/pull/18989#discussion_r820659060
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@
smattheis commented on a change in pull request #18991:
URL: https://github.com/apache/flink/pull/18991#discussion_r820776221
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java
##
@@ -100,6 +104,10 @@ public TaskIOMetricGro
flinkbot edited a comment on pull request #18998:
URL: https://github.com/apache/flink/pull/18998#issuecomment-1060662174
## CI report:
* 5e93f2149ee5e620d33164b4b5ba031cfe2b7296 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
dawidwys merged pull request #18981:
URL: https://github.com/apache/flink/pull/18981
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502314#comment-17502314
]
Lijie Wang commented on FLINK-26330:
About 0.75~1.5:
For a simple example, we assume
201 - 300 of 582 matches
Mail list logo
