[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618686#comment-17618686
]
xiaogang zhou commented on FLINK-29545:
---
[~pnowojski] This turns out to be a netwo
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29545:
---
Labels: pull-request-available (was: )
> kafka consuming stop when trigger first checkpoint
zhougit86 opened a new pull request, #21080:
URL: https://github.com/apache/flink/pull/21080
## What is the purpose of the change
detect network connection problem
## Brief change log
add an idle state handler for netty protocol
## Verifying this ch
[
https://issues.apache.org/jira/browse/FLINK-29620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618683#comment-17618683
]
liad shachoach commented on FLINK-29620:
i'll try it tomorrow, thanks :)
> Flin
[
https://issues.apache.org/jira/browse/FLINK-28643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LI Mingkun updated FLINK-28643:
---
Description:
h1. Problem
In History Server, 'HistoryServerArchiveFetcher' fetch job archived file,a
[
https://issues.apache.org/jira/browse/FLINK-29126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-29126.
--
Resolution: Fixed
> Fix spliting file optimization doesn't work for orc format
> -
HuangXingBo commented on code in PR #21079:
URL: https://github.com/apache/flink/pull/21079#discussion_r996658315
##
flink-python/pyflink/common/typeinfo.py:
##
@@ -720,6 +720,39 @@ def __repr__(self) -> str:
return 'MapTypeInfo<{}, {}>'.format(self._key_type_info,
sel
tsreaper commented on code in PR #315:
URL: https://github.com/apache/flink-table-store/pull/315#discussion_r996658295
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeWriter.java:
##
@@ -122,48 +139,61 @@ public void write(KeyValue kv
fredia closed pull request #21050: [FLINK-29095][state] Improve logging in
SharedStateRegistry
URL: https://github.com/apache/flink/pull/21050
--
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
[
https://issues.apache.org/jira/browse/FLINK-29157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618667#comment-17618667
]
Yanfei Lei edited comment on FLINK-29157 at 10/17/22 6:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-29157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618667#comment-17618667
]
Yanfei Lei commented on FLINK-29157:
> mark the interface(s) as PublicEvolving
Sinc
yunfengzhou-hub commented on code in PR #163:
URL: https://github.com/apache/flink-ml/pull/163#discussion_r996638399
##
flink-ml-python/pyflink/ml/core/linalg.py:
##
@@ -776,3 +777,15 @@ def _double_to_long_bits(value: float) -> int:
value = float("nan")
# pack dou
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618658#comment-17618658
]
Xintong Song commented on FLINK-29572:
--
[~gzkevinl],
I probably haven't understand
nagasudhakar created FLINK-29654:
Summary: Vulnerable libraries - Flink 1.15.2
Key: FLINK-29654
URL: https://issues.apache.org/jira/browse/FLINK-29654
Project: Flink
Issue Type: Bug
reswqa closed pull request #20902: [FLINK-29419] fix the problem that
testHybridFullExchangesRestart hang.
URL: https://github.com/apache/flink/pull/20902
--
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 g
reswqa commented on PR #20902:
URL: https://github.com/apache/flink/pull/20902#issuecomment-1280307609
This pull request does not fix the problem.
--
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
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618429#comment-17618429
]
Xintong Song commented on FLINK-29646:
--
cc [~fsk119]
> SQL Gateway should return a
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618428#comment-17618428
]
Xintong Song commented on FLINK-29646:
--
I agree that for this specific example, or
[
https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618422#comment-17618422
]
Jingqi Shi commented on FLINK-29653:
Anyone can assign this to me?
> close DynamicR
[
https://issues.apache.org/jira/browse/FLINK-29652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618423#comment-17618423
]
Jingqi Shi commented on FLINK-29652:
Anyone can assign this to me?
> get duplicate
Jingqi Shi created FLINK-29653:
--
Summary: close DynamicResult but it was already closed
Key: FLINK-29653
URL: https://issues.apache.org/jira/browse/FLINK-29653
Project: Flink
Issue Type: Bug
Jingqi Shi created FLINK-29652:
--
Summary: get duplicate result from sql-client in BATCH mode
Key: FLINK-29652
URL: https://issues.apache.org/jira/browse/FLINK-29652
Project: Flink
Issue Type: Bu
flinkbot commented on PR #21079:
URL: https://github.com/apache/flink/pull/21079#issuecomment-1280292955
## CI report:
* 13b7ec676805c982c7c426fe9c5cb19cde33e793 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29648:
---
Labels: pull-request-available (was: )
> "LocalDateTime not supported" error when retrievin
Vancior opened a new pull request, #21079:
URL: https://github.com/apache/flink/pull/21079
## What is the purpose of the change
This PR fixes "LocalTimeTypeInfo not supported" error when retrieving
TypeInformation from PyFlink, e.g. calling `key_by` after `to_data_stream`.
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618413#comment-17618413
]
yuanfenghu edited comment on FLINK-29646 at 10/17/22 4:46 AM:
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618413#comment-17618413
]
yuanfenghu edited comment on FLINK-29646 at 10/17/22 4:46 AM:
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618413#comment-17618413
]
yuanfenghu commented on FLINK-29646:
Thank [~xtsong] . It is really not the best wa
masteryhx commented on code in PR #21053:
URL: https://github.com/apache/flink/pull/21053#discussion_r996601693
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java:
##
@@ -39,6 +41,15 @@ public interface CompletedCheckpointStore {
fredia commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r996599726
##
flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java:
##
@@ -251,6 +254,8 @@ private void asy
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618406#comment-17618406
]
Xintong Song commented on FLINK-29646:
--
Let me ask in this way: How do you know the
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618407#comment-17618407
]
Kevin Li commented on FLINK-29572:
--
1. It is called service mesh, basically all ingress
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618404#comment-17618404
]
Xingbo Huang commented on FLINK-29419:
--
[~Weijie Guo] Is any update on this issue?
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618403#comment-17618403
]
Xingbo Huang commented on FLINK-29419:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-26238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618402#comment-17618402
]
Xingbo Huang commented on FLINK-26238:
--
[https://dev.azure.com/apache-flink/apache-
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618401#comment-17618401
]
Xingbo Huang commented on FLINK-29387:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618400#comment-17618400
]
Xingbo Huang commented on FLINK-29387:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618399#comment-17618399
]
Xingbo Huang commented on FLINK-29387:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618396#comment-17618396
]
Xingbo Huang commented on FLINK-29427:
--
https://dev.azure.com/apache-flink/apache-f
lindong28 commented on code in PR #163:
URL: https://github.com/apache/flink-ml/pull/163#discussion_r996575556
##
flink-ml-python/pyflink/ml/core/linalg.py:
##
@@ -776,3 +777,15 @@ def _double_to_long_bits(value: float) -> int:
value = float("nan")
# pack double in
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618395#comment-17618395
]
yuanfenghu commented on FLINK-29646:
I would like to explain the scenario where we u
[
https://issues.apache.org/jira/browse/FLINK-29640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29640:
Assignee: Liu
> Enhance the function configured by execution.shutdown-on-attached-exit by
[
https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618393#comment-17618393
]
Xintong Song commented on FLINK-29639:
--
Thanks, [~Jiangang]. You are assigned
> Ad
[
https://issues.apache.org/jira/browse/FLINK-29641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29641:
Assignee: Weijie Guo
> SortMergeResultPartitionReadSchedulerTest.testCreateSubpartitionRe
[
https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29639:
Assignee: Liu
> Add ResourceId in TransportException for debugging
> ---
[
https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618392#comment-17618392
]
Zhu Zhu edited comment on FLINK-29629 at 10/17/22 3:13 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618392#comment-17618392
]
Zhu Zhu commented on FLINK-29629:
-
Thanks for reporting this! I agree it is not ideal bu
[
https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618392#comment-17618392
]
Zhu Zhu edited comment on FLINK-29629 at 10/17/22 3:12 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618387#comment-17618387
]
Xintong Song commented on FLINK-29646:
--
That's probably worth-considering direction
sap1ens commented on code in PR #20475:
URL: https://github.com/apache/flink/pull/20475#discussion_r996570322
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkOptions.java:
##
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache S
sap1ens commented on code in PR #20475:
URL: https://github.com/apache/flink/pull/20475#discussion_r996570099
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -398,6 +407,11 @@ private void registerMetricSync()
flinkbot commented on PR #21078:
URL: https://github.com/apache/flink/pull/21078#issuecomment-1280194634
## CI report:
* a3b63d0182634bf3cb7bf6c3e1a5de19f309dacd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618382#comment-17618382
]
yuanfenghu commented on FLINK-29646:
Maybe you can add a parameter to the client, wh
waywtdcc closed pull request #20412: [FLINK-28985][planner]sql like statement
supports views
URL: https://github.com/apache/flink/pull/20412
--
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 speci
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r996564183
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28985:
---
Labels: pull-request-available (was: )
> support create table like view
> -
waywtdcc opened a new pull request, #21078:
URL: https://github.com/apache/flink/pull/21078
## What is the purpose of the change
```
At present, to create a table based on table like, you can only use the
table type table, not the view type.
create table
[
https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618378#comment-17618378
]
Eric Xiao commented on FLINK-29498:
---
As discussed in the [slack
thread|https://apache
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618377#comment-17618377
]
Xintong Song commented on FLINK-29646:
--
First of all, the provided PR changes the d
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r996560465
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r996560465
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618373#comment-17618373
]
Xintong Song commented on FLINK-29572:
--
[~gzkevinl],
I'm still not entirely sure w
[
https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29479:
Summary: Support whether using system PythonPath for PyFlink jobs (was:
support whether using system env
[
https://issues.apache.org/jira/browse/FLINK-25497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-25497.
---
Resolution: Duplicate
Seems duplicate with FLINK-27715. Just close it~
> Add more ML Python examples
>
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618367#comment-17618367
]
yuanfenghu commented on FLINK-29646:
There is no problem in reporting a complete exc
[
https://issues.apache.org/jira/browse/FLINK-26084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-26084.
---
Resolution: Cannot Reproduce
> Python tests exit with code 137
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-26264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-26264.
---
Resolution: Cannot Reproduce
> Python Test failed on its docs building phase
> -
[
https://issues.apache.org/jira/browse/FLINK-26385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-26385.
---
Resolution: Duplicate
> Use new Kafka source and sink in Python API
> --
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996440219
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/FLINK-28667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28667.
---
Fix Version/s: (was: 1.17.0)
Resolution: Duplicate
> "evictor" operations of "window_all" are sup
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618365#comment-17618365
]
Xintong Song commented on FLINK-29646:
--
I'm -1 for this change.
Reporting the root
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996445729
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/FLINK-29094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29094:
Component/s: Connectors / Kafka
(was: API / Python)
> Cannot stop Python job with sav
[
https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29479:
Affects Version/s: (was: 1.17.0)
> support whether using system env for pythonpath
> -
[
https://issues.apache.org/jira/browse/FLINK-29651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618362#comment-17618362
]
luoyuxia commented on FLINK-29651:
--
I would like to fix it.
> Code gen will fail when
[
https://issues.apache.org/jira/browse/FLINK-29651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29651:
-
Description:
Can be reproduced with the following code in Flink 1.15:
{code:java}
// testTable contai
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996444598
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-27715:
---
Assignee: Yunfeng Zhou (was: Huang Xingbo)
> Add more Python ML examples
> ---
[
https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-27715:
---
Assignee: Huang Xingbo
> Add more Python ML examples
> ---
>
>
luoyuxia created FLINK-29651:
Summary: Code gen will fail when the literal specified in user's
sql hasn't be escaped
Key: FLINK-29651
URL: https://issues.apache.org/jira/browse/FLINK-29651
Project: Flin
luoyuxia commented on PR #21058:
URL: https://github.com/apache/flink/pull/21058#issuecomment-1280130367
@wuchong Could you please help merge?
--
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
luoyuxia commented on PR #21061:
URL: https://github.com/apache/flink/pull/21061#issuecomment-1280130262
@wuchong Could you please help merge?
--
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-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-28985:
-
Fix Version/s: 1.17.0
> support create table like view
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-28985:
-
Fix Version/s: 1.16.1
(was: 1.17.0)
> support create table like view
> --
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-28985:
-
Affects Version/s: 1.16.0
> support create table like view
> --
>
>
flinkbot commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1280069811
## CI report:
* d7a7d794a4bc70fc7247382cbe179b51b6d2fa8c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
czy006 commented on code in PR #21012:
URL: https://github.com/apache/flink/pull/21012#discussion_r996454189
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java:
##
@@ -211,6 +218,37 @@ void testProvideJobId() throws Excep
[
https://issues.apache.org/jira/browse/FLINK-29566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618264#comment-17618264
]
Xin Hao commented on FLINK-29566:
-
Will submit a PR for that.
> Reschedule the cleanup
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996445729
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996444598
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
czy006 commented on code in PR #21012:
URL: https://github.com/apache/flink/pull/21012#discussion_r996443211
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java:
##
@@ -211,6 +218,37 @@ void testProvideJobId() throws Excep
czy006 commented on code in PR #21012:
URL: https://github.com/apache/flink/pull/21012#discussion_r996443211
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java:
##
@@ -211,6 +218,37 @@ void testProvideJobId() throws Excep
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996442270
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996440371
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r996440219
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
luyuan created FLINK-29650:
--
Summary: Printing the contents of error lines when parsing yaml
file may leak sensitive configuration values
Key: FLINK-29650
URL: https://issues.apache.org/jira/browse/FLINK-29650
[
https://issues.apache.org/jira/browse/FLINK-29633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29633:
---
Fix Version/s: kubernetes-operator-1.2.1
> Operator doesn't pass initialSavepointPath as fromSavepoi
gyfora merged PR #404:
URL: https://github.com/apache/flink-kubernetes-operator/pull/404
--
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
[
https://issues.apache.org/jira/browse/FLINK-14203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-14203.
Resolution: Won't Do
> Add an abstract class for mappers with rich model.
> --
[
https://issues.apache.org/jira/browse/FLINK-14204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-14204.
Resolution: Won't Do
> Add the model mapper for Gaussian Mixture model.
>
1 - 100 of 135 matches
Mail list logo
