[
https://issues.apache.org/jira/browse/FLINK-30616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
songv updated FLINK-30616:
--
Description:
I have a non-partition topic:
* the producer for the topic sends batch messages to the
[
https://issues.apache.org/jira/browse/FLINK-30616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
songv updated FLINK-30616:
--
Description:
I have a non-partition topic:
* the producer for the topic sends batch messages to the
songv created FLINK-30616:
-
Summary: Don't support batchMessageId when restore from checkpoint
Key: FLINK-30616
URL: https://issues.apache.org/jira/browse/FLINK-30616
Project: Flink
Issue Type: Bug
gaborgsomogyi commented on PR #599:
URL: https://github.com/apache/flink-web/pull/599#issuecomment-1376848906
Looks good, except the jira list which is somehow collapsed.
[
https://issues.apache.org/jira/browse/FLINK-30191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656477#comment-17656477
]
Yunfeng Zhou commented on FLINK-30191:
--
Hi [~martijnvisser], would you mind my asking about the
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656476#comment-17656476
]
Matthias Pohl commented on FLINK-30257:
---
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656474#comment-17656474
]
Matthias Pohl commented on FLINK-30257:
---
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656473#comment-17656473
]
Matthias Pohl commented on FLINK-30257:
---
tsreaper merged PR #473:
URL: https://github.com/apache/flink-table-store/pull/473
--
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:
maosuhan commented on PR #21613:
URL: https://github.com/apache/flink/pull/21613#issuecomment-1376836273
@laughingman7743 It looks all right now. @libenchao Do you have time to take
another look at this?
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
guoxin updated FLINK-30612:
---
Description:
data clutter in multi-threaded environment.
by design?
or , how do i use it in multi-thread
reswqa commented on code in PR #21634:
URL: https://github.com/apache/flink/pull/21634#discussion_r1065374786
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/failover/RestartTasksInBatchJobBenchmarkTest.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-30006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-30006:
---
Assignee: lincoln lee
> Cannot remove columns that are incorrectly considered constants
[
https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
guoxin updated FLINK-30612:
---
Priority: Blocker (was: Major)
> ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1065381018
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,620 @@
+/*
+ *
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1065379525
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,620 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He closed FLINK-30586.
--
Resolution: Fixed
Fixed in 1.17.0: 68b37fb867374df5a201f0b170e35c21266e5d7b
> Fix calcCodeGen failed
[
https://issues.apache.org/jira/browse/FLINK-30586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He reassigned FLINK-30586:
--
Assignee: Yunhong Zheng
> Fix calcCodeGen failed if calc with like condition contains double
godfreyhe closed pull request #21609: [FLINK-30586][table-runtime] Fix
calcCodeGen failed if calc with 'like' condition contains double quotation mark
URL: https://github.com/apache/flink/pull/21609
--
This is an automated message from the Apache Git Service.
To respond to the message,
chrismartin823 commented on PR #21625:
URL: https://github.com/apache/flink/pull/21625#issuecomment-1376787085
@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
flinkbot commented on PR #21635:
URL: https://github.com/apache/flink/pull/21635#issuecomment-1376775464
## CI report:
* 8f03e78346937fd7085d0d03b59610a14cd8180f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29769:
---
Affects Version/s: (was: 1.17.0)
> Further limit the explosion range of failover in hybrid
masteryhx opened a new pull request, #21635:
URL: https://github.com/apache/flink/pull/21635
## What is the purpose of the change
This pr reverses the direction of resolving schema compatibility could
improve the usability of schema evolution.
See FLIP-263 for more details.
[
https://issues.apache.org/jira/browse/FLINK-29597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29597:
-
Affects Version/s: (was: ml-2.2.0)
> Add Estimator and Transformer for QuantileDiscretizer
>
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1065350761
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,620 @@
+/*
+ *
laughingman7743 commented on PR #21613:
URL: https://github.com/apache/flink/pull/21613#issuecomment-1376760012
Currently all tests pass. (Maybe there is a flaky test in the e2e test).
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=44585=results
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656423#comment-17656423
]
Dong Lin commented on FLINK-29595:
--
ChiSqSelector has been be implemented as part of the
[
https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656423#comment-17656423
]
Dong Lin edited comment on FLINK-29595 at 1/10/23 5:23 AM:
---
ChiSqSelector has
[
https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-29595:
Assignee: Jiang Xin
> Add Estimator and Transformer for ChiSqSelector
>
[
https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29595.
Release Note: This is duplicate of FLINK-29601
Resolution: Duplicate
> Add Estimator and
[
https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27715:
-
Fix Version/s: ml-2.2.0
> Add more Python ML examples
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-29824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29824:
-
Fix Version/s: ml-2.2.0
> AgglomerativeClustering fails when the distanceThreshold is very large
>
[
https://issues.apache.org/jira/browse/FLINK-29824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29824:
-
Affects Version/s: (was: ml-2.2.0)
> AgglomerativeClustering fails when the distanceThreshold is
[
https://issues.apache.org/jira/browse/FLINK-30144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30144:
-
Fix Version/s: ml-2.2.0
> Guarantee Flink ML operators function correctly with object-reuse enabled
>
[
https://issues.apache.org/jira/browse/FLINK-29843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29843:
-
Fix Version/s: ml-2.2.0
> Euclidean Distance Measure generates NAN distance values
>
[
https://issues.apache.org/jira/browse/FLINK-30144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30144:
-
Affects Version/s: (was: ml-2.1.0)
> Guarantee Flink ML operators function correctly with
[
https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30603:
---
Labels: pull-request-available (was: )
> CompactActionITCase in table store is unstable
>
tsreaper opened a new pull request, #473:
URL: https://github.com/apache/flink-table-store/pull/473
In `CompactActionITCase#testStreamingCompact`, parallelism of compact job
may be larger than 1, so there is a small possibility that different writers
will perform full compaction in
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656417#comment-17656417
]
Huang Xingbo commented on FLINK-26974:
--
I'm very sorry, due to several other unexpected things in
[
https://issues.apache.org/jira/browse/FLINK-26265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-26265.
Resolution: Fixed
> Support Java algorithm in Python ML API
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27716:
-
Parent: (was: FLINK-26265)
Issue Type: Improvement (was: Sub-task)
> Add Python API docs
[
https://issues.apache.org/jira/browse/FLINK-25148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-25148.
Resolution: Cannot Reproduce
> PipelinedSubpartition.resumeConsumption throws IllegalStateException
>
[
https://issues.apache.org/jira/browse/FLINK-30241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-30241.
Resolution: Cannot Reproduce
> Flink ML Iteration ConcurrentModificationException
>
[
https://issues.apache.org/jira/browse/FLINK-29763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29763.
Resolution: Cannot Reproduce
> TaskManager heatbeat timeout exception in Github CI for python tests
>
[
https://issues.apache.org/jira/browse/FLINK-29597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29597:
-
Fix Version/s: (was: ml-2.2.0)
> Add Estimator and Transformer for QuantileDiscretizer
>
[
https://issues.apache.org/jira/browse/FLINK-29600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29600:
-
Fix Version/s: (was: ml-2.2.0)
> Add Estimator and Transformer for BucketedRandomProjectionLSH
>
[
https://issues.apache.org/jira/browse/FLINK-29596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29596:
-
Fix Version/s: (was: ml-2.2.0)
> Add Estimator and Transformer for RFormula
>
[
https://issues.apache.org/jira/browse/FLINK-30615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-30615:
Description:
# Get rid of Managed Table
# Split kafka log test into a new test class.
> Refactor
ramkrish86 commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-137671
> That is to say, with what we currently have, there's no need to update the
FTS documentation. And if we want to support FTS + ABFS + Spark/Hive/Trino, we
would need to open another
Hangxiang Yu created FLINK-30614:
Summary: Improve resolving schema compatibility -- Milestone two
Key: FLINK-30614
URL: https://issues.apache.org/jira/browse/FLINK-30614
Project: Flink
yuzelin created FLINK-30615:
---
Summary: Refactor ReadWriteTableITCase to get rid of Managed Table
Key: FLINK-30615
URL: https://issues.apache.org/jira/browse/FLINK-30615
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-29174:
Assignee: Zhipeng Zhang
> Add document for ML algorithms
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-29174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29174.
Fix Version/s: (was: ml-2.2.0)
Resolution: Fixed
> Add document for ML algorithms
>
[
https://issues.apache.org/jira/browse/FLINK-29170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-29170:
Assignee: Jiang Xin (was: Zhipeng Zhang)
> Add Transformer and Estimator for
[
https://issues.apache.org/jira/browse/FLINK-27327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-27327.
--
Fix Version/s: 1.16.1
1.15.4
Resolution: Fixed
Merged
master:
[
https://issues.apache.org/jira/browse/FLINK-29170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29170.
Release Note: This is duplicate of
https://issues.apache.org/jira/browse/FLINK-29409
Resolution:
[
https://issues.apache.org/jira/browse/FLINK-29169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29169.
Release Note: This is duplicate of FLINK-29601
Resolution: Fixed
> Add Transformer and Estimator
Hangxiang Yu created FLINK-30613:
Summary: Improve resolving schema compatibility -- Milestone one
Key: FLINK-30613
URL: https://issues.apache.org/jira/browse/FLINK-30613
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reopened FLINK-29169:
--
> Add Transformer and Estimator for UnivariateFeatureSelector
>
[
https://issues.apache.org/jira/browse/FLINK-29169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-29169:
Assignee: Jiang Xin (was: Zhipeng Zhang)
> Add Transformer and Estimator for
[
https://issues.apache.org/jira/browse/FLINK-29169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29169.
Resolution: Duplicate
> Add Transformer and Estimator for UnivariateFeatureSelector
>
Myasuka merged PR #19599:
URL: https://github.com/apache/flink/pull/19599
--
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:
[
https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27716:
-
Fix Version/s: ml-2.2.0
> Add Python API docs in ML
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-30481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30481:
---
Labels: pull-request-available (was: )
> create base aws-glue catalog implementation in
boring-cyborg[bot] commented on PR #43:
URL:
https://github.com/apache/flink-connector-aws/pull/43#issuecomment-1376709501
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-28761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-28761.
Release Note: We decided that Flink ML stages do not need to support
unaligned checkpoint and rescaling
Myasuka commented on PR #18523:
URL: https://github.com/apache/flink/pull/18523#issuecomment-1376708958
@zlzhang0122 could you please update this PR to rebase with latest code?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-30122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-30122.
Resolution: Fixed
> Flink ML KMeans getting model data throws TypeError
>
[
https://issues.apache.org/jira/browse/FLINK-30122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30122:
-
Fix Version/s: ml-2.2.0
> Flink ML KMeans getting model data throws TypeError
>
[
https://issues.apache.org/jira/browse/FLINK-30401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-30401:
Assignee: Fan Hong
> Add Estimator and Transformer for MinHashLSH
>
[
https://issues.apache.org/jira/browse/FLINK-29599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29599.
Release Note: Duplicate of FLINK-30401
Resolution: Duplicate
> Add Estimator and Transformer for
lsyldliu commented on PR #21629:
URL: https://github.com/apache/flink/pull/21629#issuecomment-1376707230
@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-30401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30401:
-
Fix Version/s: ml-2.2.0
> Add Estimator and Transformer for MinHashLSH
>
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1065316262
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,620 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-30099.
Resolution: Fixed
> Add tests to cover model data APIs for all existing algorithms
>
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1065315619
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,620 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-30014.
Resolution: Fixed
> Fix the NPE from aggregate util
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-30014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-30014:
Assignee: Jiang Xin
> Fix the NPE from aggregate util
> ---
>
>
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1065314128
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,620 @@
+/*
+ *
swuferhong commented on code in PR #21530:
URL: https://github.com/apache/flink/pull/21530#discussion_r1065313823
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java:
##
@@ -0,0 +1,620 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-30536.
Resolution: Fixed
> Remove CountingOutput from per-record code path for most operators
>
[
https://issues.apache.org/jira/browse/FLINK-28082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-28082.
-
Fix Version/s: pulsar-4.0.0
(was: 1.17.0)
Resolution: Fixed
master via
tisonkun merged PR #13:
URL: https://github.com/apache/flink-connector-pulsar/pull/13
--
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:
tisonkun commented on PR #13:
URL:
https://github.com/apache/flink-connector-pulsar/pull/13#issuecomment-1376697697
Merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
tisonkun commented on PR #15:
URL:
https://github.com/apache/flink-connector-pulsar/pull/15#issuecomment-1376697559
```
Error:
src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java:[46]
(imports) ImportOrder: Import
syhily commented on PR #15:
URL:
https://github.com/apache/flink-connector-pulsar/pull/15#issuecomment-1376694084
> To keep the user experience consistent, is it possible to make
singleFetchTime optional and only into use if configured?
Yep.
--
This is an automated message from
lincoln-lil merged PR #600:
URL: https://github.com/apache/flink-web/pull/600
--
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:
lincoln-lil commented on PR #600:
URL: https://github.com/apache/flink-web/pull/600#issuecomment-1376692262
@fsk119 thanks for reviewing this!
--
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
[
https://issues.apache.org/jira/browse/FLINK-30542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30542:
---
Labels: pull-request-available (was: )
> Support adaptive local hash aggregate in runtime
lsyldliu commented on code in PR #21586:
URL: https://github.com/apache/flink/pull/21586#discussion_r1065306202
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala:
##
@@ -202,11 +299,43 @@ class
SinBex commented on PR #21634:
URL: https://github.com/apache/flink/pull/21634#issuecomment-1376685536
@zhuzhurk @reswqa Could you please help me to review this pr?
and I'm not sure if it is appropriate for the case with hybrid type edges.
Looking forward to your suggestions, thanks
[
https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
guoxin updated FLINK-30612:
---
Description:
data clutter in multi-threaded environment.
by design? or , how do i use it in multi-thread
[
https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
guoxin updated FLINK-30612:
---
Description:
data clutter in multi-threaded environment.
by design?
or , how do i use it in multi-thread
guoxin created FLINK-30612:
--
Summary: ObjectArrayConverter is not thread-safe，raised by
reuseArray、reuseWriter
Key: FLINK-30612
URL: https://issues.apache.org/jira/browse/FLINK-30612
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-30611:
-
Component/s: Table Store
> Expire snapshot should be reentrant
>
Jingsong Lee created FLINK-30611:
Summary: Expire snapshot should be reentrant
Key: FLINK-30611
URL: https://issues.apache.org/jira/browse/FLINK-30611
Project: Flink
Issue Type: Bug
syhily commented on code in PR #13:
URL:
https://github.com/apache/flink-connector-pulsar/pull/13#discussion_r1065298845
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto/PulsarCrypto.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the
xintongsong commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1376671834
> @xintongsong - Also want to know about this
https://nightlies.apache.org/flink/flink-table-store-docs-master/docs/filesystems/overview/.
Now since ABFS support is available in
tisonkun commented on code in PR #13:
URL:
https://github.com/apache/flink-connector-pulsar/pull/13#discussion_r1065294112
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto/PulsarCrypto.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the
Jingsong Lee created FLINK-30610:
Summary: Flink-table-runtime free for disk io in flink-core
Key: FLINK-30610
URL: https://issues.apache.org/jira/browse/FLINK-30610
Project: Flink
Issue
1 - 100 of 279 matches
Mail list logo
