wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062196039
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java:
##
@@ -150,6 +193,202 @@ private int
wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062195484
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java:
##
@@ -150,6 +193,202 @@ private int
wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062195219
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java:
##
@@ -77,46 +92,74 @@ private
wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062194655
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java:
##
@@ -55,7 +70,7 @@ public class
wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062194496
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java:
##
@@ -19,15 +19,30 @@
package
wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062193741
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/VertexParallelismDecider.java:
##
@@ -18,19 +18,27 @@
package
wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062193326
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AbstractBlockingResultInfo.java:
##
@@ -43,12 +43,21 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-30561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654843#comment-17654843
]
Feifan Wang commented on FLINK-30561:
-
Hi [~masteryhx] , FLINK-30107 and FLINK-28898 are caused by
wanglijie95 commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1062192798
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertexInputInfo.java:
##
@@ -68,4 +68,9 @@ public boolean equals(Object obj) {
[
https://issues.apache.org/jira/browse/FLINK-30568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30568:
---
Labels: pull-request-available (was: )
> Add benchmark for PolyNomialExpansion,
weibozhao opened a new pull request, #198:
URL: https://github.com/apache/flink-ml/pull/198
## What is the purpose of the change
Add benchmark configurations for some of the existing algorithms.
## Brief change log
Add benchmark configurations of PolyNomialExpansion,
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654837#comment-17654837
]
Matthias Pohl edited comment on FLINK-29427 at 1/5/23 7:41 AM:
---
Same
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654837#comment-17654837
]
Matthias Pohl commented on FLINK-29427:
---
[
https://issues.apache.org/jira/browse/FLINK-28881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654836#comment-17654836
]
Matthias Pohl commented on FLINK-28881:
---
[
https://issues.apache.org/jira/browse/FLINK-28881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-28881:
--
Affects Version/s: gcp-pubsub-3.0.0
>
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654835#comment-17654835
]
Matthias Pohl edited comment on FLINK-29859 at 1/5/23 7:38 AM:
---
I'm
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-29859:
---
I'm reopening this issue because the error reappeared even though it contained
the fix of
weibozhao commented on PR #189:
URL: https://github.com/apache/flink-ml/pull/189#issuecomment-1371875726
>
OK
--
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
[
https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654827#comment-17654827
]
Matthias Pohl edited comment on FLINK-25500 at 1/5/23 7:36 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654827#comment-17654827
]
Matthias Pohl edited comment on FLINK-25500 at 1/5/23 7:35 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-30516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-30516:
Description: Add files table in Table Store and user can query row count
from `mytable$files` (was: Add
weibozhao commented on code in PR #189:
URL: https://github.com/apache/flink-ml/pull/189#discussion_r1062181069
##
docs/content/docs/operators/feature/randomsplitter.md:
##
@@ -31,9 +31,10 @@ An AlgoOperator which splits a table into N tables according
to the given weight
[
https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654827#comment-17654827
]
Matthias Pohl edited comment on FLINK-25500 at 1/5/23 7:34 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-25500:
--
Affects Version/s: 1.16.0
>
[
https://issues.apache.org/jira/browse/FLINK-30516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-30516:
Summary: Support files table in table store (was: Add file count and row
count in snapshots table)
>
[
https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-25500:
--
Priority: Major (was: Minor)
>
[
https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654827#comment-17654827
]
Matthias Pohl commented on FLINK-25500:
---
zhipeng93 commented on PR #189:
URL: https://github.com/apache/flink-ml/pull/189#issuecomment-1371872841
@weibozhao Thanks for the update :) Can you also update the PR title as well
as the commit message to make it more informative? (e.g., `Add HasSeed param
for RandomSplitter`)
--
This
zhipeng93 commented on code in PR #189:
URL: https://github.com/apache/flink-ml/pull/189#discussion_r1062179082
##
docs/content/docs/operators/feature/randomsplitter.md:
##
@@ -31,9 +31,10 @@ An AlgoOperator which splits a table into N tables according
to the given weight
zhipeng93 commented on code in PR #189:
URL: https://github.com/apache/flink-ml/pull/189#discussion_r1062179082
##
docs/content/docs/operators/feature/randomsplitter.md:
##
@@ -31,9 +31,10 @@ An AlgoOperator which splits a table into N tables according
to the given weight
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654822#comment-17654822
]
Tomoyuki NAKAMURA commented on FLINK-30093:
---
I have investigated the Flink 1.16 implementation
lindong28 commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r1062178236
##
flink-ml-benchmark/src/main/resources/robustscaler-benchmark.json:
##
@@ -0,0 +1,42 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+//
zhipeng93 commented on PR #189:
URL: https://github.com/apache/flink-ml/pull/189#issuecomment-1371870055
Thanks for the PR. LGTM.
--
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-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-30533.
Resolution: Fixed
> SourceOperator#emitNext() should push records to DataOutput in a while loop
>
[
https://issues.apache.org/jira/browse/FLINK-30507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30507:
--
Labels: test-stability (was: )
>
lindong28 commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r1062172506
##
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java:
##
@@ -54,6 +60,44 @@ public void testParseJsonFile() throws Exception {
jiangxin369 commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r1062172361
##
flink-ml-benchmark/src/main/resources/robustscaler-benchmark.json:
##
@@ -0,0 +1,42 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+//
[
https://issues.apache.org/jira/browse/FLINK-29594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654815#comment-17654815
]
Matthias Pohl commented on FLINK-29594:
---
[
https://issues.apache.org/jira/browse/FLINK-30507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654814#comment-17654814
]
Matthias Pohl commented on FLINK-30507:
---
[
https://issues.apache.org/jira/browse/FLINK-30516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654813#comment-17654813
]
Shammon commented on FLINK-30516:
-
For this issue, I think maybe we should add statistics such as total
lindong28 commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r1062167754
##
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java:
##
@@ -54,6 +60,44 @@ public void testParseJsonFile() throws Exception {
jiangxin369 commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r1062165249
##
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java:
##
@@ -54,6 +60,44 @@ public void testParseJsonFile() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-30558.
---
Resolution: Fixed
master:
b50f42673fcd44bdd6de73f77d646df5c2ad1eed
1.16:
[
https://issues.apache.org/jira/browse/FLINK-30569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30569:
---
Labels: pull-request-available (was: )
> File Format can not change with data file exists
Jingsong Lee created FLINK-30569:
Summary: File Format can not change with data file exists
Key: FLINK-30569
URL: https://issues.apache.org/jira/browse/FLINK-30569
Project: Flink
Issue Type:
JingsongLi opened a new pull request, #459:
URL: https://github.com/apache/flink-table-store/pull/459
1. Set file format to orc
2. Write records.
3. Set file format to parquet.
4. Write records
5. Read -> throw exception...
We should support change file format.
--
This
jiangxin369 commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r1062159232
##
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java:
##
@@ -54,6 +60,44 @@ public void testParseJsonFile() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30558:
Affects Version/s: 1.16.0
> The metric 'numRestarts' reported in SchedulerBase will be overridden by
>
yuchuanchen commented on code in PR #21563:
URL: https://github.com/apache/flink/pull/21563#discussion_r1062158485
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetVectorizedInputFormat.java:
##
@@ -123,7 +151,7 @@ public ParquetReader
[
https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30558:
Fix Version/s: 1.16.1
> The metric 'numRestarts' reported in SchedulerBase will be overridden by
>
zhuzhurk merged PR #21598:
URL: https://github.com/apache/flink/pull/21598
--
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:
xintongsong commented on code in PR #21579:
URL: https://github.com/apache/flink/pull/21579#discussion_r1062140088
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ChainingOutput.java:
##
@@ -40,33 +38,24 @@
private static final Logger LOG =
[
https://issues.apache.org/jira/browse/FLINK-30561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654744#comment-17654744
]
Hangxiang Yu commented on FLINK-30561:
--
It seems FLINK-30107 and FLINK-28898 are caused by this ?
flinkbot commented on PR #21602:
URL: https://github.com/apache/flink/pull/21602#issuecomment-1371783090
## CI report:
* 21d92c71e94f00b97ffad0180dd88ec06d4e17f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30567:
---
Labels: pull-request-available (was: )
> Wrong insert overwrite behavior when the table
luoyuxia opened a new pull request, #21602:
URL: https://github.com/apache/flink/pull/21602
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-30560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30560.
Fix Version/s: table-store-0.3.0
Assignee: yuzelin
Resolution: Fixed
master:
JingsongLi merged PR #457:
URL: https://github.com/apache/flink-table-store/pull/457
--
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-30565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30565:
---
Labels: pull-request-available (was: )
> Flink-parquet free for flink-table-store-format
>
JingsongLi opened a new pull request, #458:
URL: https://github.com/apache/flink-table-store/pull/458
Copy codes from flink-parquet.
--
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-30497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-30497.
-
Resolution: Implemented
Merged into master: cce059c556bc2538cba8918e281320516c4be222
>
fsk119 merged PR #21592:
URL: https://github.com/apache/flink/pull/21592
--
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:
weibo zhao created FLINK-30568:
--
Summary: Add benchmark for PolyNomialExpansion, Normalizer,
Binarizer, Interaction, MaxAbsScaler, VectorSlicer, ElementWiseProduct and
Featurehasher
Key: FLINK-30568
URL:
[
https://issues.apache.org/jira/browse/FLINK-30567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654725#comment-17654725
]
luoyuxia commented on FLINK-30567:
--
Introduced by FLINK-29337, we miss to convert the table name into
luoyuxia created FLINK-30567:
Summary: Wrong insert overwrite behavior when the table contains
uppercase character with Hive dialect
Key: FLINK-30567
URL: https://issues.apache.org/jira/browse/FLINK-30567
[
https://issues.apache.org/jira/browse/FLINK-30566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang reassigned FLINK-30566:
-
Assignee: Zhipeng Zhang
> Add benchmark configurations for agglomerativeclustering,
[
https://issues.apache.org/jira/browse/FLINK-30566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30566:
---
Labels: pull-request-available (was: )
> Add benchmark configurations for
zhipeng93 opened a new pull request, #197:
URL: https://github.com/apache/flink-ml/pull/197
## What is the purpose of the change
- Add benchmark configurations for some of the existing algorithms.
## Brief change log
- Add benchmark configuration files for
Zhipeng Zhang created FLINK-30566:
-
Summary: Add benchmark configurations for agglomerativeclustering,
hashingtf, idf, kbinsdiscretizer, linearregression, linearsvc,
logisticregression, ngram, regextokenizer, tokenizer and vectorindexer
[
https://issues.apache.org/jira/browse/FLINK-30563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30563:
---
Labels: pull-request-available (was: )
> Update training exercises to use Flink 1.16
>
TanYuxin-tyx opened a new pull request, #50:
URL: https://github.com/apache/flink-training/pull/50
Update the Flink version to Flink 1.16.
--
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-30563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654714#comment-17654714
]
Yuxin Tan commented on FLINK-30563:
---
Thanks [~danderson] for reporting this. I want to take a look at
Jingsong Lee created FLINK-30565:
Summary: Flink-parquet free for flink-table-store-format
Key: FLINK-30565
URL: https://issues.apache.org/jira/browse/FLINK-30565
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-30552.
-
Resolution: Fixed
master via https://github.com/apache/flink-connector-pulsar/pull/11
> Pulsar
tisonkun merged PR #11:
URL: https://github.com/apache/flink-connector-pulsar/pull/11
--
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:
xintongsong commented on code in PR #21565:
URL: https://github.com/apache/flink/pull/21565#discussion_r1062064266
##
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java:
##
@@ -435,9 +487,19 @@ private void startTaskExecutorInContainerAsync(
flinkbot commented on PR #21601:
URL: https://github.com/apache/flink/pull/21601#issuecomment-1371700252
## CI report:
* 2b2b2edad3807c999105bb9163bf21da8bffe6c6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lsyldliu opened a new pull request, #21601:
URL: https://github.com/apache/flink/pull/21601
## What is the purpose of the change
*Implementing a native hive avg function based on the expression aggregate
function, can improve the agg performance by using hash-agg strategy.*
yuzelin commented on code in PR #457:
URL: https://github.com/apache/flink-table-store/pull/457#discussion_r1062053382
##
docs/content/docs/how-to/writing-tables.md:
##
@@ -87,3 +87,66 @@ INSERT OVERWRITE MyTable PARTITION (key1 = value1, key2 =
value2, ...) SELECT ..
{{<
[
https://issues.apache.org/jira/browse/FLINK-30547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30547.
Resolution: Fixed
master: f2314e46617d4d0dcbdc5f65a2699209072a08e3
> Flink-table-runtime free
[
https://issues.apache.org/jira/browse/FLINK-30556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654702#comment-17654702
]
luoyuxia edited comment on FLINK-30556 at 1/5/23 2:15 AM:
--
[~Wencong Liu]
JingsongLi merged PR #452:
URL: https://github.com/apache/flink-table-store/pull/452
--
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-29796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-29796.
Resolution: Fixed
> pyflink protobuf requirement out of date
>
[
https://issues.apache.org/jira/browse/FLINK-30556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654702#comment-17654702
]
luoyuxia commented on FLINK-30556:
--
[~Wencong Liu] Thanks for invesgation. TBH, that's what my thought.
[
https://issues.apache.org/jira/browse/FLINK-30560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30560:
---
Labels: pull-request-available (was: )
> Add more description of 'Overwriting a Partition'
JingsongLi commented on code in PR #457:
URL: https://github.com/apache/flink-table-store/pull/457#discussion_r1062035797
##
docs/content/docs/how-to/writing-tables.md:
##
@@ -87,3 +87,66 @@ INSERT OVERWRITE MyTable PARTITION (key1 = value1, key2 =
value2, ...) SELECT ..
{{<
[
https://issues.apache.org/jira/browse/FLINK-30084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-30084:
Assignee: Weihua Hu
> Remove unused ResourceActions.notifyAllocationFailure
>
[
https://issues.apache.org/jira/browse/FLINK-29869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29869:
Assignee: Weihua Hu
> make ResourceActions declarative
>
[
https://issues.apache.org/jira/browse/FLINK-29870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29870:
Assignee: Weihua Hu
> split ResourceNotEnoughNotifier from ResourceActions
>
weibozhao commented on PR #189:
URL: https://github.com/apache/flink-ml/pull/189#issuecomment-1371647105
>
> Hi @weibozhao, thanks for the update. Could you please modify the
description section of this PR and its corresponding Jira ticket, explaining
the changes made in
[
https://issues.apache.org/jira/browse/FLINK-30030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654699#comment-17654699
]
luoyuxia commented on FLINK-30030:
--
After some investigation, the expected behavior should consider
[
https://issues.apache.org/jira/browse/FLINK-30030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-30030.
Fix Version/s: 1.16.1
1.16.0
Resolution: Invalid
> Unexpected behavior for
[
https://issues.apache.org/jira/browse/FLINK-30561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feifan Wang updated FLINK-30561:
Priority: Critical (was: Major)
> ChangelogStreamHandleReaderWithCache cause
[
https://issues.apache.org/jira/browse/FLINK-30561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feifan Wang updated FLINK-30561:
Priority: Major (was: Critical)
> ChangelogStreamHandleReaderWithCache cause
lindong28 commented on code in PR #195:
URL: https://github.com/apache/flink-ml/pull/195#discussion_r1062018596
##
flink-ml-benchmark/src/main/resources/dct-benchmark.json:
##
@@ -0,0 +1,40 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+//
lindong28 commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r1062011981
##
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java:
##
@@ -54,6 +60,44 @@ public void testParseJsonFile() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-25509:
Assignee: Hang Ruan (was: Dong Lin)
> FLIP-208: Add RecordEvaluator to dynamically stop source
Alex Sorokoumov created FLINK-30564:
---
Summary: Select from a new table with Kafka LogStore crashes with
UnknownTopicOrPartitionException
Key: FLINK-30564
URL: https://issues.apache.org/jira/browse/FLINK-30564
kristoffSC commented on PR #21393:
URL: https://github.com/apache/flink/pull/21393#issuecomment-1371489783
@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-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30483:
--
Assignee: Jagadesh Adireddi
> Make Avro format support for TIMESTAMP_LTZ
>
1 - 100 of 215 matches
Mail list logo
