wangyang0918 commented on PR #199:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/199#issuecomment-1123255675
I get your point and will finish the review today. Let's keep an eye on the
java-operator-sdk to see whether on-the-fly status updates could also be
supported :)
-
[
https://issues.apache.org/jira/browse/FLINK-27048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27048.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: a93f2bee5a135491c7ce79e46a55a2
MartijnVisser merged PR #19377:
URL: https://github.com/apache/flink/pull/19377
--
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
[
https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-27450:
--
Assignee: tartarus
> [JDK 11] Hive SessionState can't be initialized due to classload
[
https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27450.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: ba9af5fbbf7eb755b0ee564a971513
MartijnVisser merged PR #19608:
URL: https://github.com/apache/flink/pull/19608
--
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
JingsongLi commented on code in PR #113:
URL: https://github.com/apache/flink-table-store/pull/113#discussion_r869926081
##
flink-table-store-hive/pom.xml:
##
@@ -0,0 +1,626 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instanc
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27483:
--
Assignee: Fuyao Li
> Support adding custom HTTP header for HTTP based Jar fetch
> ---
JingsongLi commented on code in PR #113:
URL: https://github.com/apache/flink-table-store/pull/113#discussion_r867465627
##
flink-table-store-hive/src/main/java/org/apache/flink/table/store/JobConfWrapper.java:
##
@@ -0,0 +1,195 @@
+/*
+ * Licensed to the Apache Software Foundat
gyfora commented on PR #199:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/199#issuecomment-1123245220
@wangyang0918 I would not rush the ConfigMap change for the following
reasons:
- It's not completely clear to me what should go into status and what in
the configm
Airblader commented on code in PR #18868:
URL: https://github.com/apache/flink/pull/18868#discussion_r869918112
##
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.ts:
##
@@ -16,45 +16,90 @@
* limitations under the License.
*/
-import
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534696#comment-17534696
]
Aitozi commented on FLINK-27483:
Yes, I have not seen you have an initial PR just now, y
[
https://issues.apache.org/jira/browse/FLINK-27565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534694#comment-17534694
]
Ingo Bürk edited comment on FLINK-27565 at 5/11/22 6:27 AM:
[
https://issues.apache.org/jira/browse/FLINK-27565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk resolved FLINK-27565.
---
Fix Version/s: 1.16.0
Resolution: Fixed
> Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime
[
https://issues.apache.org/jira/browse/FLINK-27565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534694#comment-17534694
]
Ingo Bürk commented on FLINK-27565:
---
Resolved on master
commit 1e980a33e76c9725f54579
[
https://issues.apache.org/jira/browse/FLINK-27565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27565:
---
Labels: pull-request-available (was: )
> Bump minimist from 1.2.5 to 1.2.6 in /flink-runtim
JingsongLi commented on code in PR #107:
URL: https://github.com/apache/flink-table-store/pull/107#discussion_r869914759
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/DataFileMetaSerializer.java:
##
@@ -48,27 +42,25 @@ public RowData toRow(DataFi
Airblader merged PR #19501:
URL: https://github.com/apache/flink/pull/19501
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534692#comment-17534692
]
Yang Wang commented on FLINK-27495:
---
[~gyfora] Following the discussion above, do you
gyfora commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r869906352
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorSessionJobConfigOptions.java:
##
@@ -0,0 +1,44 @
gyfora commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r869905741
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorSessionJobConfigOptions.java:
##
@@ -0,0 +1,44 @
wangyang0918 commented on PR #199:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/199#issuecomment-112322
Using the java-operator-sdk v3 for robust status updates and an extra
ConfigMap per FlinkDeployment for the on-the-fly status updates makes a lot of
sense to me.
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r869903829
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorSessionJobConfigOptions.java:
##
@@ -0,0 +1
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r869897712
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorSessionJobConfigOptions.java:
##
@@ -0,0 +1
tsreaper commented on code in PR #107:
URL: https://github.com/apache/flink-table-store/pull/107#discussion_r869889027
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/DataFileMetaSerializer.java:
##
@@ -48,27 +42,25 @@ public RowData toRow(DataFile
gyfora commented on PR #199:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/199#issuecomment-1123201475
Thanks for raising this @wangyang0918
To be very specific here, the `statusCache` is needed because the
java-operator-sdk-framework does not know about the status updat
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534677#comment-17534677
]
Gyula Fora commented on FLINK-27483:
[~aitozi] if you haven't started on this yet I
JingsongLi merged PR #531:
URL: https://github.com/apache/flink-web/pull/531
--
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
gyfora commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r869878137
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorSessionJobConfigOptions.java:
##
@@ -0,0 +1,44 @
JingsongLi commented on PR #531:
URL: https://github.com/apache/flink-web/pull/531#issuecomment-1123196136
Thanks everyone for your review~ Merging...
--
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
openinx commented on code in PR #115:
URL: https://github.com/apache/flink-table-store/pull/115#discussion_r869863607
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/writer/AppendOnlyWriter.java:
##
@@ -0,0 +1,169 @@
+/*
+ * Licensed to the Apache Softw
fredia commented on code in PR #19502:
URL: https://github.com/apache/flink/pull/19502#discussion_r869854865
##
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html:
##
@@ -550,6 +550,19 @@
{{ checkPointConfig['checkpoints_a
wangyang0918 commented on PR #199:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/199#issuecomment-1123160841
I want to confirm what is the long term solution. Do we want to keep the
manual status update or leverage the java-operator-sdk v3 to avoid the
conflicts?
The
[
https://issues.apache.org/jira/browse/FLINK-27507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534662#comment-17534662
]
Shubham Bansal commented on FLINK-27507:
[~danderson] I have raised the diff. Re
[
https://issues.apache.org/jira/browse/FLINK-27507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27507:
---
Labels: pull-request-available starter (was: starter)
> Update operations playground for 1.
shba24 opened a new pull request, #30:
URL: https://github.com/apache/flink-playgrounds/pull/30
Beyond a straightforward update to 1.14.4, I also
- docker image for maven:3.6-jdk-8-slim is not available anymore. so
increased the version to maven:3.8-jdk-8-slim
- updated the kafka d
Tartarus0zm commented on PR #19608:
URL: https://github.com/apache/flink/pull/19608#issuecomment-1123146246
> @Tartarus0zm Can you please squash commits & rebase? I can merge it
afterwards
@MartijnVisser yes, I has squash commits & rebase. Let's wait for CI to
pass. thanks
--
Thi
weibozhao commented on code in PR #86:
URL: https://github.com/apache/flink-ml/pull/86#discussion_r869841348
##
flink-ml-lib/src/test/java/org/apache/flink/ml/evaluation/BinaryClassificationEvaluatorTest.java:
##
@@ -0,0 +1,245 @@
+/*
+ * Licensed to the Apache Software Foundati
flinkbot commented on PR #19697:
URL: https://github.com/apache/flink/pull/19697#issuecomment-1123140982
## CI report:
* 225a161e2c921967cbe726a12d653864b73f2eb5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533700#comment-17533700
]
Jingsong Lee edited comment on FLINK-27542 at 5/11/22 3:25 AM:
---
wanglijie95 commented on PR #19686:
URL: https://github.com/apache/flink/pull/19686#issuecomment-1123139536
@wangyang0918 Thanks for review. I have created a backport PR to
release-1.15: https://github.com/apache/flink/pull/19697
--
This is an automated message from the Apache Git Servi
[
https://issues.apache.org/jira/browse/FLINK-27542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reopened FLINK-27542:
--
> Add end to end tests for Hive to read external table store files
> -
wanglijie95 opened a new pull request, #19697:
URL: https://github.com/apache/flink/pull/19697
## What is the purpose of the change
Fix yarn doc page display error.
## Verifying this change
This change is a doc fix without any test coverage. This error was
introduced in https://
JingsongLi merged PR #118:
URL: https://github.com/apache/flink-table-store/pull/118
--
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...@
Jason Kania created FLINK-27568:
---
Summary: Cannot submit JobGraph
Key: FLINK-27568
URL: https://issues.apache.org/jira/browse/FLINK-27568
Project: Flink
Issue Type: Bug
Affects Versions: 1.
tsreaper commented on code in PR #115:
URL: https://github.com/apache/flink-table-store/pull/115#discussion_r869830332
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/writer/AppendOnlyWriter.java:
##
@@ -0,0 +1,169 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534653#comment-17534653
]
Fuyao Li commented on FLINK-27483:
--
Thanks [~aitozi] . You can go ahead and implement t
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534627#comment-17534627
]
Fuyao Li edited comment on FLINK-27483 at 5/11/22 2:56 AM:
---
I
yangjunhan commented on PR #18868:
URL: https://github.com/apache/flink/pull/18868#issuecomment-1123126193
@Airblader @gaoyunhaii Thanks for the advice. I will pay more attention on
such problems from now on. Both mentioned issues has been taken care of. If no
further problems, I think this
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27483:
---
Labels: pull-request-available (was: )
> Support adding custom HTTP header for HTTP based J
FuyaoLi2017 opened a new pull request, #202:
URL: https://github.com/apache/flink-kubernetes-operator/pull/202
Add session job configuration field. Allow user to add custom HTTP header if
they use HTTP based Jar fetcher for session jobs.
This is not tested. Might need to refactor code
tsreaper opened a new pull request, #118:
URL: https://github.com/apache/flink-table-store/pull/118
Currently e2e tests are not stable and may fail with `Container did not
start correctly`. This is because docker images are occupying host machine
ports now. As tests may run in parallel, doc
Myasuka commented on code in PR #19502:
URL: https://github.com/apache/flink/pull/19502#discussion_r869823074
##
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html:
##
@@ -550,6 +550,19 @@
{{ checkPointConfig['checkpoints_
wangyang0918 commented on PR #19686:
URL: https://github.com/apache/flink/pull/19686#issuecomment-1123113560
@wanglijie95 Could you please also create a backport PR to release-1.15?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/FLINK-27563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-27563:
-
Assignee: Lijie Wang
> Resource Providers - Yarn doc page has minor display error
> --
flinkbot commented on PR #19696:
URL: https://github.com/apache/flink/pull/19696#issuecomment-1123110067
## CI report:
* 05e5e39781179497fde6d2a2be4e5a4073082beb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27271:
---
Labels: pull-request-available (was: )
> Add globalwindows window allocator
> -
cun8cun8 opened a new pull request, #19696:
URL: https://github.com/apache/flink/pull/19696
## 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 o
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534645#comment-17534645
]
Aitozi commented on FLINK-27483:
+1 for this solution, I will open a PR for it this week
[
https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534642#comment-17534642
]
Ran Tao edited comment on FLINK-22793 at 5/11/22 2:16 AM:
--
[~ni
[
https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534642#comment-17534642
]
Ran Tao commented on FLINK-22793:
-
[~nicholasjiang] Hi, jiang, I both have some ideas an
[
https://issues.apache.org/jira/browse/FLINK-26939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534641#comment-17534641
]
jackwangcs commented on FLINK-26939:
Hi [~lsy] , [~twalthr] could you assign this t
yunfengzhou-hub commented on code in PR #86:
URL: https://github.com/apache/flink-ml/pull/86#discussion_r869795956
##
flink-ml-lib/src/test/java/org/apache/flink/ml/evaluation/BinaryClassificationEvaluatorTest.java:
##
@@ -0,0 +1,245 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/FLINK-26939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackwangcs updated FLINK-26939:
---
Attachment: image-2022-05-11-09-51-21-400.png
> Add TRANSLATE supported in SQL & Table API
> ---
openinx commented on code in PR #115:
URL: https://github.com/apache/flink-table-store/pull/115#discussion_r869802293
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/writer/AppendOnlyWriter.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-17295:
--
Assignee: Zhu Zhu
> Refactor the ExecutionAttemptID to consist of ExecutionVertexID and
> at
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534629#comment-17534629
]
Yangze Guo commented on FLINK-17295:
[~zhuzh] Assigned it to you. I'm willing to hel
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534627#comment-17534627
]
Fuyao Li edited comment on FLINK-27483 at 5/11/22 1:01 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534627#comment-17534627
]
Fuyao Li commented on FLINK-27483:
--
I agree with Gyula, I guess we can create a session
flinkbot commented on PR #19695:
URL: https://github.com/apache/flink/pull/19695#issuecomment-1123059918
## CI report:
* e0ab4d4e7e1528a36dad9beea6c221c6057c8856 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuzhuang2017 commented on PR #19695:
URL: https://github.com/apache/flink/pull/19695#issuecomment-1123057813
@MartijnVisser , Sorry to bother you, can you help me review this pr? Thank
you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
liuzhuang2017 opened a new pull request, #19695:
URL: https://github.com/apache/flink/pull/19695
## What is the purpose of the change
- **This is the English document:**
![image](https://user-images.githubusercontent.com/95120044/167746698-b463fac4-7311-41d7-a1d3-c764e947f51c.p
mans2singh commented on PR #19542:
URL: https://github.com/apache/flink/pull/19542#issuecomment-1123051731
@leonardBang @wuchong - Can you please review this minor docs update PR ?
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-27509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534618#comment-17534618
]
Shubham Bansal commented on FLINK-27509:
[~danderson] I have raised the diff. Re
[
https://issues.apache.org/jira/browse/FLINK-27509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27509:
---
Labels: pull-request-available starter (was: starter)
> Update table walkthrough playground
shba24 opened a new pull request, #29:
URL: https://github.com/apache/flink-playgrounds/pull/29
Beyond a straightforward update to 1.14.4, I also
- set the kafka consumer startup mode to 'earliest-offset' because of
[FLINK-24277](https://issues.apache.org/jira/browse/FLINK-24277)
-
[
https://issues.apache.org/jira/browse/FLINK-26773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534616#comment-17534616
]
Jonathan Lazarus commented on FLINK-26773:
--
I have a solution, involving insert
[
https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-27255.
--
Resolution: Fixed
> Flink-avro does not support serialization and deserialization of avro sche
[
https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-27255:
-
Fix Version/s: 1.16.0
> Flink-avro does not support serialization and deserialization of avro sc
tweise commented on PR #19645:
URL: https://github.com/apache/flink/pull/19645#issuecomment-1123005232
@haizhou-zhao thanks for the contribution! Would you like to open back port
PRs for the release 1.14 and 1.15 release branches?
--
This is an automated message from the Apache Git Servic
tweise merged PR #19645:
URL: https://github.com/apache/flink/pull/19645
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-27435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534609#comment-17534609
]
Thomas Weise commented on FLINK-27435:
--
[~gyfora] [~wangyang0918] I'm considering a
[
https://issues.apache.org/jira/browse/FLINK-27435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reassigned FLINK-27435:
Assignee: Thomas Weise
> Kubernetes Operator keeps savepoint history
> --
nryanov commented on PR #19517:
URL: https://github.com/apache/flink/pull/19517#issuecomment-1122972828
@MartijnVisser Fixed commit message. Also checked documentation in
[master](https://github.com/apache/flink/blob/master/docs/content/docs/connectors/datastream/kafka.md#deserializer)
brac
tweise commented on PR #19645:
URL: https://github.com/apache/flink/pull/19645#issuecomment-1122950961
@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
MartijnVisser commented on PR #19377:
URL: https://github.com/apache/flink/pull/19377#issuecomment-1122794396
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534542#comment-17534542
]
Gyula Fora commented on FLINK-27495:
Basically using the rest API in Flink 1.15 allo
[
https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534540#comment-17534540
]
Gyula Fora edited comment on FLINK-27495 at 5/10/22 7:04 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534540#comment-17534540
]
Gyula Fora commented on FLINK-27495:
Seems like I forgot to mention that I am talkin
[
https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534537#comment-17534537
]
Thomas Weise commented on FLINK-27495:
--
Hi [~gyfora] can we detail how the REST API
afedulov commented on code in PR #19660:
URL: https://github.com/apache/flink/pull/19660#discussion_r869513703
##
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactoryTest.java:
##
@@ -21
[
https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534490#comment-17534490
]
Alexis Sarda-Espinosa edited comment on FLINK-27504 at 5/10/22 5:28 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534490#comment-17534490
]
Alexis Sarda-Espinosa commented on FLINK-27504:
---
I did read the leveled co
[
https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-26588.
Resolution: Resolved
> Translate the new CAST documentation to Chinese
> -
[
https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-26588:
---
Fix Version/s: 1.16.0
> Translate the new CAST documentation to Chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534087#comment-17534087
]
Leonard Xu edited comment on FLINK-26588 at 5/10/22 4:51 PM:
-
leonardBang merged PR #19689:
URL: https://github.com/apache/flink/pull/19689
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-23633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534465#comment-17534465
]
Xinbin Huang commented on FLINK-23633:
--
[~thw] it would be great to assign the issu
wanglijie95 commented on PR #19686:
URL: https://github.com/apache/flink/pull/19686#issuecomment-1122607612
@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 commen
zhipeng93 commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r868883335
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java:
##
@@ -0,0 +1,382 @@
+/*
+ * Licensed to the Apache Sof
1 - 100 of 294 matches
Mail list logo