[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #199: [FLINK-27551] Update status manually instead of relying on updatecontrol

2022-05-10 Thread GitBox
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 :) -

[jira] [Closed] (FLINK-27048) Add ArchUnit tests for Elasticsearch to only depend on public API

2022-05-10 Thread Martijn Visser (Jira)
[ 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

[GitHub] [flink] MartijnVisser merged pull request #19377: [FLINK-27048][test] Add ArchUnit rule that connectors should only depend on public API

2022-05-10 Thread GitBox
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

[jira] [Assigned] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

2022-05-10 Thread Martijn Visser (Jira)
[ 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

[jira] [Closed] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

2022-05-10 Thread Martijn Visser (Jira)
[ 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

[GitHub] [flink] MartijnVisser merged pull request #19608: [FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initialization issue with jdk11

2022-05-10 Thread GitBox
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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #113: [FLINK-27347] Support reading external table store table in Hive

2022-05-10 Thread GitBox
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

[jira] [Assigned] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Gyula Fora (Jira)
[ 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 > ---

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #113: [FLINK-27347] Support reading external table store table in Hive

2022-05-10 Thread GitBox
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

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #199: [FLINK-27551] Update status manually instead of relying on updatecontrol

2022-05-10 Thread GitBox
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

[GitHub] [flink] Airblader commented on a diff in pull request #18868: [FLINK-26206][runtime-web] add service layer abstraction and refactor config service

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Aitozi (Jira)
[ 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

[jira] [Comment Edited] (FLINK-27565) Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard

2022-05-10 Thread Jira
[ 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:

[jira] [Resolved] (FLINK-27565) Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard

2022-05-10 Thread Jira
[ 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

[jira] [Commented] (FLINK-27565) Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard

2022-05-10 Thread Jira
[ 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

[jira] [Updated] (FLINK-27565) Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard

2022-05-10 Thread ASF GitHub Bot (Jira)
[ 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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #107: [FLINK-27372] Make DataFileMeta and ManifestFileMeta schemaless

2022-05-10 Thread GitBox
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

[GitHub] [flink] Airblader merged pull request #19501: [FLINK-27565][runtime-web] Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27495) Observer should update last savepoint information directly from cluster too

2022-05-10 Thread Yang Wang (Jira)
[ 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

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #202: [FLINK-27483]Add session job config field

2022-05-10 Thread GitBox
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 @

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #202: [FLINK-27483]Add session job config field

2022-05-10 Thread GitBox
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 @

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #199: [FLINK-27551] Update status manually instead of relying on updatecontrol

2022-05-10 Thread GitBox
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.

[GitHub] [flink-kubernetes-operator] FuyaoLi2017 commented on a diff in pull request #202: [FLINK-27483]Add session job config field

2022-05-10 Thread GitBox
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

[GitHub] [flink-kubernetes-operator] FuyaoLi2017 commented on a diff in pull request #202: [FLINK-27483]Add session job config field

2022-05-10 Thread GitBox
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

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #107: [FLINK-27372] Make DataFileMeta and ManifestFileMeta schemaless

2022-05-10 Thread GitBox
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

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #199: [FLINK-27551] Update status manually instead of relying on updatecontrol

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Gyula Fora (Jira)
[ 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

[GitHub] [flink-web] JingsongLi merged pull request #531: Add Table Store 0.1.0 release

2022-05-10 Thread GitBox
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

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #202: [FLINK-27483]Add session job config field

2022-05-10 Thread GitBox
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 @

[GitHub] [flink-web] JingsongLi commented on pull request #531: Add Table Store 0.1.0 release

2022-05-10 Thread GitBox
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

[GitHub] [flink-table-store] openinx commented on a diff in pull request #115: [FLINK-27546] Add append only writer which implements the RecordWriter interface

2022-05-10 Thread GitBox
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

[GitHub] [flink] fredia commented on a diff in pull request #19502: [FLINK-27260][Runtime/REST] Expose changelog configurations in Rest API and Web UI

2022-05-10 Thread GitBox
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

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #199: [FLINK-27551] Update status manually instead of relying on updatecontrol

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27507) Update operations playground for 1.14

2022-05-10 Thread Shubham Bansal (Jira)
[ 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

[jira] [Updated] (FLINK-27507) Update operations playground for 1.14

2022-05-10 Thread ASF GitHub Bot (Jira)
[ 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.

[GitHub] [flink-playgrounds] shba24 opened a new pull request, #30: [FLINK-27507] update operations-walkthrough playground for Flink 1.14

2022-05-10 Thread GitBox
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

[GitHub] [flink] Tartarus0zm commented on pull request #19608: [FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initialization issue with jdk11

2022-05-10 Thread GitBox
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

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-10 Thread GitBox
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

[GitHub] [flink] flinkbot commented on pull request #19697: [FLINK-27563][docs] Fix yarn doc page display error.

2022-05-10 Thread GitBox
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`

[jira] [Comment Edited] (FLINK-27542) Add end to end tests for Hive to read external table store files

2022-05-10 Thread Jingsong Lee (Jira)
[ 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: ---

[GitHub] [flink] wanglijie95 commented on pull request #19686: [FLINK-27563][docs] Fix yarn doc page display error.

2022-05-10 Thread GitBox
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

[jira] [Reopened] (FLINK-27542) Add end to end tests for Hive to read external table store files

2022-05-10 Thread Jingsong Lee (Jira)
[ 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 > -

[GitHub] [flink] wanglijie95 opened a new pull request, #19697: [FLINK-27563][docs] Fix yarn doc page display error.

2022-05-10 Thread GitBox
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://

[GitHub] [flink-table-store] JingsongLi merged pull request #118: [FLINK-27542] E2e docker image should not occupy host machine ports as tests may run in parallel

2022-05-10 Thread GitBox
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...@

[jira] [Created] (FLINK-27568) Cannot submit JobGraph

2022-05-10 Thread Jason Kania (Jira)
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.

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #115: [FLINK-27546] Add append only writer which implements the RecordWriter interface

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Fuyao Li (Jira)
[ 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

[jira] [Comment Edited] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Fuyao Li (Jira)
[ 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

[GitHub] [flink] yangjunhan commented on pull request #18868: [FLINK-26206][runtime-web] add service layer abstraction and refactor config service

2022-05-10 Thread GitBox
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

[jira] [Updated] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread ASF GitHub Bot (Jira)
[ 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

[GitHub] [flink-kubernetes-operator] FuyaoLi2017 opened a new pull request, #202: [FLINK-27483]Add session job config field

2022-05-10 Thread GitBox
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

[GitHub] [flink-table-store] tsreaper opened a new pull request, #118: [FLINK-27542] E2e docker image should not occupy host machine ports as tests may run in parallel

2022-05-10 Thread GitBox
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

[GitHub] [flink] Myasuka commented on a diff in pull request #19502: [FLINK-27260][Runtime/REST] Expose changelog configurations in Rest API and Web UI

2022-05-10 Thread GitBox
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_

[GitHub] [flink] wangyang0918 commented on pull request #19686: [FLINK-27563][docs] Fix yarn doc page display error.

2022-05-10 Thread GitBox
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

[jira] [Assigned] (FLINK-27563) Resource Providers - Yarn doc page has minor display error

2022-05-10 Thread Yang Wang (Jira)
[ 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 > --

[GitHub] [flink] flinkbot commented on pull request #19696: [FLINK-27271][API/Python]Add globalwindows window allocator

2022-05-10 Thread GitBox
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`

[jira] [Updated] (FLINK-27271) Add globalwindows window allocator

2022-05-10 Thread ASF GitHub Bot (Jira)
[ 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 > -

[GitHub] [flink] cun8cun8 opened a new pull request, #19696: [FLINK-27271][API/Python]Add globalwindows window allocator

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Aitozi (Jira)
[ 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

[jira] [Comment Edited] (FLINK-22793) HybridSource Table Implementation

2022-05-10 Thread Ran Tao (Jira)
[ 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

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2022-05-10 Thread Ran Tao (Jira)
[ 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

[jira] [Commented] (FLINK-26939) Add TRANSLATE supported in SQL & Table API

2022-05-10 Thread jackwangcs (Jira)
[ 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

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-10 Thread GitBox
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

[jira] [Updated] (FLINK-26939) Add TRANSLATE supported in SQL & Table API

2022-05-10 Thread jackwangcs (Jira)
[ 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 > ---

[GitHub] [flink-table-store] openinx commented on a diff in pull request #115: [FLINK-27546] Add append only writer which implements the RecordWriter interface

2022-05-10 Thread GitBox
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

[jira] [Assigned] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2022-05-10 Thread Yangze Guo (Jira)
[ 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

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2022-05-10 Thread Yangze Guo (Jira)
[ 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

[jira] [Comment Edited] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Fuyao Li (Jira)
[ 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

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-10 Thread Fuyao Li (Jira)
[ 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

[GitHub] [flink] flinkbot commented on pull request #19695: [hotfix][docs-zh] Fix the formatting errors of some Chinese documents.

2022-05-10 Thread GitBox
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`

[GitHub] [flink] liuzhuang2017 commented on pull request #19695: [hotfix][docs-zh] Fix the formatting errors of some Chinese documents.

2022-05-10 Thread GitBox
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

[GitHub] [flink] liuzhuang2017 opened a new pull request, #19695: [hotfix][docs-zh] Fix the formatting errors of some Chinese documents.

2022-05-10 Thread GitBox
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

[GitHub] [flink] mans2singh commented on pull request #19542: [hotfix][ops][state][docs] Corrections in incremental checkpoint section

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27509) Update table walkthrough playground for 1.14

2022-05-10 Thread Shubham Bansal (Jira)
[ 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

[jira] [Updated] (FLINK-27509) Update table walkthrough playground for 1.14

2022-05-10 Thread ASF GitHub Bot (Jira)
[ 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

[GitHub] [flink-playgrounds] shba24 opened a new pull request, #29: [FLINK-27509] update table-walkthrough playground for Flink 1.14

2022-05-10 Thread GitBox
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) -

[jira] [Commented] (FLINK-26773) ResourceManager leader election can a reconnect while shutting down the JobMaster

2022-05-10 Thread Jonathan Lazarus (Jira)
[ 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

[jira] [Resolved] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-05-10 Thread Thomas Weise (Jira)
[ 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

[jira] [Updated] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-05-10 Thread Thomas Weise (Jira)
[ 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

[GitHub] [flink] tweise commented on pull request #19645: [FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema

2022-05-10 Thread GitBox
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

[GitHub] [flink] tweise merged pull request #19645: [FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27435) Kubernetes Operator keeps savepoint history

2022-05-10 Thread Thomas Weise (Jira)
[ 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

[jira] [Assigned] (FLINK-27435) Kubernetes Operator keeps savepoint history

2022-05-10 Thread Thomas Weise (Jira)
[ 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 > --

[GitHub] [flink] nryanov commented on pull request #19517: [hotfix][docs] Fix StringDeserializer typo

2022-05-10 Thread GitBox
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

[GitHub] [flink] tweise commented on pull request #19645: [FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema

2022-05-10 Thread GitBox
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

[GitHub] [flink] MartijnVisser commented on pull request #19377: [FLINK-27048][test] Add ArchUnit rule that connectors should only depend on public API

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-27495) Observer should update last savepoint information directly from cluster too

2022-05-10 Thread Gyula Fora (Jira)
[ 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

[jira] [Comment Edited] (FLINK-27495) Observer should update last savepoint information directly from cluster too

2022-05-10 Thread Gyula Fora (Jira)
[ 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: -

[jira] [Commented] (FLINK-27495) Observer should update last savepoint information directly from cluster too

2022-05-10 Thread Gyula Fora (Jira)
[ 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

[jira] [Commented] (FLINK-27495) Observer should update last savepoint information directly from cluster too

2022-05-10 Thread Thomas Weise (Jira)
[ 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

[GitHub] [flink] afedulov commented on a diff in pull request #19660: [FLINK-27185][connectors] Convert connector modules to assertj

2022-05-10 Thread GitBox
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

[jira] [Comment Edited] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

2022-05-10 Thread Alexis Sarda-Espinosa (Jira)
[ 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: --

[jira] [Commented] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

2022-05-10 Thread Alexis Sarda-Espinosa (Jira)
[ 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

[jira] [Resolved] (FLINK-26588) Translate the new CAST documentation to Chinese

2022-05-10 Thread Leonard Xu (Jira)
[ 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 > -

[jira] [Updated] (FLINK-26588) Translate the new CAST documentation to Chinese

2022-05-10 Thread Leonard Xu (Jira)
[ 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 > --

[jira] [Comment Edited] (FLINK-26588) Translate the new CAST documentation to Chinese

2022-05-10 Thread Leonard Xu (Jira)
[ 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: -

[GitHub] [flink] leonardBang merged pull request #19689: [BP-1.15][FLINK-26588][docs]Translate the new CAST documentation to C…

2022-05-10 Thread GitBox
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

[jira] [Commented] (FLINK-23633) HybridSource: Support dynamic stop position in FileSource

2022-05-10 Thread Xinbin Huang (Jira)
[ 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

[GitHub] [flink] wanglijie95 commented on pull request #19686: [FLINK-27563][docs] Fix yarn doc page display error.

2022-05-10 Thread GitBox
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

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-10 Thread GitBox
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   2   3   >