[
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 topic(to
[
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 topic(to
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&focusedCommentId=17656477#comment-17656477
]
Yunfeng Zhou commented on FLINK-30191:
--
Hi [~martijnvisser], would you mind my aski
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656476#comment-17656476
]
Matthias Pohl commented on FLINK-30257:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656474#comment-17656474
]
Matthias Pohl commented on FLINK-30257:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656473#comment-17656473
]
Matthias Pohl commented on FLINK-30257:
---
https://dev.azure.com/apache-flink/apache
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: issues-unsubscr...@fl
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 me
[
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 e
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 th
[
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 fro
[
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 @@
+/*
+ * Licen
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 @@
+/*
+ * Licen
[
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, please
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 com
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 shuff
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 @@
+/*
+ * Licen
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&view=results
--
This is
[
https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656423#comment-17656423
]
Dong Lin commented on FLINK-29595:
--
ChiSqSelector has been be implemented as part of th
[
https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656423#comment-17656423
]
Dong Lin edited comment on FLINK-29595 at 1/10/23 5:23 AM:
---
Ch
[
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 Transformer
[
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 ver
[
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 object-reu
[
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 differen
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656417#comment-17656417
]
Huang Xingbo commented on FLINK-26974:
--
I'm very sorry, due to several other unexpe
[
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 in
[
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 ReadWri
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 P
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
Issue
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: S
[
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 VarianceThresholdSe
[
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: 19f4239ab34a23
[
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: Dup
[
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 for
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
Issue
[
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 UnivariateFeatureSe
[
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: issues-unsubscr...@flink.apach
[
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
> -
>
> Key:
[
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 fli
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 fo
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 a
[
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 Min
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 @@
+/*
+ * Licen
[
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 @@
+/*
+ * Licen
[
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 @@
+/*
+ * Licen
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 @@
+/*
+ * Licen
[
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 htt
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: issues-unsubscr...
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 commen
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
org.apache.flink.connector.pulsa
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 th
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: issues-unsubscr...@flink.a
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 HashAggCo
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 a
[
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 en
[
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 e
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 Apache
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 FileS
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 Apac
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 Type
1 - 100 of 279 matches
Mail list logo
