[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #233: [FLINK-27728] Adding os update to debian image

2022-05-20 Thread GitBox
gyfora commented on PR #233: URL: https://github.com/apache/flink-kubernetes-operator/pull/233#issuecomment-1133542210 I also triggered the github action manually, it seems like a persistent issue. I cannot reproduce it locally, where it works fine on my M1 macbook -- This is an

[jira] [Commented] (FLINK-27060) Extending /jars/:jarid/run API to support setting Flink configs

2022-05-20 Thread ConradJam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540354#comment-17540354 ] ConradJam commented on FLINK-27060: --- Hi [~martijnvisser] , I've looked closely at the new SQL Gateway

[GitHub] [flink] wsry commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

2022-05-20 Thread GitBox
wsry commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r878647986 ## flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java: ## @@ -84,6 +86,33 @@ CompletableFuture registerPartitionWithProducer(

[jira] [Updated] (FLINK-27728) dockerFile build results in five vulnerabilities

2022-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27728: --- Labels: pull-request-available (was: ) > dockerFile build results in five vulnerabilities

[GitHub] [flink-kubernetes-operator] jbusche commented on pull request #233: [FLINK-27728] Adding os update to debian image

2022-05-20 Thread GitBox
jbusche commented on PR #233: URL: https://github.com/apache/flink-kubernetes-operator/pull/233#issuecomment-1133536998 Yes, thanks @gyfora, I'll do that going forward. It's interesting, it builds locally, but not on github. Didn't know how to try a re-run, so added a comment and trying

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #232: Doc updates: Upgrade process, compatibility guarantess, crd overview update

2022-05-20 Thread GitBox
gyfora commented on PR #232: URL: https://github.com/apache/flink-kubernetes-operator/pull/232#issuecomment-1133533358 cc @tweise @morhidi @wangyang0918 -- 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

[jira] [Assigned] (FLINK-27728) dockerFile build results in five vulnerabilities

2022-05-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27728: -- Assignee: James Busche > dockerFile build results in five vulnerabilities >

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #233: Adding os update to debian image

2022-05-20 Thread GitBox
gyfora commented on PR #233: URL: https://github.com/apache/flink-kubernetes-operator/pull/233#issuecomment-1133532220 Please add [FLINK-27728] to both the PR and the commit message as a prefix that will help us review :) -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #233: Adding os update to debian image

2022-05-20 Thread GitBox
gyfora commented on PR #233: URL: https://github.com/apache/flink-kubernetes-operator/pull/233#issuecomment-1133531934 Is this linked to any jira? Seems like the docker build doesnt run: ``` Error: buildx bake failed with: error: failed to solve: process

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #227: [FLINK-27685] Scale subresource prototype

2022-05-20 Thread GitBox
gyfora commented on PR #227: URL: https://github.com/apache/flink-kubernetes-operator/pull/227#issuecomment-1133530577 But in general you are right the reactive mode should be quicker and more reliable in shaky conditions. We can probably support that in the future once standalone mode

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #227: [FLINK-27685] Scale subresource prototype

2022-05-20 Thread GitBox
gyfora commented on PR #227: URL: https://github.com/apache/flink-kubernetes-operator/pull/227#issuecomment-1133530034 @jeesmon in some sense I agree. But task manager pods can fail for various reasons and you need to make sure you can provision them reliably if you are running real

[jira] [Commented] (FLINK-27418) Flink SQL TopN result is wrong

2022-05-20 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540342#comment-17540342 ] Roman Boyko commented on FLINK-27418: - The PR is ready -

[GitHub] [flink] flinkbot commented on pull request #19781: Just for test : output buffer aligned to uc

2022-05-20 Thread GitBox
flinkbot commented on PR #19781: URL: https://github.com/apache/flink/pull/19781#issuecomment-1133515005 ## CI report: * d799641209c94af0f1694bd3ff289e2d457c34a6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] 1996fanrui opened a new pull request, #19781: Just for test : output buffer aligned to uc

2022-05-20 Thread GitBox
1996fanrui opened a new pull request, #19781: URL: https://github.com/apache/flink/pull/19781 Just for test -- 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,

[jira] [Commented] (FLINK-27728) dockerFile build results in five vulnerabilities

2022-05-20 Thread James Busche (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540339#comment-17540339 ] James Busche commented on FLINK-27728: -- Created PR

[GitHub] [flink-kubernetes-operator] jbusche opened a new pull request, #233: Adding os update to debian image

2022-05-20 Thread GitBox
jbusche opened a new pull request, #233: URL: https://github.com/apache/flink-kubernetes-operator/pull/233 Signed-off-by: James Busche When the flink-kubernetes-operator is build with the: ``` RUN apt-get update RUN apt-get upgrade -y ``` Then four current

[jira] [Created] (FLINK-27728) dockerFile build results in five vulnerabilities

2022-05-20 Thread James Busche (Jira)
James Busche created FLINK-27728: Summary: dockerFile build results in five vulnerabilities Key: FLINK-27728 URL: https://issues.apache.org/jira/browse/FLINK-27728 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #19780: [FLINK-27727][tests] Migrate TypeSerializerUpgradeTestBase to JUnit5

2022-05-20 Thread GitBox
flinkbot commented on PR #19780: URL: https://github.com/apache/flink/pull/19780#issuecomment-1133476724 ## CI report: * d37ff59316c99c98921076352e1755e2f4738bc9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27727) [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5

2022-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27727: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Migrate

[GitHub] [flink] snuyanzin opened a new pull request, #19780: [FLINK-27727][tests] Migrate TypeSerializerUpgradeTestBase to JUnit5

2022-05-20 Thread GitBox
snuyanzin opened a new pull request, #19780: URL: https://github.com/apache/flink/pull/19780 ## What is the purpose of the change Update the `TypeSerializerUpgradeTestBase` class and its successors to AssertJ and JUnit 5 following the [JUnit 5 Migration

[jira] [Updated] (FLINK-27727) [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5

2022-05-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-27727: Component/s: Tests > [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5 >

[jira] [Created] (FLINK-27727) [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5

2022-05-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-27727: --- Summary: [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5 Key: FLINK-27727 URL: https://issues.apache.org/jira/browse/FLINK-27727 Project:

[GitHub] [flink-kubernetes-operator] jeesmon commented on pull request #227: [FLINK-27685] Scale subresource prototype

2022-05-20 Thread GitBox
jeesmon commented on PR #227: URL: https://github.com/apache/flink-kubernetes-operator/pull/227#issuecomment-1133323923 @gyfora Considering a scale event can potentially block resuming a job (due to new task managers in Pending state because of worker node provisioning delay or other

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #230: [build] Add doc build for new release branch

2022-05-20 Thread GitBox
mbalassi commented on PR #230: URL: https://github.com/apache/flink-kubernetes-operator/pull/230#issuecomment-1133208465 https://user-images.githubusercontent.com/5990983/169592735-8af1bdfa-8ec4-4c3d-b0e0-8e80ba2830fd.png;> -- This is an automated message from the Apache Git Service.

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #230: [build] Add doc build for new release branch

2022-05-20 Thread GitBox
mbalassi merged PR #230: URL: https://github.com/apache/flink-kubernetes-operator/pull/230 -- 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:

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

2022-05-20 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540227#comment-17540227 ] Alexis Sarda-Espinosa commented on FLINK-27504: --- What I meant is that there are 2

[GitHub] [flink-docker] afedulov commented on a diff in pull request #116: [FLINK-27671][ci] Publish snapshot images to GHCR

2022-05-20 Thread GitBox
afedulov commented on code in PR #116: URL: https://github.com/apache/flink-docker/pull/116#discussion_r878381552 ## .github/workflows/snapshot.yml: ## @@ -0,0 +1,68 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See

[GitHub] [flink] flinkbot commented on pull request #19779: [FLINK-27726] [Connector-Hive] shade thrift and fb303 in hive connector

2022-05-20 Thread GitBox
flinkbot commented on PR #19779: URL: https://github.com/apache/flink/pull/19779#issuecomment-1133107881 ## CI report: * fa57f53591c5112eed6cde7cfb68d083128625f2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27726) shade thrift and fb303 in hive connector

2022-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27726: --- Labels: pull-request-available (was: ) > shade thrift and fb303 in hive connector >

[GitHub] [flink] chenqin opened a new pull request, #19779: [FLINK-27726] [Connector-Hive] shade thrift and fb303 in hive connector

2022-05-20 Thread GitBox
chenqin opened a new pull request, #19779: URL: https://github.com/apache/flink/pull/19779 Hive connector introduced fb303 and thrift version to connect to specific hive meta store version. If user code also pull specific thrift version along with fb303 that is not same as what

[GitHub] [flink] xinbinhuang commented on pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

2022-05-20 Thread GitBox
xinbinhuang commented on PR #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-1133100839 > https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/finegrained_resource/#notice ah, wasn't realized this! thanks for the reference! I'll give a through read

[jira] [Updated] (FLINK-27726) shade thrift and fb303 in hive connector

2022-05-20 Thread Chen Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-27726: - Summary: shade thrift and fb303 in hive connector (was: shad thrift and fb303 in hive connector) >

[jira] [Created] (FLINK-27726) shad thrift and fb303 in hive connector

2022-05-20 Thread Chen Qin (Jira)
Chen Qin created FLINK-27726: Summary: shad thrift and fb303 in hive connector Key: FLINK-27726 URL: https://issues.apache.org/jira/browse/FLINK-27726 Project: Flink Issue Type: Improvement

[GitHub] [flink] xinbinhuang commented on a diff in pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

2022-05-20 Thread GitBox
xinbinhuang commented on code in PR #17873: URL: https://github.com/apache/flink/pull/17873#discussion_r878322562 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java: ## @@ -184,6 +185,8 @@ private void decorateNode(Integer vertexID,

[GitHub] [flink] xinbinhuang commented on a diff in pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

2022-05-20 Thread GitBox
xinbinhuang commented on code in PR #17873: URL: https://github.com/apache/flink/pull/17873#discussion_r878322562 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java: ## @@ -184,6 +185,8 @@ private void decorateNode(Integer vertexID,

[GitHub] [flink] xinbinhuang commented on a diff in pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

2022-05-20 Thread GitBox
xinbinhuang commented on code in PR #17873: URL: https://github.com/apache/flink/pull/17873#discussion_r878322562 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java: ## @@ -184,6 +185,8 @@ private void decorateNode(Integer vertexID,

[GitHub] [flink] echauchot commented on a diff in pull request #19680: [FLINK-27457] Implement flush() logic in Cassandra output formats

2022-05-20 Thread GitBox
echauchot commented on code in PR #19680: URL: https://github.com/apache/flink/pull/19680#discussion_r878323535 ## flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBaseTest.java: ## @@ -0,0 +1,352 @@ +/* +

[GitHub] [flink] echauchot commented on a diff in pull request #19680: [FLINK-27457] Implement flush() logic in Cassandra output formats

2022-05-20 Thread GitBox
echauchot commented on code in PR #19680: URL: https://github.com/apache/flink/pull/19680#discussion_r878323055 ## flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java: ## @@ -17,130 +17,160 @@

[GitHub] [flink] xinbinhuang commented on a diff in pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

2022-05-20 Thread GitBox
xinbinhuang commented on code in PR #17873: URL: https://github.com/apache/flink/pull/17873#discussion_r878322562 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java: ## @@ -184,6 +185,8 @@ private void decorateNode(Integer vertexID,

[GitHub] [flink] xinbinhuang commented on a diff in pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

2022-05-20 Thread GitBox
xinbinhuang commented on code in PR #17873: URL: https://github.com/apache/flink/pull/17873#discussion_r878322562 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java: ## @@ -184,6 +185,8 @@ private void decorateNode(Integer vertexID,

[GitHub] [flink-docker] afedulov commented on a diff in pull request #116: [FLINK-27671][ci] Publish snapshot images to GHCR

2022-05-20 Thread GitBox
afedulov commented on code in PR #116: URL: https://github.com/apache/flink-docker/pull/116#discussion_r878287621 ## .github/workflows/snapshot.yml: ## @@ -0,0 +1,71 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #230: [build] Add doc build for new release branch

2022-05-20 Thread GitBox
mbalassi commented on PR #230: URL: https://github.com/apache/flink-kubernetes-operator/pull/230#issuecomment-1133010753 I see, there is a typo in the script  . Will fix later. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-27412) Allow flinkVersion v1_13 in flink-kubernetes-operator

2022-05-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27412: --- Issue Type: New Feature (was: Improvement) > Allow flinkVersion v1_13 in flink-kubernetes-operator

[jira] [Updated] (FLINK-26953) Introduce Operator Specific Metrics

2022-05-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26953: --- Issue Type: New Feature (was: Improvement) > Introduce Operator Specific Metrics >

[jira] [Updated] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress

2022-05-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26926: --- Issue Type: New Feature (was: Improvement) > Allow users to force upgrade even if savepoint is in

[jira] [Updated] (FLINK-26140) Add basic handling mechanism to deal with job upgrade errors

2022-05-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26140: --- Issue Type: New Feature (was: Improvement) > Add basic handling mechanism to deal with job upgrade

[jira] [Updated] (FLINK-27714) Migrate to java-operator-sdk v3

2022-05-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27714: --- Issue Type: New Feature (was: Improvement) > Migrate to java-operator-sdk v3 >

[jira] [Updated] (FLINK-27714) Migrate to java-operator-sdk v3

2022-05-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27714: --- Affects Version/s: (was: kubernetes-operator-1.0.0) > Migrate to java-operator-sdk v3 >

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #227: [FLINK-27685] Scale subresource prototype

2022-05-20 Thread GitBox
gyfora commented on PR #227: URL: https://github.com/apache/flink-kubernetes-operator/pull/227#issuecomment-1132961228 @jeesmon That is completely expected. When you scale up the operator performs a stateful upgrade to the new parallelism. The job is resubmitted and the native

[GitHub] [flink-kubernetes-operator] jeesmon commented on pull request #227: [FLINK-27685] Scale subresource prototype

2022-05-20 Thread GitBox
jeesmon commented on PR #227: URL: https://github.com/apache/flink-kubernetes-operator/pull/227#issuecomment-1132958028 @gyfora I was able to run the `basic-scaling` example with your changes locally and it seems to be working fine. One thing I noticed is parallelism getting updated even

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #230: [build] Add doc build for new release branch

2022-05-20 Thread GitBox
mbalassi commented on PR #230: URL: https://github.com/apache/flink-kubernetes-operator/pull/230#issuecomment-1132955616 Indeed, if you check the [nigthlies root](https://nightlies.apache.org/flink/) the aliased docs are missing. Will play with it to see what is up. -- This is an

[GitHub] [flink] fapaul commented on a diff in pull request #19655: [FLINK-27527] Create a file-based upsert sink for testing internal components

2022-05-20 Thread GitBox
fapaul commented on code in PR #19655: URL: https://github.com/apache/flink/pull/19655#discussion_r878166302 ## flink-tests/src/test/java/org/apache/flink/test/completeness/TypeInfoTestCoverageTest.java: ## @@ -46,6 +62,24 @@ public void testTypeInfoTestCoverage() {

[jira] [Assigned] (FLINK-27527) Create a file-based Upsert sink for testing internal components

2022-05-20 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-27527: Assignee: Alexander Preuss > Create a file-based Upsert sink for testing

[jira] [Commented] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

2022-05-20 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540127#comment-17540127 ] Alexander Preuss commented on FLINK-27725: -- CC: [~twalthr]  > Create tests for TypeInformation

[jira] [Created] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

2022-05-20 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-27725: Summary: Create tests for TypeInformation and TypeSerializer classes in table Key: FLINK-27725 URL: https://issues.apache.org/jira/browse/FLINK-27725

[jira] [Updated] (FLINK-27502) Add file Suffix to data files

2022-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27502: --- Labels: pull-request-available (was: ) > Add file Suffix to data files >

[GitHub] [flink-table-store] hililiwei opened a new pull request, #133: [FLINK-27502] Add file Suffix to data files

2022-05-20 Thread GitBox
hililiwei opened a new pull request, #133: URL: https://github.com/apache/flink-table-store/pull/133 ## What is the purpose of the change Add file Suffix to data files ## Verifying this change org.apache.flink.table.store.format.FileFormatSuffixTest -- This is an

[jira] [Updated] (FLINK-27650) First environment variable of top level pod template is lost

2022-05-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27650: -- Fix Version/s: kubernetes-operator-1.1.0 (was: kubernetes-operator-1.0.0) >

[jira] [Closed] (FLINK-27647) Improve Metrics documentation to include newly added metrics

2022-05-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27647. - Resolution: Fixed Fixed via: main: ea86018735c934549f6be4b19111c633b1386b7c release-1.0:

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #231: [FLINK-27647] Improve Metrics documentation to include newly added metrics

2022-05-20 Thread GitBox
wangyang0918 merged PR #231: URL: https://github.com/apache/flink-kubernetes-operator/pull/231 -- 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:

[GitHub] [flink] alpreu commented on a diff in pull request #19655: [FLINK-27527] Create a file-based upsert sink for testing internal components

2022-05-20 Thread GitBox
alpreu commented on code in PR #19655: URL: https://github.com/apache/flink/pull/19655#discussion_r878106621 ## flink-test-utils-parent/flink-test-utils/pom.xml: ## @@ -35,6 +35,12 @@ under the License. + + org.apache.flink +

[jira] [Closed] (FLINK-27490) [JUnit5 Migration] Module: flink-table-code-splitter

2022-05-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27490. Fix Version/s: 1.16.0 Assignee: Sergey Nuyanzin Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #19638: [FLINK-27490][table][tests] Migrate test to JUnit5 for flink-table-co…

2022-05-20 Thread GitBox
zentol merged PR #19638: URL: https://github.com/apache/flink/pull/19638 -- 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:

[GitHub] [flink] flinkbot commented on pull request #19778: [FLINK-27418][table-planner] fix topN retraction for previously delet…

2022-05-20 Thread GitBox
flinkbot commented on PR #19778: URL: https://github.com/apache/flink/pull/19778#issuecomment-1132775661 ## CI report: * f0affacf9db5723adfa6896e7d1da312ad3a971e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27418) Flink SQL TopN result is wrong

2022-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27418: --- Labels: pull-request-available (was: ) > Flink SQL TopN result is wrong >

[GitHub] [flink] rovboyko opened a new pull request, #19778: [FLINK-27418][table-planner] fix topN retraction for previously delet…

2022-05-20 Thread GitBox
rovboyko opened a new pull request, #19778: URL: https://github.com/apache/flink/pull/19778 …ed record ## What is the purpose of the change Fixing the bug inside RetractableTopNFunction. The bug occurs when the record initially inserted inside topN, then it is dropped

[jira] (FLINK-27134) OSS sink can't get access key id

2022-05-20 Thread Alex Z (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27134 ] Alex Z deleted comment on FLINK-27134: was (Author: alexzax): [~wujinhu] What provider should I choose if I want to load assess key from flink-conf.yaml? > OSS sink can't get access key id >

[jira] [Comment Edited] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-05-20 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 5/20/22 10:46 AM: [~tartarus]

[GitHub] [flink] luoyuxia commented on a diff in pull request #19562: [FLINK-27304][hive] Calcite's varbinary type should be converted to Hive's binary type.

2022-05-20 Thread GitBox
luoyuxia commented on code in PR #19562: URL: https://github.com/apache/flink/pull/19562#discussion_r877701927 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserTypeConverter.java: ## @@ -289,6 +289,7 @@ private

[jira] [Assigned] (FLINK-27705) num-sorted-run.compaction-trigger should not interfere the num-levels

2022-05-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27705: Assignee: Jane Chan > num-sorted-run.compaction-trigger should not interfere the

[jira] [Closed] (FLINK-27706) Refactor all subclasses of FileStoreTableITCase to use the batchSql.

2022-05-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27706. Assignee: Zheng Hu Resolution: Fixed master: 43326310de7af4bb3695d3dbcb184b23dab467bf >

[GitHub] [flink-table-store] JingsongLi merged pull request #129: [FLINK-27706] Refactor all subclasses of FileStoreTableITCase to use the batchSql

2022-05-20 Thread GitBox
JingsongLi merged PR #129: URL: https://github.com/apache/flink-table-store/pull/129 -- 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:

[GitHub] [flink] flinkbot commented on pull request #19777: [hotfix][connector/pulsar] Update atEventTime to atPublishTime in JavaDoc

2022-05-20 Thread GitBox
flinkbot commented on PR #19777: URL: https://github.com/apache/flink/pull/19777#issuecomment-1132731765 ## CI report: * 0f4846beac1d300f45e2af1aacd43e6059871ebd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] deadwind4 commented on pull request #19777: [hotfix][connector/pulsar] Update atEventTime to atPublishTime in JavaDoc

2022-05-20 Thread GitBox
deadwind4 commented on PR #19777: URL: https://github.com/apache/flink/pull/19777#issuecomment-1132730334 @fapaul Please review it, thanks a lot. -- 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

[GitHub] [flink] deadwind4 opened a new pull request, #19777: [hotfix][connector/pulsar] Update atEventTime to atPublishTime in JavaDoc

2022-05-20 Thread GitBox
deadwind4 opened a new pull request, #19777: URL: https://github.com/apache/flink/pull/19777 ## What is the purpose of the change The `atEventTime` is deprecated, We need update JavaDoc to `atPublishTime` ## Brief change log - *Update atEventTime to atPublishTime in

[jira] [Commented] (FLINK-27705) num-sorted-run.compaction-trigger should not interfere the num-levels

2022-05-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540029#comment-17540029 ] Jingsong Lee commented on FLINK-27705: -- Thanks [~qingyue] for reporting. If the user only modifies

[GitHub] [flink-ml] dotbg commented on a diff in pull request #95: Migrated to flink 1.15.0.

2022-05-20 Thread GitBox
dotbg commented on code in PR #95: URL: https://github.com/apache/flink-ml/pull/95#discussion_r877976862 ## flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java: ## @@ -407,13 +415,15 @@ public void testSaveAndReload() throws Exception {

[GitHub] [flink] fapaul commented on a diff in pull request #19655: [FLINK-27527] Create a file-based upsert sink for testing internal components

2022-05-20 Thread GitBox
fapaul commented on code in PR #19655: URL: https://github.com/apache/flink/pull/19655#discussion_r877968464 ## flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/connector/upserttest/sink/UpsertTestSinkWriter.java: ## @@ -0,0 +1,101 @@ +/* + * Licensed to

[GitHub] [flink] fapaul commented on a diff in pull request #19655: [FLINK-27527] Create a file-based upsert sink for testing internal components

2022-05-20 Thread GitBox
fapaul commented on code in PR #19655: URL: https://github.com/apache/flink/pull/19655#discussion_r877968464 ## flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/connector/upserttest/sink/UpsertTestSinkWriter.java: ## @@ -0,0 +1,101 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-27713) Bump Apache Beam to 2.40.0

2022-05-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540026#comment-17540026 ] Huang Xingbo commented on FLINK-27713: -- apche-beam is currently voting for 2.39.0-rc2 and I don't

[GitHub] [flink] 1996fanrui commented on pull request #19723: [FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers

2022-05-20 Thread GitBox
1996fanrui commented on PR #19723: URL: https://github.com/apache/flink/pull/19723#issuecomment-1132715250 Hi @pnowojski , I fixed your all comments and re-submit commits(refer the [coding style

[GitHub] [flink] 1996fanrui commented on a diff in pull request #19723: [FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers

2022-05-20 Thread GitBox
1996fanrui commented on code in PR #19723: URL: https://github.com/apache/flink/pull/19723#discussion_r877965401 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java: ## @@ -103,6 +112,14 @@ class

[jira] [Created] (FLINK-27724) The SubtaskCheckpointCoordinatorImpl#close() isn't called in anywhere

2022-05-20 Thread fanrui (Jira)
fanrui created FLINK-27724: -- Summary: The SubtaskCheckpointCoordinatorImpl#close() isn't called in anywhere Key: FLINK-27724 URL: https://issues.apache.org/jira/browse/FLINK-27724 Project: Flink

[jira] [Updated] (FLINK-27719) Create Apache Flink slack workspace

2022-05-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27719: - Description: This is an umbrella for tasks related to setting up the Apache Flink slack

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

2022-05-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17295. --- Resolution: Done Merged into master: 061df0ba8f2cd4b4e6436ebde1bc249bc629e940

[jira] [Assigned] (FLINK-27723) Slack: revisit how this communication channel works

2022-05-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27723: Assignee: Xintong Song > Slack: revisit how this communication channel works >

[jira] [Created] (FLINK-27723) Slack: revisit how this communication channel works

2022-05-20 Thread Xintong Song (Jira)
Xintong Song created FLINK-27723: Summary: Slack: revisit how this communication channel works Key: FLINK-27723 URL: https://issues.apache.org/jira/browse/FLINK-27723 Project: Flink Issue

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

2022-05-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17295: Fix Version/s: 1.16.0 > Refactor the ExecutionAttemptID to consist of ExecutionVertexID and >

[GitHub] [flink] zhuzhurk merged pull request #19747: [FLINK-17295][runtime] Refactor the ExecutionAttemptID to consist of ExecutionGraphID, ExecutionVertexID and attemptNumber

2022-05-20 Thread GitBox
zhuzhurk merged PR #19747: URL: https://github.com/apache/flink/pull/19747 -- 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:

[GitHub] [flink] deadwind4 commented on pull request #19774: [FLINK-27711][python][connector/pulsar] Align setTopicPattern for Pulsar Connector

2022-05-20 Thread GitBox
deadwind4 commented on PR #19774: URL: https://github.com/apache/flink/pull/19774#issuecomment-1132699762 @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

[GitHub] [flink] zhuzhurk commented on pull request #19747: [FLINK-17295][runtime] Refactor the ExecutionAttemptID to consist of ExecutionGraphID, ExecutionVertexID and attemptNumber

2022-05-20 Thread GitBox
zhuzhurk commented on PR #19747: URL: https://github.com/apache/flink/pull/19747#issuecomment-1132699933 Thanks for reviewing! @zentol @KarmaGYZ 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

[jira] [Created] (FLINK-27722) Slack: set up auto-updated invitation link

2022-05-20 Thread Xintong Song (Jira)
Xintong Song created FLINK-27722: Summary: Slack: set up auto-updated invitation link Key: FLINK-27722 URL: https://issues.apache.org/jira/browse/FLINK-27722 Project: Flink Issue Type:

[GitHub] [flink] pnowojski commented on a diff in pull request #19723: [FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers

2022-05-20 Thread GitBox
pnowojski commented on code in PR #19723: URL: https://github.com/apache/flink/pull/19723#discussion_r877954907 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java: ## @@ -103,6 +112,14 @@ class

[GitHub] [flink-docker] gaoyunhaii commented on a diff in pull request #116: [FLINK-27671][ci] Publish snapshot images to GHCR

2022-05-20 Thread GitBox
gaoyunhaii commented on code in PR #116: URL: https://github.com/apache/flink-docker/pull/116#discussion_r877954036 ## .github/workflows/snapshot.yml: ## @@ -0,0 +1,71 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements.

[jira] [Created] (FLINK-27721) Slack: set up archive

2022-05-20 Thread Xintong Song (Jira)
Xintong Song created FLINK-27721: Summary: Slack: set up archive Key: FLINK-27721 URL: https://issues.apache.org/jira/browse/FLINK-27721 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-27294) Add Transformer for EvalBinaryClass

2022-05-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27294: - Fix Version/s: ml-2.1.0 > Add Transformer for EvalBinaryClass >

[jira] [Updated] (FLINK-27294) Add Transformer for EvalBinaryClass

2022-05-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27294: - Affects Version/s: ml-2.1.0 > Add Transformer for EvalBinaryClass >

[jira] [Created] (FLINK-27720) Slack: Update the project website regarding communication channels

2022-05-20 Thread Xintong Song (Jira)
Xintong Song created FLINK-27720: Summary: Slack: Update the project website regarding communication channels Key: FLINK-27720 URL: https://issues.apache.org/jira/browse/FLINK-27720 Project: Flink

[jira] [Resolved] (FLINK-27294) Add Transformer for EvalBinaryClass

2022-05-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-27294. -- Resolution: Done Merged in to master via 702863b3570e626520644326f6dba91d2c8a90ba and

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #95: Migrated to flink 1.15.0.

2022-05-20 Thread GitBox
yunfengzhou-hub commented on PR #95: URL: https://github.com/apache/flink-ml/pull/95#issuecomment-1132696084 Hi @dotbg , Could you please check the failures in the Python checks? So far as I can see they should just be caused by removing scala versions in package names. -- This is an

  1   2   3   >