flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
ZhijieYang commented on a change in pull request #17902:
URL: https://github.com/apache/flink/pull/17902#discussion_r759015168
##
File path: docs/content.zh/docs/ops/metrics.md
##
@@ -28,26 +28,26 @@ under the License.
# 指标
-Flink exposes a metric system that allows gather
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zhipeng93 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r759012504
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450930#comment-17450930
]
Arvid Heise commented on FLINK-24348:
-
Okay the script "testcontainers_start.sh" is
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-18634:
---
Assignee: (was: Fabian Paul)
> FlinkKafkaProducerITCase.testRecoverCommittedTransaction
[
https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-22342:
---
Assignee: (was: Fabian Paul)
> FlinkKafkaProducerITCase fails with producer leak
>
zhipeng93 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r759008827
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
zhipeng93 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r759007852
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zhipeng93 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r759003838
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17949:
URL: https://github.com/apache/flink/pull/17949#issuecomment-982158256
## CI report:
* a787ab271f51e7152894777d4740113b8070c011 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17949:
URL: https://github.com/apache/flink/pull/17949#issuecomment-982158256
## CI report:
* a787ab271f51e7152894777d4740113b8070c011 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
twalthr commented on a change in pull request #17878:
URL: https://github.com/apache/flink/pull/17878#discussion_r758998441
##
File path:
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DateSerializer.java
##
@@ -39,6 +41,11 @@
pub
[
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450921#comment-17450921
]
Arvid Heise commented on FLINK-22300:
-
Okay I see, so Flink would never evict the da
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17952:
URL: https://github.com/apache/flink/pull/17952#issuecomment-982356774
## CI report:
* 53241c7762943233cafc115a929c73a9e4abd878 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #17952:
URL: https://github.com/apache/flink/pull/17952#issuecomment-982357716
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
Airblader commented on pull request #17788:
URL: https://github.com/apache/flink/pull/17788#issuecomment-982357283
@shenzhu My PR was merged now. If you rebase I think those violations should
not show up anymore.
--
This is an automated message from the Apache Git Service.
To respond to
flinkbot commented on pull request #17952:
URL: https://github.com/apache/flink/pull/17952#issuecomment-982356774
## CI report:
* 53241c7762943233cafc115a929c73a9e4abd878 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-25047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25047.
Fix Version/s: 1.15.0
Resolution: Fixed
Fixed in master: a09cc4704433cb76b936a51b422d812e1a
[
https://issues.apache.org/jira/browse/FLINK-25011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25011:
---
Labels: pull-request-available (was: )
> Introduce VertexParallelismDecider
> -
twalthr closed pull request #17898:
URL: https://github.com/apache/flink/pull/17898
--
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-unsubsc
wanglijie95 opened a new pull request #17952:
URL: https://github.com/apache/flink/pull/17952
## What is the purpose of the change
Introduce VertexParallelismDecider and default implementation for adaptive
batch scheduler.
## Brief change log
Introduce VertexParallelismDeci
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17749:
URL: https://github.com/apache/flink/pull/17749#issuecomment-965029957
## CI report:
* 2ce453d313fcea2e1fae39900e6ba97b7a129246 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450912#comment-17450912
]
Arvid Heise commented on FLINK-24348:
-
I have not found out much yesterday. It is a
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
ZhijieYang commented on a change in pull request #17902:
URL: https://github.com/apache/flink/pull/17902#discussion_r758982717
##
File path: docs/content.zh/docs/ops/metrics.md
##
@@ -28,26 +28,26 @@ under the License.
# 指标
-Flink exposes a metric system that allows gather
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-25104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450908#comment-17450908
]
Hang Ruan commented on FLINK-25104:
---
I will add stoppingOffsetsInitializer setting in
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Yun Gao created FLINK-25105:
---
Summary: Enables final checkpoint by default
Key: FLINK-25105
URL: https://issues.apache.org/jira/browse/FLINK-25105
Project: Flink
Issue Type: Sub-task
Comp
[
https://issues.apache.org/jira/browse/FLINK-25105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-25105:
---
Assignee: Yun Gao
> Enables final checkpoint by default
> ---
>
>
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17951:
URL: https://github.com/apache/flink/pull/17951#issuecomment-982270439
## CI report:
* db68caf8d0edcbc8acb022cd2832d3ba56854eb9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangbaohua updated FLINK-25103:
---
Issue Type: Improvement (was: Bug)
> KeyedBroadcastProcessFunction run set 6, parallelism ValueStat
Hang Ruan created FLINK-25104:
-
Summary: Kafka table source cannot be used as bounded
Key: FLINK-25104
URL: https://issues.apache.org/jira/browse/FLINK-25104
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-25085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-25085:
Description: Add a dedicated thread pool in Endpoint to schedule tasks that
have a long delay such as Phys
[
https://issues.apache.org/jira/browse/FLINK-25085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-25085:
Summary: Add a scheduled thread pool in Endpoint and close it when job
terminates (was: Add a scheduled t
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zhipeng93 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r758973297
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
zhipeng93 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r758973059
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
flinkbot edited a comment on pull request #17902:
URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303
## CI report:
* 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
JasonLeeCoding commented on pull request #17690:
URL: https://github.com/apache/flink/pull/17690#issuecomment-982329624
@wuchong please help me take a look on this issue,thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
flinkbot edited a comment on pull request #17874:
URL: https://github.com/apache/flink/pull/17874#issuecomment-976109395
## CI report:
* 060e52ce536943d38d0acbf1899aecd5e3ac5ed8 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-25025:
Assignee: Huang Xingbo
> BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFin
[
https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450887#comment-17450887
]
Huang Xingbo commented on FLINK-25025:
--
Ok. I will take a look.
> BatchArrowPython
wangbaohua created FLINK-25103:
--
Summary: KeyedBroadcastProcessFunction run set 6, parallelism
ValueState variables A, could you tell me how to store in the six tasks A
Key: FLINK-25103
URL: https://issues.apache.o
[
https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450886#comment-17450886
]
Yun Gao commented on FLINK-24348:
-
I copied some detailed log found be [~arvid] in anot
[
https://issues.apache.org/jira/browse/FLINK-25088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450885#comment-17450885
]
Yun Gao commented on FLINK-25088:
-
Very thanks [~arvid] ! I'll also copy the above deta
zhipeng93 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r758968020
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-25102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450881#comment-17450881
]
Jingsong Lee commented on FLINK-25102:
--
Thanks [~gaoyunhaii] for reporting, I will
flinkbot edited a comment on pull request #17939:
URL: https://github.com/apache/flink/pull/17939#issuecomment-981420515
## CI report:
* 9ccb311aec0b5f0d14197c5de37a171ea15c6097 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450880#comment-17450880
]
Wenlong Lyu commented on FLINK-20370:
-
[~lincoln.86xy] Even sink implements Parallel
MyLanPangzi commented on pull request #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-982321397
@maosuhan This would be a good option for users if it could be converted
automatically. like this
PbCodegenSimpleDeserializer#codegen
```java
if(type instanc
flinkbot edited a comment on pull request #17684:
URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710
## CI report:
* 14a1758e9482b8f3319fb39775429d22f7a62b97 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16962:
URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061
## CI report:
* cd6fdccd8986b45c43d05bde8efc226a8487d139 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450878#comment-17450878
]
Yun Gao commented on FLINK-24935:
-
[https://dev.azure.com/apache-flink/apache-flink/_bui
[
https://issues.apache.org/jira/browse/FLINK-25102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450877#comment-17450877
]
Yun Gao commented on FLINK-25102:
-
Hi [~lzljs3620320] this issue seems to have the same
maosuhan commented on pull request #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-982317036
@MyLanPangzi Thanks for your feedback. I think it is doable, what about
adding a new option like 'protobuf.enum-as-int'?
--
This is an automated message from the Apache Git S
Yun Gao created FLINK-25102:
---
Summary: ParquetFileSystemITCase.testPartialDynamicPartition
failed on azure
Key: FLINK-25102
URL: https://issues.apache.org/jira/browse/FLINK-25102
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450876#comment-17450876
]
chenqizhu edited comment on FLINK-25099 at 11/30/21, 6:04 AM:
[
https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450876#comment-17450876
]
chenqizhu edited comment on FLINK-25099 at 11/30/21, 6:03 AM:
[
https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450876#comment-17450876
]
chenqizhu commented on FLINK-25099:
---
[~zuston] This is all the client logs
[^fli
[
https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-25099:
--
Attachment: flink-chenqizhu-client-hdfsn21n163.log
> flink on yarn Accessing two HDFS Clusters
> -
[
https://issues.apache.org/jira/browse/FLINK-24926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450874#comment-17450874
]
Yun Tang commented on FLINK-24926:
--
Thanks for the explanation [~lincoln.86xy].
You mi
[
https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23047:
Affects Version/s: 1.15.0
> CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure
> --
[
https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450872#comment-17450872
]
Yun Gao commented on FLINK-23047:
-
[https://dev.azure.com/apache-flink/apache-flink/_bui
Airblader commented on pull request #17788:
URL: https://github.com/apache/flink/pull/17788#issuecomment-982311002
@shenzhu I'm addressing those in https://github.com/apache/flink/pull/17898.
In the meantime for this PR you can add the violations to the file since you're
only exposing addi
shenzhu commented on pull request #17788:
URL: https://github.com/apache/flink/pull/17788#issuecomment-982309892
Hey @Airblader ,
I got some architecture tests failing for this PR, the failing messages are
as follows
```
java.lang.AssertionError: Architecture Violation [Priorit
[
https://issues.apache.org/jira/browse/FLINK-25101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25101:
Summary: FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce
failed due to CorrelationIdMisma
[
https://issues.apache.org/jira/browse/FLINK-25101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25101:
Labels: test-stability (was: )
> FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed
Yun Gao created FLINK-25101:
---
Summary:
FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to
Key: FLINK-25101
URL: https://issues.apache.org/jira/browse/FLINK-25101
Project: Flink
shenzhu commented on pull request #17919:
URL: https://github.com/apache/flink/pull/17919#issuecomment-982304022
> Hi @shenzhu I left a couple more comments, but overall the approach is not
100% correct, because it applies the trimming only when casting from string
types. It should also ap
Yun Gao created FLINK-25100:
---
Summary: RMQSourceITCase failed on azure due to
java.io.EOFException
Key: FLINK-25100
URL: https://issues.apache.org/jira/browse/FLINK-25100
Project: Flink
Issue Type
lindong28 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r758920274
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
lindong28 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r758920274
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java
##
@@ -0,0 +1,653 @@
+/*
+ * Licensed to the Ap
lindong28 commented on a change in pull request #28:
URL: https://github.com/apache/flink-ml/pull/28#discussion_r758946526
##
File path:
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java
##
@@ -0,0 +1,244 @@
+/*
+ * Licensed to the Apache S
flinkbot edited a comment on pull request #17950:
URL: https://github.com/apache/flink/pull/17950#issuecomment-982256290
## CI report:
* e8633bd19b6636319a85835ad9949754d93a9dbd Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
shenzhu commented on a change in pull request #17919:
URL: https://github.com/apache/flink/pull/17919#discussion_r758942835
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/StringToBinaryCastRule.java
##
@@ -45,6 +52,
[
https://issues.apache.org/jira/browse/FLINK-23390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450859#comment-17450859
]
Yun Gao commented on FLINK-23390:
-
[https://dev.azure.com/apache-flink/apache-flink/_bui
[
https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450853#comment-17450853
]
Junfan Zhang commented on FLINK-25099:
--
Could you make the log level debug and atta
1 - 100 of 575 matches
Mail list logo