[
https://issues.apache.org/jira/browse/FLINK-24568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429531#comment-17429531
]
Zhao Yihao commented on FLINK-24568:
I can fix it! haha (:
> Configuration equals m
[
https://issues.apache.org/jira/browse/FLINK-24568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429536#comment-17429536
]
Yihao Zhao commented on FLINK-24568:
I can fix it !
> Configuration equals method
[
https://issues.apache.org/jira/browse/FLINK-24568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yihao Zhao updated FLINK-24568:
---
Comment: was deleted
(was: I can fix it !
)
> Configuration equals method does not properly check
[
https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429247#comment-17429247
]
Yuepeng Pan edited comment on FLINK-22315 at 10/16/21, 9:48 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429565#comment-17429565
]
Yuepeng Pan commented on FLINK-24489:
-
Hi, [~dwysakowicz], [~airblader], [~twalthr].
[
https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429566#comment-17429566
]
Jark Wu commented on FLINK-22315:
-
[~RocMarshal] yes, it should support.
> Support ADD
lindong28 commented on a change in pull request #10:
URL: https://github.com/apache/flink-ml/pull/10#discussion_r730194806
##
File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java
##
@@ -97,17 +100,17 @@ public PipelineModel fit(Table... inputs) {
SteNicholas opened a new pull request #17500:
URL: https://github.com/apache/flink/pull/17500
## What is the purpose of the change
*According to the experience of other frameworks, snappy compression is
recommended by default, which will reduce the file size.This does not affect
rea
flinkbot edited a comment on pull request #17499:
URL: https://github.com/apache/flink/pull/17499#issuecomment-944260234
--
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-24564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24564:
---
Labels: pull-request-available (was: )
> Change the default compression to snappy for parqu
flinkbot edited a comment on pull request #17502:
URL: https://github.com/apache/flink/pull/17502#issuecomment-944431678
--
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-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24538:
---
Labels: pull-request-available test-stability (was: test-stability)
> ZooKeeperLeaderElecti
flinkbot edited a comment on pull request #17474:
URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500
--
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
Airblader opened a new pull request #17499:
URL: https://github.com/apache/flink/pull/17499
## What is the purpose of the change
The affected test was written due to a 64kB compilation issue. While that
issue is fixed, there seems to be a limitation in Janino that can trigger a
fals
flinkbot edited a comment on pull request #17345:
URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717
--
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
flinkbot edited a comment on pull request #17443:
URL: https://github.com/apache/flink/pull/17443#issuecomment-939267795
--
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
flinkbot edited a comment on pull request #17482:
URL: https://github.com/apache/flink/pull/17482#issuecomment-943277366
## CI report:
* 602af52c64a2dc57ff6e656253dd64b45cd53335 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
xmarker opened a new pull request #17502:
URL: https://github.com/apache/flink/pull/17502
## What is the purpose of the change
*Fix ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten
fails with NPE*
## Brief change log
- *Use a loca
[
https://issues.apache.org/jira/browse/FLINK-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14954:
---
Labels: pull-request-available (was: )
> Publish OpenAPI specification of REST Monitoring A
sjwiesman commented on a change in pull request #17487:
URL: https://github.com/apache/flink/pull/17487#discussion_r729896428
##
File path:
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/DataStreamJob.java
##
@@ -21,44 +21,45 @@
im
flinkbot edited a comment on pull request #17473:
URL: https://github.com/apache/flink/pull/17473#issuecomment-943109733
--
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-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24516:
---
Labels: pull-request-available (was: )
> Modernize Maven Archetype
> --
flinkbot edited a comment on pull request #17488:
URL: https://github.com/apache/flink/pull/17488#issuecomment-943918958
## CI report:
* 0982a65fe89288ee43368a852d8b7f3deca6a12a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17466:
URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642
## CI report:
* 5126c857d00a33ed34a3b1a8b610b89e4e9193d7 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zoltar9264 commented on pull request #17443:
URL: https://github.com/apache/flink/pull/17443#issuecomment-944241791
--
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 unsub
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
--
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
flinkbot edited a comment on pull request #17497:
URL: https://github.com/apache/flink/pull/17497#issuecomment-944172373
## CI report:
* 3889238f09abd6c6e58c8c57ad03c8bea5ea10eb Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21406:
---
Labels: auto-deprioritized-major pull-request-available (was:
auto-deprioritized-major)
>
[
https://issues.apache.org/jira/browse/FLINK-24563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24563:
---
Labels: pull-request-available (was: )
> Comparing timstamp_ltz with random string throws N
gaoyunhaii commented on a change in pull request #18:
URL: https://github.com/apache/flink-ml/pull/18#discussion_r730201843
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache Sof
CrynetLogistics commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r729783117
##
File path:
flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/async/KinesisDataStreamsSinkWriter.java
##
flinkbot edited a comment on pull request #17498:
URL: https://github.com/apache/flink/pull/17498#issuecomment-944209637
--
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
flinkbot edited a comment on pull request #17487:
URL: https://github.com/apache/flink/pull/17487#issuecomment-943762621
--
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
flinkbot edited a comment on pull request #17481:
URL: https://github.com/apache/flink/pull/17481#issuecomment-943273916
## CI report:
* 9f452d38c5cc26fb1388e4e96ef0acc2d3e50b57 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17500:
URL: https://github.com/apache/flink/pull/17500#issuecomment-944278328
--
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
sjwiesman commented on a change in pull request #276:
URL: https://github.com/apache/flink-statefun/pull/276#discussion_r729895780
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java
##
@@ -94,6 +91,2
flinkbot commented on pull request #17500:
URL: https://github.com/apache/flink/pull/17500#issuecomment-944278328
--
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 unsubsc
JingGe opened a new pull request #17501:
URL: https://github.com/apache/flink/pull/17501
## What is the purpose of the change
The goal of this PR to provide AvroParquetRecordFormat implementation to
read avro GenericRecords from parquet via the new Flink FileSource.
This is t
flinkbot commented on pull request #17498:
URL: https://github.com/apache/flink/pull/17498#issuecomment-944211479
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
flinkbot commented on pull request #17499:
URL: https://github.com/apache/flink/pull/17499#issuecomment-944260008
--
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 unsubsc
xhumanoid commented on pull request #16190:
URL: https://github.com/apache/flink/pull/16190#issuecomment-944283253
@zentol during migration java files `FlinkChillPackageRegistrar.java` and
`PriorityQueueSerializer.java` was moved in incorrect `src/main/scala` folder
--
This is an automat
flinkbot edited a comment on pull request #17496:
URL: https://github.com/apache/flink/pull/17496#issuecomment-944116990
## CI report:
* dbf464b6017b241d4862402caba14a7681b64335 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
--
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 unsubsc
[
https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24562:
---
Labels: pull-request-available (was: )
> YarnResourceManagerDriverTest should not use Conta
flinkbot edited a comment on pull request #17411:
URL: https://github.com/apache/flink/pull/17411#issuecomment-933425378
## CI report:
* 13188c09af0fd707f0c15a83819ebc899fbaeb6a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
RocMarshal commented on pull request #17463:
URL: https://github.com/apache/flink/pull/17463#issuecomment-944947844
Hi, @dianfu , here is a minor typo. Would you like to help me to check it ?
Thank you very much.
--
This is an automated message from the Apache Git Service.
To respond to
flinkbot edited a comment on pull request #17465:
URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244
## CI report:
* e501f19931561b4c685f5064857794c690ff1d28 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
sjwiesman commented on pull request #17487:
URL: https://github.com/apache/flink/pull/17487#issuecomment-944371238
Updated with E2E fixes
--
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
flinkbot commented on pull request #17502:
URL: https://github.com/apache/flink/pull/17502#issuecomment-944431248
--
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 unsubsc
zhipeng93 commented on a change in pull request #18:
URL: https://github.com/apache/flink-ml/pull/18#discussion_r730339576
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed to the Apache So
zhipeng93 commented on a change in pull request #18:
URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340195
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperator.java
##
@@ -0,0 +1,170 @@
+/*
+ *
zhipeng93 commented on a change in pull request #18:
URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340233
##
File path: flink-ml-lib/pom.xml
##
@@ -65,6 +71,44 @@ under the License.
core
1.1.2
+
+ org.apache.flink
+ flink-clien
zhipeng93 commented on a change in pull request #18:
URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340268
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache Soft
zhipeng93 commented on a change in pull request #18:
URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340287
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache Soft
zhipeng93 commented on a change in pull request #18:
URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340357
##
File path:
flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache Soft
55 matches
Mail list logo