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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610805#comment-17610805
]
Yun Gao commented on FLINK-29348:
-
Merged on master via 7bae0ebb6379c175522bd903838bb3737fc6c65d
Merged
[
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
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)
>
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
[
https://issues.apache.org/jira/browse/FLINK-29463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610781#comment-17610781
]
Huang Xingbo commented on FLINK-29463:
--
cc [~renqs] [~smiralex]
>
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
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=17610779#comment-17610779
]
Yun Gao commented on FLINK-29339:
-
> The numbers are irrelevant though, as is the size of the response.
[
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)
>
[
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=17610777#comment-17610777
]
Weijie Guo commented on FLINK-29460:
[~hxbks2ks] Thanks for reporting this unstable test, I think
[
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
[
https://issues.apache.org/jira/browse/FLINK-29460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610770#comment-17610770
]
Huang Xingbo commented on FLINK-29460:
--
[~Weijie Guo] Could you help take a look? Thx.
>
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=17610767#comment-17610767
]
Huang Xingbo commented on FLINK-29427:
--
[
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=17610766#comment-17610766
]
Huang Xingbo commented on FLINK-24179:
--
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
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=17610763#comment-17610763
]
Huang Xingbo commented on FLINK-29387:
--
This is an unstable case, not sure if you have run it
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
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
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.
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
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
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
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
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=17610638#comment-17610638
]
Mason Chen commented on FLINK-28185:
cc: [~renqs] [~martijnvisser] would anyone have bandwidth to
[
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)
>
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
[
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
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
##
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
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610571#comment-17610571
]
Martijn Visser commented on FLINK-29458:
I believe this the same as
[
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
[
https://issues.apache.org/jira/browse/FLINK-29124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610570#comment-17610570
]
xiaochen zhou commented on FLINK-29124:
---
hi，I would like to deal with it. Can you assign this
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610567#comment-17610567
]
xiaochen zhou commented on FLINK-29176:
---
hi，I would like to deal with it. Can you assign this
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
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
[ 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
[
https://issues.apache.org/jira/browse/FLINK-29300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610565#comment-17610565
]
xiaochen zhou commented on FLINK-29300:
---
hi，I would like to deal with it. Can you assign this
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610563#comment-17610563
]
Jark Wu commented on FLINK-29458:
-
[~zmm_flink] I assigned this ticket to you. Feel free to open pull
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610561#comment-17610561
]
xiaochen zhou commented on FLINK-29368:
---
hi，I would like to deal with it. Can you assign this
[
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
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://issues.apache.org/jira/browse/FLINK-29432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610560#comment-17610560
]
xiaochen zhou commented on FLINK-29432:
---
hi，I would like to deal with it. Can you assign this
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
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:
*
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:
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
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
[
https://issues.apache.org/jira/browse/FLINK-27995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610527#comment-17610527
]
Martijn Visser commented on FLINK-27995:
[~lsy] No, but the upgrade work for Calcite has started
[
https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=17610521#comment-17610521
]
Chesnay Schepler commented on FLINK-29408:
--
If you change the {{test_pool_definition}} you run
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
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)
>
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610503#comment-17610503
]
chenyuzhi edited comment on FLINK-29387 at 9/28/22 11:22 AM:
-
I have re-run
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610503#comment-17610503
]
chenyuzhi commented on FLINK-29387:
---
I have return testIntervalJoinSideOutputLeftLateData() and
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
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:
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610481#comment-17610481
]
Qingsheng Ren commented on FLINK-29270:
---
I think this is because of the implementation of
[
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:
[
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
[
https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610476#comment-17610476
]
Jingsong Lee commented on FLINK-29345:
--
The orc writer has memory management and needs to be
[
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=17610474#comment-17610474
]
Qingsheng Ren commented on FLINK-29398:
---
[~jeremy.degroot] Thanks for the contribution! Feel free
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610472#comment-17610472
]
Qingsheng Ren commented on FLINK-29437:
---
[~martijnvisser] This feature was initially implemented
[
https://issues.apache.org/jira/browse/FLINK-25002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610471#comment-17610471
]
Chesnay Schepler commented on FLINK-25002:
--
Several projects have started to open/export
[
https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610470#comment-17610470
]
luoyuxia commented on FLINK-29408:
--
I try to debug the failure in this pr
dalongliu created FLINK-29451:
-
Summary: Push down group by partition column for Aggregate
(Min/Max/Count) for Parquet and Orc
Key: FLINK-29451
URL: https://issues.apache.org/jira/browse/FLINK-29451
1 - 100 of 267 matches
Mail list logo
