flinkbot commented on PR #20920:
URL: https://github.com/apache/flink/pull/20920#issuecomment-1261806646
## CI report:
* 4c69f78d0646496c19c8e440ec1d8eea40a5a624 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20919:
URL: https://github.com/apache/flink/pull/20919#issuecomment-1261803345
## CI report:
* 13768998641e373b578b2ad46b3369f854432b8d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
SmirAlex opened a new pull request, #20920:
URL: https://github.com/apache/flink/pull/20920
## What is the purpose of the change
*Fix unstable test InputFormatCacheLoaderTest*
## Brief change log
- *Fixed unstable tests*
- *Fixed `InputFormatCacheLoader
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29405:
---
Labels: pull-request-available (was: )
> InputFormatCacheLoaderTest is unstable
> -
SmirAlex opened a new pull request, #20919:
URL: https://github.com/apache/flink/pull/20919
## What is the purpose of the change
*Fix unstable test InputFormatCacheLoaderTest*
## Brief change log
- *Fixed unstable tests*
- *Fixed `InputFormatCacheLoader
[
https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610805#comment-17610805
]
Yun Gao commented on FLINK-29348:
-
Merged on master via 7bae0ebb6379c175522bd903838bb373
[
https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-29348.
---
Resolution: Fixed
> The DPP(dynamic partition pruning) can not work with adaptive batch scheduler
>
gaoyunhaii closed pull request #20906: [FLINK-29348][table]
DynamicFilteringEvent can be stored in the CoordinatorStore if it's received
before the listener source coordinator is started.
URL: https://github.com/apache/flink/pull/20906
--
This is an automated message from the Apache Git Serv
flinkbot commented on PR #20918:
URL: https://github.com/apache/flink/pull/20918#issuecomment-1261731796
## CI report:
* e4a09747a93213c223c2fc1a8015bd15a9ba591f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29460:
---
Labels: pull-request-available test-stability (was: test-stability)
> HsResultPartitionTest
reswqa opened a new pull request, #20918:
URL: https://github.com/apache/flink/pull/20918
## What is the purpose of the change
*HsResultPartitionTest.testRelease failed with AssertionFailedError. This is
caused by FLINK-29425, it changes the conditions for spilling, which may cause
s
[
https://issues.apache.org/jira/browse/FLINK-29463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610781#comment-17610781
]
Huang Xingbo commented on FLINK-29463:
--
cc [~renqs] [~smiralex]
> InputFormatCache
Yun Gao created FLINK-29462:
---
Summary: LookupJoinITCase failed on azure due to classloader
leaking
Key: FLINK-29462
URL: https://issues.apache.org/jira/browse/FLINK-29462
Project: Flink
Issue Type
Huang Xingbo created FLINK-29463:
Summary: InputFormatCacheLoaderTest.checkCounter failed with
AssertionError
Key: FLINK-29463
URL: https://issues.apache.org/jira/browse/FLINK-29463
Project: Flink
Huang Xingbo created FLINK-29461:
Summary: ProcessDataStreamStreamingTests.test_process_function
unstable
Key: FLINK-29461
URL: https://issues.apache.org/jira/browse/FLINK-29461
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610779#comment-17610779
]
Yun Gao commented on FLINK-29339:
-
> The numbers are irrelevant though, as is the size o
[
https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-29339:
Fix Version/s: 1.17.0
1.16.1
(was: 1.16.0)
> JobMasterPartitionT
[
https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-29339:
Affects Version/s: 1.17.0
> JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager
>
[
https://issues.apache.org/jira/browse/FLINK-29460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610777#comment-17610777
]
Weijie Guo commented on FLINK-29460:
[~hxbks2ks] Thanks for reporting this unstable
[
https://issues.apache.org/jira/browse/FLINK-29460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-29460:
Assignee: Weijie Guo
> HsResultPartitionTest.testRelease failed with AssertionFailedError
[
https://issues.apache.org/jira/browse/FLINK-29460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610770#comment-17610770
]
Huang Xingbo commented on FLINK-29460:
--
[~Weijie Guo] Could you help take a look?
Huang Xingbo created FLINK-29460:
Summary: HsResultPartitionTest.testRelease failed with
AssertionFailedError
Key: FLINK-29460
URL: https://issues.apache.org/jira/browse/FLINK-29460
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610767#comment-17610767
]
Huang Xingbo commented on FLINK-29427:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29427:
-
Priority: Critical (was: Major)
> LookupJoinITCase failed with classloader problem
> --
[
https://issues.apache.org/jira/browse/FLINK-24179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610766#comment-17610766
]
Huang Xingbo commented on FLINK-24179:
--
https://dev.azure.com/apache-flink/apache-f
tisonkun commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1261652065
Upgrade to 2.27.1 and eliminate the workaround. Wait for the new CI report
and merge.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
chenyuzhi459 commented on PR #20782:
URL: https://github.com/apache/flink/pull/20782#issuecomment-1261650261
> The commit-msg needs to be changed to
>
>
[[FLINK-29195](https://issues.apache.org/jira/browse/FLINK-29195)][runtime/Checkpoint]
Expose lastCompletedCheckpointId metric
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610763#comment-17610763
]
Huang Xingbo commented on FLINK-29387:
--
This is an unstable case, not sure if you h
lindong28 commented on code in PR #158:
URL: https://github.com/apache/flink-ml/pull/158#discussion_r982987872
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VarianceThresholdSelectorTest.java:
##
@@ -0,0 +1,310 @@
+/*
+ * Licensed to the Apache Software Foundation (A
gaborgsomogyi commented on PR #20875:
URL: https://github.com/apache/flink/pull/20875#issuecomment-1261396893
If I understand it correctly then the proxy would add CORS, right? If we can
test it in a real environment then I'm fine w/ the actual code.
--
This is an automated message from t
zentol commented on PR #20914:
URL: https://github.com/apache/flink/pull/20914#issuecomment-1261293216
@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.
T
zentol commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1261243933
Sure, let's wait for the release.
--
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 specif
flinkbot commented on PR #20917:
URL: https://github.com/apache/flink/pull/20917#issuecomment-1261236774
## CI report:
* a50fddb254b7ca512798f9684848e700a1f132d0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuml07 commented on PR #20917:
URL: https://github.com/apache/flink/pull/20917#issuecomment-1261232665
CC @twalthr
--
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 unsu
liuml07 opened a new pull request, #20917:
URL: https://github.com/apache/flink/pull/20917
## What is the purpose of the change
Refine code examples in data_stream_api
## Brief change log
* Fix variable names to make code example cleaer
* Make it clear di
tisonkun commented on code in PR #20584:
URL: https://github.com/apache/flink/pull/20584#discussion_r982665349
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/FixedRangeGenerator.java:
##
@@ -18,23 +18,40 @
[
https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-29459:
---
Assignee: Yun Gao
> Sink v2 has bugs in supporting legacy v1 implementations with global committer
morhidi opened a new pull request, #388:
URL: https://github.com/apache/flink-kubernetes-operator/pull/388
## What is the purpose of the change
Currently it is not clear how one would associate completed manual
savepoints with savepointTriggerNonce-es when using the operator. This mak
mas-chen commented on PR #20215:
URL: https://github.com/apache/flink/pull/20215#issuecomment-1261134281
@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.
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610638#comment-17610638
]
Mason Chen commented on FLINK-28185:
cc: [~renqs] [~martijnvisser] would anyone have
[
https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29339:
-
Priority: Critical (was: Blocker)
> JobMasterPartitionTrackerImpl#requestShuffleDescrip
Yun Gao created FLINK-29459:
---
Summary: Sink v2 has bugs in supporting legacy v1 implementations
with global committer
Key: FLINK-29459
URL: https://issues.apache.org/jira/browse/FLINK-29459
Project: Flink
tisonkun commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1261033026
@zentol thanks for your reviewing.
I've submitted a patch to the upstream
https://github.com/diffplug/spotless/pull/1353.
Supposed 1) we're not in a hurry on this change 2)
[
https://issues.apache.org/jira/browse/FLINK-29446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29446:
---
Labels: pull-request-available (was: )
> Remove Calcite classes which were fixed in 1.24
>
snuyanzin commented on PR #20909:
URL: https://github.com/apache/flink/pull/20909#issuecomment-1260966039
@twalthr could you please have a look once you have time?
It looks like for some reason these classes were not removed during update
to 1.24+
--
This is an automated message from t
flinkbot commented on PR #20916:
URL: https://github.com/apache/flink/pull/20916#issuecomment-1260892974
## CI report:
* 9abb3f1aa01ae2990b8b56f34f7f25556dc41a3f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
morhidi opened a new pull request, #387:
URL: https://github.com/apache/flink-kubernetes-operator/pull/387
## What is the purpose of the change
Provide an option to retrieve credentials for local prometheus/grafana setup
## Brief change log
- Documentation updated
## Ver
XComp commented on code in PR #20805:
URL: https://github.com/apache/flink/pull/20805#discussion_r982266603
##
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnExceptionExtensionTest.java:
##
@@ -42,10 +51,10 @@ class RetryOnEx
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610571#comment-17610571
]
Martijn Visser commented on FLINK-29458:
I believe this the same as https://gith
[
https://issues.apache.org/jira/browse/FLINK-29452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29452:
--
Description: {{RetryOn*ExtensionTest}} does the evaluation of the tests
assuming that all test
[
https://issues.apache.org/jira/browse/FLINK-29124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610570#comment-17610570
]
xiaochen zhou commented on FLINK-29124:
---
hi,I would like to deal with it. Can you
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29458:
---
Fix Version/s: (was: 1.14.4)
> When two tables have the same field, do not specify the t
[
https://issues.apache.org/jira/browse/FLINK-29452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29452:
--
Summary: RetryOn*ExtensionTest is implemented in a way that doesn't allow
the successful execu
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610567#comment-17610567
]
xiaochen zhou commented on FLINK-29176:
---
hi,I would like to deal with it. Can you
syhily opened a new pull request, #20916:
URL: https://github.com/apache/flink/pull/20916
This is a backport PR for https://github.com/apache/flink/pull/20584.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
tisonkun commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1260883468
Pushed a workaround on the plugin configs. I'm submitting a patch for
upstream to avoid such a workaround.
--
This is an automated message from the Apache Git Service.
To respond to th
[ https://issues.apache.org/jira/browse/FLINK-29432 ]
xiaochen zhou deleted comment on FLINK-29432:
---
was (Author: zxcoccer):
hi,I would like to deal with it. Can you assign this ticket to me ?:)
> Replace GenericUDFNvl with GenericUDFCoalesce
[
https://issues.apache.org/jira/browse/FLINK-29300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610565#comment-17610565
]
xiaochen zhou commented on FLINK-29300:
---
hi,I would like to deal with it. Can you
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610563#comment-17610563
]
Jark Wu commented on FLINK-29458:
-
[~zmm_flink] I assigned this ticket to you. Feel free
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-29458:
---
Assignee: ZuoYan
> When two tables have the same field, do not specify the table name,Exception
>
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZuoYan updated FLINK-29458:
---
Attachment: image-2022-09-28-21-00-09-054.png
> When two tables have the same field, do not specify the tabl
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZuoYan updated FLINK-29458:
---
Attachment: image-2022-09-28-21-00-22-733.png
> When two tables have the same field, do not specify the tabl
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZuoYan updated FLINK-29458:
---
Description:
When two tables are join, the two tables have the same field. When querying
select, an excepti
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZuoYan updated FLINK-29458:
---
Description:
When two tables are join, the two tables have the same field. When querying
select, an excepti
[
https://issues.apache.org/jira/browse/FLINK-29368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610561#comment-17610561
]
xiaochen zhou commented on FLINK-29368:
---
hi,I would like to deal with it. Can you
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZuoYan updated FLINK-29458:
---
Attachment: image-2022-09-28-21-00-01-302.png
> When two tables have the same field, do not specify the tabl
ZuoYan created FLINK-29458:
--
Summary: When two tables have the same field, do not specify the
table name,Exception will be thrown:SqlValidatorException :Column 'currency' is
ambiguous
Key: FLINK-29458
URL: https://issue
[
https://issues.apache.org/jira/browse/FLINK-29432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610560#comment-17610560
]
xiaochen zhou commented on FLINK-29432:
---
hi,I would like to deal with it. Can you
flinkbot commented on PR #20915:
URL: https://github.com/apache/flink/pull/20915#issuecomment-1260866912
## CI report:
* 685bf72738af944382ba89aa0c1e63d5db1b502f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily opened a new pull request, #20915:
URL: https://github.com/apache/flink/pull/20915
This is a backport PR for https://github.com/apache/flink/pull/20584.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
tisonkun commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1260853095
It seems the version bump cause this configure not work, I will try to find
a reasonable followup:
```xml
tisonkun commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1260849504
@zentol with this change I tested JDK 17 can work with spotless:
```bash
gh pr checkout 20911
mvn -nsu spotless:apply
```
... while it generates diff on:
*
f
Chesnay Schepler created FLINK-29457:
Summary: Add a uid(hash) remapping function
Key: FLINK-29457
URL: https://issues.apache.org/jira/browse/FLINK-29457
Project: Flink
Issue Type: Sub-ta
Chesnay Schepler created FLINK-29456:
Summary: Add methods that acept OperatorIdentifier
Key: FLINK-29456
URL: https://issues.apache.org/jira/browse/FLINK-29456
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-29455:
Summary: Add OperatorIdentifier
Key: FLINK-29455
URL: https://issues.apache.org/jira/browse/FLINK-29455
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29453:
-
Description:
The state process API is currently limited to working with uids.
We should
[
https://issues.apache.org/jira/browse/FLINK-27995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610527#comment-17610527
]
Martijn Visser commented on FLINK-27995:
[~lsy] No, but the upgrade work for Cal
[
https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610521#comment-17610521
]
Chesnay Schepler edited comment on FLINK-29408 at 9/28/22 11:57 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610521#comment-17610521
]
Chesnay Schepler commented on FLINK-29408:
--
If you change the {{test_pool_defin
zentol commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1260792311
Could there be a bug in that spotless version that the skip parameter is
being ignored?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
flinkbot commented on PR #20914:
URL: https://github.com/apache/flink/pull/20914#issuecomment-1260791047
## CI report:
* b3800fdda11710910218031cfb15788f15936d59 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28453:
---
Labels: pull-request-available test-stability (was: test-stability)
> KafkaSourceLegacyITCa
zentol opened a new pull request, #20914:
URL: https://github.com/apache/flink/pull/20914
Deduplicate code to ease further changes down the line.
--
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 t
Chesnay Schepler created FLINK-29454:
Summary: Deduplicate code in SavepointReader
Key: FLINK-29454
URL: https://issues.apache.org/jira/browse/FLINK-29454
Project: Flink
Issue Type: Sub-t
Chesnay Schepler created FLINK-29453:
Summary: Add uidHash support to State Processor API
Key: FLINK-29453
URL: https://issues.apache.org/jira/browse/FLINK-29453
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610503#comment-17610503
]
chenyuzhi edited comment on FLINK-29387 at 9/28/22 11:22 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610503#comment-17610503
]
chenyuzhi commented on FLINK-29387:
---
I have return testIntervalJoinSideOutputLeftLateD
gyfora opened a new pull request, #573:
URL: https://github.com/apache/flink-web/pull/573
TODO: Release blogpost
--
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 unsubscr
Matthias Pohl created FLINK-29452:
-
Summary: RetryOnExceptionExtensionTest is implemented in a way
that doesn't allow the successful execution of individual tests
Key: FLINK-29452
URL: https://issues.apache.org/ji
chenyuzhi459 commented on PR #20782:
URL: https://github.com/apache/flink/pull/20782#issuecomment-1260717847
@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 comme
[
https://issues.apache.org/jira/browse/FLINK-29270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-29270.
-
Resolution: Won't Fix
> Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_
[
https://issues.apache.org/jira/browse/FLINK-29270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610481#comment-17610481
]
Qingsheng Ren commented on FLINK-29270:
---
I think this is because of the implementa
[
https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29345.
Resolution: Invalid
revert in:
master: 696d65c387b708228c99bef6914a8859c301d6e8
release-0.2: 2cdd
[
https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reopened FLINK-29345:
--
> Too many open files in table store orc writer
> -
>
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-29437:
Description:
I notice that the key group range in consumer side of Kafka Shuffle is not
aligned w
[
https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610476#comment-17610476
]
Jingsong Lee commented on FLINK-29345:
--
The orc writer has memory management and ne
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-29398:
-
Assignee: Jeremy DeGroot
> Utilize Rack Awareness in Flink Consumer
> -
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610474#comment-17610474
]
Qingsheng Ren commented on FLINK-29398:
---
[~jeremy.degroot] Thanks for the contribu
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610472#comment-17610472
]
Qingsheng Ren commented on FLINK-29437:
---
[~martijnvisser] This feature was initial
[
https://issues.apache.org/jira/browse/FLINK-25002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610471#comment-17610471
]
Chesnay Schepler commented on FLINK-25002:
--
Several projects have started to op
1 - 100 of 254 matches
Mail list logo