MartijnVisser commented on PR #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-1160046705
> The main reason I use scala in the code is that it's more clear to write
codegen code. In the first version of this PR, I used java code to do that. If
we cannot use scala depende
[
https://issues.apache.org/jira/browse/FLINK-28119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556222#comment-17556222
]
Martijn Visser edited comment on FLINK-28119 at 6/20/22 6:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556222#comment-17556222
]
Martijn Visser commented on FLINK-28119:
[~martijnvisser] Thanks! I'll update th
[
https://issues.apache.org/jira/browse/FLINK-28119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28119:
--
Assignee: Martijn Visser
> Update the document for Contribute Documentation
> ---
MartijnVisser commented on code in PR #20011:
URL: https://github.com/apache/flink/pull/20011#discussion_r901309667
##
flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java:
##
@@ -527,13 +527,30 @@ public static FileSystem getUnguardedFileSystem(final URI
fsUri) th
[
https://issues.apache.org/jira/browse/FLINK-28125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556220#comment-17556220
]
Weijie Guo commented on FLINK-28125:
Hi [~xtsong] , I am interested in this ticket,
[
https://issues.apache.org/jira/browse/FLINK-28115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28115:
---
Flags: (was: Important)
> Flink 1.15.0 Parallelism Rebalance causes flink job failure
> --
[
https://issues.apache.org/jira/browse/FLINK-28116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28116:
---
Issue Type: New Feature (was: Improvement)
> Elasticsearch connector doesn't provide securi
[
https://issues.apache.org/jira/browse/FLINK-28116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28116:
---
Component/s: Connectors / ElasticSearch
> Elasticsearch connector doesn't provide security t
[
https://issues.apache.org/jira/browse/FLINK-28116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28116:
---
Flags: (was: Important)
> Elasticsearch connector doesn't provide security through token
>
[
https://issues.apache.org/jira/browse/FLINK-28117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556214#comment-17556214
]
Martijn Visser commented on FLINK-28117:
[~jingge] Why would these metrics only
maosuhan commented on PR #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-1160032898
> Thanks for starting the review @libenchao - I have one comment about this
one
>
> > 2. I noticed you introduced scala dependency for this module, hence we'd
better to add the sc
[
https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556209#comment-17556209
]
Feifan Wang commented on FLINK-27822:
-
Hi [~jingge] , can you help me find a Chinese
[
https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-28121:
---
Assignee: Chengkai Yang
> Translate "Extension Points" and "Full Stack Example" in "User-defined
>
deadwind4 commented on PR #20005:
URL: https://github.com/apache/flink/pull/20005#issuecomment-1160018239
@jmd300 You can read [How to
contribue](https://flink.apache.org/contributing/contribute-code.html) and [how
to contribute
doc](https://flink.apache.org/contributing/contribute-documen
csviri commented on code in PR #269:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/269#discussion_r901287441
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventHelper.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apac
deadwind4 commented on PR #19988:
URL: https://github.com/apache/flink/pull/19988#issuecomment-1160014687
@dianfu I agree with you. If we migrate all built-in functions to the new
stack, we could create a new Jira ticket to target this.
--
This is an automated message from the Apache Git
dianfu commented on PR #19988:
URL: https://github.com/apache/flink/pull/19988#issuecomment-1160011713
@snuyanzin @deadwind4 Per my understanding, the new stack is to ease the
adding of new built-in functions. For existing functions, as the work is
already done, it isn't convincing for me t
zhoulii commented on PR #19984:
URL: https://github.com/apache/flink/pull/19984#issuecomment-1160009844
@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.
deadwind4 commented on code in PR #20017:
URL: https://github.com/apache/flink/pull/20017#discussion_r901276805
##
docs/content.zh/docs/dev/table/types.md:
##
@@ -100,47 +100,38 @@ t = DataTypes.INTERVAL(DataTypes.DAY(),
DataTypes.SECOND(3))
{{< /tab >}}
{{< /tabs >}}
+
-
[
https://issues.apache.org/jira/browse/FLINK-27159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27159.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Merged to master via 210c6275c08466fcd93fa8c4dede379724c20df5
dianfu closed pull request #19958: [FLINK-27159][table-api] Support
first_value/last_value in the Table API
URL: https://github.com/apache/flink/pull/19958
--
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
dianfu commented on PR #19958:
URL: https://github.com/apache/flink/pull/19958#issuecomment-1160004679
> And there is a minor issue , I find that the functions documentation for
python is redirect to System (Built-in) Functions documentation for Java API.
It's first_value() in python while
Xuannan Su created FLINK-28126:
--
Summary: Iteration gets stuck when replayable datastream and its
downstream operator have different parallelism
Key: FLINK-28126
URL: https://issues.apache.org/jira/browse/FLINK-28126
[
https://issues.apache.org/jira/browse/FLINK-27861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-27861.
---
Assignee: dalongliu
Resolution: Fixed
Fixed in master: 7032ce386d7e765ad9a295732f2f909db97dce1b
> Int
reswqa commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r901274198
##
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java:
##
@@ -1449,20 +1449,70 @@ public void testProcessRes
wuchong merged PR #19859:
URL: https://github.com/apache/flink/pull/19859
--
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
deadwind4 commented on PR #22:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/22#issuecomment-1159997140
@MartijnVisser I create a `SimpleElasticsearchEmitter` class in
https://github.com/apache/flink/pull/19732 and rename it to
`MapElasticsearchEmitter` in https://gith
gaoyunhaii commented on PR #545:
URL: https://github.com/apache/flink-web/pull/545#issuecomment-1159993038
Very thanks @zhuzhurk for the review! I have update the PR accordingly
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Xintong Song created FLINK-28125:
Summary: Promote leadership changing logs to INFO level
Key: FLINK-28125
URL: https://issues.apache.org/jira/browse/FLINK-28125
Project: Flink
Issue Type: Im
1996fanrui commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r901261999
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest build
[
https://issues.apache.org/jira/browse/FLINK-28123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556191#comment-17556191
]
Zhuang Liu commented on FLINK-28123:
-
[~martijnvisser],OK，thanks your reply.I will
[
https://issues.apache.org/jira/browse/FLINK-28123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556189#comment-17556189
]
Martijn Visser commented on FLINK-28123:
[~liu zhuang] Please try this with the
[
https://issues.apache.org/jira/browse/FLINK-28123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28123:
---
Fix Version/s: (was: 1.16.0)
> When a flink job is restarted, the metaspce size of the t
MartijnVisser commented on PR #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-1159966132
Thanks for starting the review @libenchao - I have one comment about this one
> 2\. I noticed you introduced scala dependency for this module, hence we'd
better to add the sca
lindong28 merged PR #112:
URL: https://github.com/apache/flink-ml/pull/112
--
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.apac
lindong28 commented on PR #112:
URL: https://github.com/apache/flink-ml/pull/112#issuecomment-1159959274
Thanks for the information. 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 spec
lindong28 commented on PR #112:
URL: https://github.com/apache/flink-ml/pull/112#issuecomment-1159956579
For the record, @yunfengzhou-hub has done benchmarks to verify the
performance impact of this PR. Here are the results:
- Benchmark setup: an iterative data stream job with an almo
deadwind4 opened a new pull request, #22:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/22
The PR only aligns code in main repo, the MapElasticsearchEmitter class is
used in PyFlink ES connector.
I will use this [ticket](https://issues.apache.org/jira/browse/FLINK-
gaoyunhaii commented on code in PR #545:
URL: https://github.com/apache/flink-web/pull/545#discussion_r901234540
##
_posts/2022-06-01-final-checkpoint-part1.md:
##
@@ -81,59 +81,61 @@ running subtasks. The states could be repartitioned on
restarting and all the ne
To support c
gaoyunhaii commented on code in PR #545:
URL: https://github.com/apache/flink-web/pull/545#discussion_r901234152
##
_posts/2022-06-01-final-checkpoint-part1.md:
##
@@ -81,59 +81,61 @@ running subtasks. The states could be repartitioned on
restarting and all the ne
To support c
flinkbot commented on PR #20019:
URL: https://github.com/apache/flink/pull/20019#issuecomment-1159939416
## CI report:
* c8c674d62adc242a0caef7193c34f81a76ec2420 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r895604615
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java:
##
@@ -76,7 +74,7 @@ public interface TaskLocalStateStore {
/**
* Remov
xintongsong opened a new pull request, #20019:
URL: https://github.com/apache/flink/pull/20019
See #19646
--
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-
[
https://issues.apache.org/jira/browse/FLINK-27877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-27877.
--
Resolution: Fixed
> Improve performance of several feature engineering algorithms
> --
[
https://issues.apache.org/jira/browse/FLINK-27877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27877:
-
Summary: Improve StringIndexer performance and optimize flink-ml-bench
(was: Improve performance of sev
[
https://issues.apache.org/jira/browse/FLINK-28115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556178#comment-17556178
]
Qingsheng Ren commented on FLINK-28115:
---
>From the stack trace it looks like unrel
lindong28 merged PR #111:
URL: https://github.com/apache/flink-ml/pull/111
--
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.apac
lindong28 commented on PR #111:
URL: https://github.com/apache/flink-ml/pull/111#issuecomment-1159934718
Thanks for the update. 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
liuzhuo created FLINK-28124:
---
Summary: Flink on K8S in hosetNetwork mode, the CPU usage will
spike
Key: FLINK-28124
URL: https://issues.apache.org/jira/browse/FLINK-28124
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-27696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-27696:
-
Description:
We don't have to assign each task with a whole bucket data files. Instead, we
can
JingsongLi opened a new pull request, #165:
URL: https://github.com/apache/flink-table-store/pull/165
We don't have to assign each task with a whole bucket data files. Instead,
we can use some algorithm ( such as bin-packing) to split the whole bucket data
files into multiple fragments to i
[
https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28107.
---
Assignee: LuNing Wang
Resolution: Fixed
Merged to master via 11910d52cd1b948b21d0ea04263be689d2bd721e
dianfu closed pull request #20002:
[FLINK-28107][python][connector/elasticsearch] Support id of document is null
URL: https://github.com/apache/flink/pull/20002
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[ https://issues.apache.org/jira/browse/FLINK-28111 ]
yutao deleted comment on FLINK-28111:
---
was (Author: chaojipaopao):
[~jingge] ok,just in work day.i will try
> flinksql use hivecatalog cause union all operation lost 'eventTime
> attribute'
> -
fredia commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r895925820
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java:
##
@@ -141,6 +158,29 @@ public void storeLocalState(
subt
gaoyunhaii closed pull request #19653: [FLINK-27523] Runtime supports producing
and consuming cached intermediate results
URL: https://github.com/apache/flink/pull/19653
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
gaoyunhaii commented on PR #19653:
URL: https://github.com/apache/flink/pull/19653#issuecomment-1159909912
Thanks @Sxnan for the PR and @zhuzhurk @wsry for the review! will merge~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/FLINK-28123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556166#comment-17556166
]
Zhuang Liu commented on FLINK-28123:
-
TaskManager log:
2022-06-17 16:35:42,720 ERR
Aitozi commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r901209861
##
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java:
##
@@ -1466,6 +1466,52 @@ public void testProcessReso
wangyang0918 commented on code in PR #15832:
URL: https://github.com/apache/flink/pull/15832#discussion_r901208618
##
flink-runtime/src/main/java/org/apache/flink/runtime/persistence/PossibleInconsistentStateException.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Soft
flinkbot commented on PR #20018:
URL: https://github.com/apache/flink/pull/20018#issuecomment-1159898654
## CI report:
* a49f2dfbd0b2cdca8292d621fd322494aefef06f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28120:
---
Labels: pull-request-available (was: )
> Meet assert error: BatchPhysicalExchange.BATCH_PHY
luoyuxia opened a new pull request, #20018:
URL: https://github.com/apache/flink/pull/20018
## What is the purpose of the change
To fix FlinkCost comparison issue that the logic inconsistent between
`Flink#isLe` and `Flink#equal`.
## Brief change log
Modify the compa
cason0126 commented on PR #19964:
URL: https://github.com/apache/flink/pull/19964#issuecomment-1159896445
@ChengkaiYang2022 Thanks for correcting. I will fix them ;
There is one part I am confusing about : using (both inclusive) instead of
using '[' and ']' 。 I think using `[` and`]
Zhuang Liu created FLINK-28123:
---
Summary: When a flink job is restarted, the metaspce size of the
taskmanager does not decrease but keeps increasing. After several restarts, the
flink job metaspce oom.
Key: FLINK-28123
[
https://issues.apache.org/jira/browse/FLINK-28019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28019:
-
Fix Version/s: 1.15.2
> Error occurred when retract a staled record when enable state ttl in
>
[
https://issues.apache.org/jira/browse/FLINK-28019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554931#comment-17554931
]
Jingsong Lee edited comment on FLINK-28019 at 6/20/22 2:13 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-28019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28019:
-
Fix Version/s: 1.14.6
> Error occurred when retract a staled record when enable state ttl in
>
JingsongLi merged PR #19996:
URL: https://github.com/apache/flink/pull/19996
--
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.ap
JingsongLi merged PR #19997:
URL: https://github.com/apache/flink/pull/19997
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-16105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556085#comment-17556085
]
Chengkai Yang edited comment on FLINK-16105 at 6/20/22 2:11 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556158#comment-17556158
]
Chengkai Yang commented on FLINK-28121:
---
[~jark] hi,could you assign this to me?
zhipeng93 commented on PR #111:
URL: https://github.com/apache/flink-ml/pull/111#issuecomment-1159890361
@lindong28 @yunfengzhou-hub Thanks for the PR. The comments have been
addressed in the latest PR.
--
This is an automated message from the Apache Git Service.
To respond to the message
yunfengzhou-hub commented on code in PR #111:
URL: https://github.com/apache/flink-ml/pull/111#discussion_r901202810
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/BenchmarkUtils.java:
##
@@ -99,6 +99,7 @@ private static BenchmarkResult runBenchmark(
zhipeng93 commented on code in PR #111:
URL: https://github.com/apache/flink-ml/pull/111#discussion_r901202605
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/BenchmarkUtils.java:
##
@@ -99,6 +99,7 @@ private static BenchmarkResult runBenchmark(
Da
[
https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-28121:
--
Description:
The links are
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/tabl
[
https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-28122:
--
Description:
The links are
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table
[
https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-28122:
--
Component/s: chinese-translation
Documentation
> Translate "Overview " and "P
Chengkai Yang created FLINK-28122:
-
Summary: Translate "Overview " and "Project Configuration" in
"User-defined Sources & Sinks" page
Key: FLINK-28122
URL: https://issues.apache.org/jira/browse/FLINK-28122
[
https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-28121:
--
Summary: Translate "Extension Points" and "Full Stack Example" in
"User-defined Sources & Sink
zhipeng93 commented on code in PR #111:
URL: https://github.com/apache/flink-ml/pull/111#discussion_r901200665
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/DoubleGenerator.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software
Chengkai Yang created FLINK-28121:
-
Summary: Translate in "Extension Points" and "Full Stack Example"
in "User-defined Sources & Sinks" page
Key: FLINK-28121
URL: https://issues.apache.org/jira/browse/FLINK-28121
[
https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556154#comment-17556154
]
luoyuxia commented on FLINK-28120:
--
[~godfrey] Could you please have a look. And I woul
Sxnan commented on PR #19653:
URL: https://github.com/apache/flink/pull/19653#issuecomment-1159884365
@wsry Thanks for your feedback. @gaoyunhaii Could you help merging the PR if
there are no more concern?
--
This is an automated message from the Apache Git Service.
To respond to the mess
[
https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28120:
-
Description:
When I run the following sql with Hive dialect,
{code:java}
create table src(key string,
[
https://issues.apache.org/jira/browse/FLINK-28111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556153#comment-17556153
]
yutao commented on FLINK-28111:
---
[~jingge] [~martijnvisser] flink 1.15.0 also have this p
yunfengzhou-hub commented on PR #112:
URL: https://github.com/apache/flink-ml/pull/112#issuecomment-1159880670
Hi @lindong28, Thanks for reviewing this PR.
Before this PR is implemented, Flink ML stages with iterations, like KMeans,
have to spend at least 100 ms for each iteration th
ChengkaiYang2022 commented on code in PR #19964:
URL: https://github.com/apache/flink/pull/19964#discussion_r901187712
##
docs/content.zh/docs/dev/table/types.md:
##
@@ -686,55 +669,50 @@ TIME(p)
DataTypes.TIME(p)
```
-**Bridging to JVM Types**
+**JVM Types桥接**
-| Java Typ
zhoulii commented on code in PR #19984:
URL: https://github.com/apache/flink/pull/19984#discussion_r901196339
##
flink-core/src/test/java/org/apache/flink/api/common/io/GlobFilePathFilterTest.java:
##
@@ -27,14 +27,13 @@
import java.io.IOException;
import java.util.Collections
[
https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28120:
-
Attachment: 截屏2022-06-18 上午11.48.46.png
> Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lo
[ https://issues.apache.org/jira/browse/FLINK-26270 ]
fengjk deleted comment on FLINK-26270:
was (Author: JIRAUSER284851):
The current fix is repackaged by modifying the source code Settings , But not
dynamic parameter configuration：
this.csvMappe
luoyuxia created FLINK-28120:
Summary: Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL
has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0,
1]true.[]]
Key: FLINK-28120
URL: https://i
liujiawinds commented on PR #20006:
URL: https://github.com/apache/flink/pull/20006#issuecomment-1159871386
@reswqa Thanks for your review.
--
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 spe
complone commented on PR #164:
URL:
https://github.com/apache/flink-table-store/pull/164#issuecomment-1159859486
> Hi @complone AppendOnly's compaction is not the compaction inside
MergeTree, AppendOnly's compaction is actually a small files merge
I will read [leveldb related
materi
[
https://issues.apache.org/jira/browse/FLINK-28114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28114.
---
Assignee: Dian Fu
Resolution: Fixed
Fixed in:
- master via 6b04a50ae2182d4cdd8e44ea9a16171d1d2394ce
-
deadwind4 commented on PR #20002:
URL: https://github.com/apache/flink/pull/20002#issuecomment-1159838998
@dianfu make sense to me.
--
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 co
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556114#comment-17556114
]
Weijie Guo edited comment on FLINK-28033 at 6/19/22 6:43 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556114#comment-17556114
]
Weijie Guo edited comment on FLINK-28033 at 6/19/22 6:43 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556114#comment-17556114
]
Weijie Guo commented on FLINK-28033:
`newMinWatermark` is a local variable, it will
1 - 100 of 169 matches
Mail list logo
