flinkbot commented on PR #19876:
URL: https://github.com/apache/flink/pull/19876#issuecomment-1146539680
## CI report:
* 15425334700214c0c4822f0b8c37e15eacc8fe7b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27895:
---
Labels: pull-request-available (was: )
> Enable the CI test for Hive's 3.x
>
luoyuxia opened a new pull request, #19876:
URL: https://github.com/apache/flink/pull/19876
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-27895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27895:
-
Component/s: Build System / CI
> Enable the CI test for Hive's 3.x
>
[
https://issues.apache.org/jira/browse/FLINK-27895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17547906#comment-17547906
]
luoyuxia commented on FLINK-27895:
--
[~jark] Yes, it'll be my first priority.
> Enable the CI test for
[
https://issues.apache.org/jira/browse/FLINK-15854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-15854.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: 22f9a6d03f5337ffa4f322a526aecefba1539248
>
wuchong merged PR #18958:
URL: https://github.com/apache/flink/pull/18958
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-27895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17547897#comment-17547897
]
Jark Wu commented on FLINK-27895:
-
[~luoyuxia] could you support this as a high priority? I think this
[
https://issues.apache.org/jira/browse/FLINK-27895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27895:
Fix Version/s: 1.16.0
> Enable the CI test for Hive's 3.x
> --
>
>
wangyang0918 commented on PR #542:
URL: https://github.com/apache/flink-web/pull/542#issuecomment-1146521248
cc @gyfora I have addressed the comments and test the web-site locally.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
luoyuxia commented on PR #18958:
URL: https://github.com/apache/flink/pull/18958#issuecomment-1146507010
@wuchong I have opened the issue
[FLINK-27895](https://issues.apache.org/jira/browse/FLINK-27895).
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-27894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17547812#comment-17547812
]
luoyuxia commented on FLINK-27894:
--
Simliar issue to
luoyuxia created FLINK-27895:
Summary: Enable the CI test for Hive's 3.x
Key: FLINK-27895
URL: https://issues.apache.org/jira/browse/FLINK-27895
Project: Flink
Issue Type: Improvement
Miuler commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1146499549
@gyfora I already corrected the code
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Miuler commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1146460454
> @Miuler I looked into this a little and this is the only thing we need to
change for this to work (and make your test to pass):
>
> ```
> diff --git
Miuler commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r889415035
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -274,6 +278,89 @@
gyfora commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r889333575
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -274,6 +278,89 @@
gyfora commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r889333575
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -274,6 +278,89 @@
[
https://issues.apache.org/jira/browse/FLINK-27890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27890:
---
Fix Version/s: (was: 1.15.0)
> bug of SideOutputExample.java
>
[
https://issues.apache.org/jira/browse/FLINK-27894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17546186#comment-17546186
]
Biao Geng commented on FLINK-27894:
---
cc [~luoyuxia] have you ever met such error?
> Build
Biao Geng created FLINK-27894:
-
Summary: Build flink-connector-hive failed using Maven@3.8.5
Key: FLINK-27894
URL: https://issues.apache.org/jira/browse/FLINK-27894
Project: Flink
Issue Type:
gyfora commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1146109215
@Miuler I looked into this a little and this is the only thing we need to
change for this to work (and make your test to pass):
```
diff --git
afedulov commented on code in PR #19286:
URL: https://github.com/apache/flink/pull/19286#discussion_r889068627
##
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java:
##
@@ -227,6 +228,24 @@ public void testInvalidIgnoreParseError() {
XComp commented on code in PR #19807:
URL: https://github.com/apache/flink/pull/19807#discussion_r889021351
##
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunctionTest.java:
##
@@ -107,7 +107,7 @@ public void
afedulov commented on code in PR #19286:
URL: https://github.com/apache/flink/pull/19286#discussion_r889011653
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java:
##
@@ -206,6 +235,6 @@ public int hashCode() {
afedulov commented on code in PR #19286:
URL: https://github.com/apache/flink/pull/19286#discussion_r889011653
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java:
##
@@ -206,6 +235,6 @@ public int hashCode() {
afedulov commented on code in PR #19286:
URL: https://github.com/apache/flink/pull/19286#discussion_r889011653
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java:
##
@@ -206,6 +235,6 @@ public int hashCode() {
afedulov commented on code in PR #19286:
URL: https://github.com/apache/flink/pull/19286#discussion_r889011653
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java:
##
@@ -206,6 +235,6 @@ public int hashCode() {
wuchong commented on PR #18958:
URL: https://github.com/apache/flink/pull/18958#issuecomment-1146034953
@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.
wuchong commented on PR #18958:
URL: https://github.com/apache/flink/pull/18958#issuecomment-1146033650
> @wuchong We haven't enabled the CI test for Hive 3.x. Usually I wiil run
the test in my local manually for Hive 3.x with command `mvn test -Phive-3.1.1`
Could you open an issue
[
https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hector Miuler Malpica Gallegos updated FLINK-27889:
---
Description:
My FlinkDeployment was left with erros, when
Jeesmon Jacob created FLINK-27893:
-
Summary: Add additionalPrinterColumns for Job Status and
Reconciliation Status in CRDs
Key: FLINK-27893
URL: https://issues.apache.org/jira/browse/FLINK-27893
godfreyhe commented on code in PR #19286:
URL: https://github.com/apache/flink/pull/19286#discussion_r888967055
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java:
##
@@ -206,6 +235,6 @@ public int hashCode() {
XComp commented on PR #19807:
URL: https://github.com/apache/flink/pull/19807#issuecomment-1145988076
I see, thanks for clarification. I guess, you're refering to
[FLINK-25325](https://issues.apache.org/jira/browse/FLINK-25325). I'm just
wondering why there's not `flink-connectors-jdbc`
wangyang0918 commented on code in PR #542:
URL: https://github.com/apache/flink-web/pull/542#discussion_r888962011
##
_posts/2022-05-23-release-kubernetes-operator-1.0.0.md:
##
@@ -0,0 +1,123 @@
+---
+layout: post
+title: "Apache Flink Kubernetes Operator 1.0.0 Release
alpreu commented on PR #19807:
URL: https://github.com/apache/flink/pull/19807#issuecomment-1145981118
> @alpreu Sorry for replying that late, but what about also migrating from
junit4 to junit5 as part of that effort? Since we decided to go for
assertj/junit5 in general? What's the
XComp commented on PR #19807:
URL: https://github.com/apache/flink/pull/19807#issuecomment-1145971636
@alpreu Sorry for replying that late, but what about also migrating from
junit4 to junit5 as part of that effort? Since we decided to go for
assertj/junit5 in general? What's the
wangyang0918 commented on code in PR #542:
URL: https://github.com/apache/flink-web/pull/542#discussion_r888944134
##
_posts/2022-05-23-release-kubernetes-operator-1.0.0.md:
##
@@ -0,0 +1,123 @@
+---
+layout: post
+title: "Apache Flink Kubernetes Operator 1.0.0 Release
snuyanzin commented on PR #19873:
URL: https://github.com/apache/flink/pull/19873#issuecomment-1145958813
@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
metaswirl opened a new pull request, #19875:
URL: https://github.com/apache/flink/pull/19875
see https://github.com/apache/flink/pull/19852
--
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
flinkbot commented on PR #19874:
URL: https://github.com/apache/flink/pull/19874#issuecomment-1145942574
## CI report:
* d3d6c3fdc59c035b9d75125bcfdc9a93e4376e75 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19875:
URL: https://github.com/apache/flink/pull/19875#issuecomment-1145942675
## CI report:
* 94acd64785eab2f2cedfc006b0bfca4f27a717c4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
metaswirl opened a new pull request, #19874:
URL: https://github.com/apache/flink/pull/19874
see https://github.com/apache/flink/pull/19852
--
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
gyfora commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145936781
@Miuler i will take a look later tonight to see what is the minimal fix that
we need. Then we can discuss if we want to refactor the cancel in a separate
ticket maybe
afedulov commented on PR #19286:
URL: https://github.com/apache/flink/pull/19286#issuecomment-1145918386
@godfreyhe I reverted the optimization and propose to merge the pushdown
functionality as is.
--
This is an automated message from the Apache Git Service.
To respond to the message,
echauchot commented on PR #19680:
URL: https://github.com/apache/flink/pull/19680#issuecomment-1145913812
@zentol I'm done addressing your last round of comments, PTAL. I hope now it
is fine and we will not need another round of review.
--
This is an automated message from the Apache Git
Miuler commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145911680
> Do you have a yaml that I can use to reproduce this? I am still not
convinced that we need to refactor etc
In the test is the real yaml, but hide some names, the
echauchot commented on code in PR #19680:
URL: https://github.com/apache/flink/pull/19680#discussion_r887888690
##
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java:
##
@@ -17,130 +17,160 @@
Miuler commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r84192
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -354,8 +355,54 @@ protected
gyfora commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145900109
And please don’t get me wrong, all I am trying to do is keep this as simple
as possible :) I have already spent quite a lot of time simplifying these
methods and the flow
gyfora commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145898541
Do you have a yaml that I can use to reproduce this? I am still not
convinced that we need to refactor etc
--
This is an automated message from the Apache Git Service.
Miuler commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r78032
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/LastReconciledSpecException.java:
##
@@ -0,0 +1,25 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545674#comment-17545674
]
Ben Carlton edited comment on FLINK-27887 at 6/3/22 12:03 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545840#comment-17545840
]
Ben Carlton commented on FLINK-27887:
-
Thank you Martijn! I've created an infrastructure issue as
echauchot commented on code in PR #19680:
URL: https://github.com/apache/flink/pull/19680#discussion_r36440
##
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java:
##
@@ -17,130 +17,160 @@
Miuler commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r77851
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -354,8 +355,54 @@ protected
Miuler commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145889080
This log was sent to me by sysadmin, and when I do the
Miuler commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145875377
> @Miuler could you please provide a detailed description of what this
change does specifically and what is the error scenario that we are handling
here?
>
> This
[
https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27887.
--
Resolution: Information Provided
[~carlton.ibm] That's weird. As mentioned in the Slack
morhidi opened a new pull request, #254:
URL: https://github.com/apache/flink-kubernetes-operator/pull/254
This PR enables handling namespace changes via Dynamically Operator
Configuration through the config option:
`kubernetes.operator.watched.namespaces`. Watched namespaces originally
echauchot commented on code in PR #19680:
URL: https://github.com/apache/flink/pull/19680#discussion_r36440
##
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java:
##
@@ -17,130 +17,160 @@
morhidi commented on PR #253:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/253#issuecomment-1145840078
cc @Aitozi
--
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
echauchot commented on code in PR #19680:
URL: https://github.com/apache/flink/pull/19680#discussion_r36440
##
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java:
##
@@ -17,130 +17,160 @@
[
https://issues.apache.org/jira/browse/FLINK-27892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545829#comment-17545829
]
Matyas Orhidi edited comment on FLINK-27892 at 6/3/22 10:47 AM:
Can be
[
https://issues.apache.org/jira/browse/FLINK-27892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545829#comment-17545829
]
Matyas Orhidi commented on FLINK-27892:
---
Can be reproduced by submitting the same session jobs
[
https://issues.apache.org/jira/browse/FLINK-27892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27892:
---
Labels: pull-request-available (was: )
> More than 1 secondary resource related to primary
morhidi opened a new pull request, #253:
URL: https://github.com/apache/flink-kubernetes-operator/pull/253
Creating the primary cache indexers using composite keys [name,namespace] in
EventSourceUtils
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-27892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-27892:
--
Assignee: Matyas Orhidi
> More than 1 secondary resource related to primary
>
[
https://issues.apache.org/jira/browse/FLINK-27888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CodeRap updated FLINK-27888:
Attachment: flink_not_contain_jar.png
> SQL Error in Flink1.15
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-27888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545813#comment-17545813
]
CodeRap commented on FLINK-27888:
-
Your function or class does not packaged into the flink-sql-demo.jar
[
https://issues.apache.org/jira/browse/FLINK-27892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-27892:
--
Component/s: Kubernetes Operator
Fix Version/s: kubernetes-operator-1.1.0
Matyas Orhidi created FLINK-27892:
-
Summary: More than 1 secondary resource related to primary
Key: FLINK-27892
URL: https://issues.apache.org/jira/browse/FLINK-27892
Project: Flink
Issue
flinkbot commented on PR #19873:
URL: https://github.com/apache/flink/pull/19873#issuecomment-1145780540
## CI report:
* 9372b26cc4bd66b1d3ac1d589a60d142c055cd3e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27891:
---
Labels: pull-request-available (was: )
> Add ARRAY_APPEND and ARRAY_PREPEND supported in
snuyanzin opened a new pull request, #19873:
URL: https://github.com/apache/flink/pull/19873
## What is the purpose of the change
This is an implementation of `ARRAY_APPEND` and `ARRAY_PREPEND` inspired by
https://github.com/apache/flink/pull/19543
## Brief change log
-
gyfora commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145773156
In addition I would like to kindly ask you to not include any refactorings
with this fix initially. This will help us understand the problem your solution
better.
Sergey Nuyanzin created FLINK-27891:
---
Summary: Add ARRAY_APPEND and ARRAY_PREPEND supported in SQL &
Table API
Key: FLINK-27891
URL: https://issues.apache.org/jira/browse/FLINK-27891
Project: Flink
mbalassi commented on PR #251:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/251#issuecomment-1145766704
Hi @chethanuk-plutoflume,
Thank you for your first contribution to the Flink Kubernetes Operator.
Usually we ask for creating a ticket in our
gyfora commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r888767237
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -354,8 +355,54 @@ protected
gyfora commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r888762251
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/LastReconciledSpecException.java:
##
@@ -0,0 +1,25 @@
+/*
+ *
gyfora commented on code in PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#discussion_r888760743
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -354,8 +355,54 @@ protected
gyfora commented on PR #252:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/252#issuecomment-1145749943
@Miuler could you please provide a detailed description of what this change
does specifically and what is the error scenario that we are handling here?
This is a
yunfengzhou-hub commented on code in PR #97:
URL: https://github.com/apache/flink-ml/pull/97#discussion_r888753223
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshot.java:
##
@@ -90,18 +90,18 @@ public void writeTo(OutputStream
yunfengzhou-hub commented on code in PR #97:
URL: https://github.com/apache/flink-ml/pull/97#discussion_r888749310
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheWriter.java:
##
@@ -19,127 +19,104 @@
package
yunfengzhou-hub commented on code in PR #97:
URL: https://github.com/apache/flink-ml/pull/97#discussion_r888745233
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentWriter.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache
yunfengzhou-hub commented on code in PR #97:
URL: https://github.com/apache/flink-ml/pull/97#discussion_r888738791
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentWriter.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-27884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545770#comment-17545770
]
Etienne Chauchot commented on FLINK-27884:
--
First difficulty that I can see is with guava dep
flinkbot commented on PR #19872:
URL: https://github.com/apache/flink/pull/19872#issuecomment-1145722323
## CI report:
* e14b0ad4b01cebc06340f00d52fd56948a26ff05 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yunfengzhou-hub commented on code in PR #97:
URL: https://github.com/apache/flink-ml/pull/97#discussion_r888730986
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java:
##
@@ -182,4 +307,79 @@ public void snapshotState(StateSnapshotContext
whitecloud6688 opened a new pull request, #19872:
URL: https://github.com/apache/flink/pull/19872
## What is the purpose of the change
通过 flink写有https加密和证书认证的 elasticsearch 7 失败，日志如下，请问需要加什么参数？或者是配置什么呢？
建表语句：
CREATE TABLE orders_es (
order_id INT COMMENT '订单id',
echauchot commented on code in PR #19680:
URL: https://github.com/apache/flink/pull/19680#discussion_r887888690
##
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java:
##
@@ -17,130 +17,160 @@
echauchot commented on code in PR #19680:
URL: https://github.com/apache/flink/pull/19680#discussion_r887784305
##
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java:
##
@@ -17,130 +17,160 @@
yunfengzhou-hub commented on code in PR #97:
URL: https://github.com/apache/flink-ml/pull/97#discussion_r888724585
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java:
##
@@ -182,4 +307,79 @@ public void snapshotState(StateSnapshotContext
XiaoWen Wei created FLINK-27890:
---
Summary: bug of SideOutputExample.java
Key: FLINK-27890
URL: https://issues.apache.org/jira/browse/FLINK-27890
Project: Flink
Issue Type: Bug
94 matches
Mail list logo
