flinkbot commented on PR #19544:
URL: https://github.com/apache/flink/pull/19544#issuecomment-1104790514
## CI report:
* e0f40248e0cc76ab7fd2095b7f79a856e7481abe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27240:
---
Labels: pull-request-available (was: )
> Support ADD PARTITION statement for partitioned ta
lsyldliu opened a new pull request, #19544:
URL: https://github.com/apache/flink/pull/19544
## What is the purpose of the change
Support ADD PARTITION statement for partitioned table
## Brief change log
- *Support ADD PARTITION statement for partitioned table*
[
https://issues.apache.org/jira/browse/FLINK-26772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525443#comment-17525443
]
Matthias Pohl commented on FLINK-26772:
---
The problem is that we're waiting for the
JingsongLi commented on code in PR #97:
URL: https://github.com/apache/flink-table-store/pull/97#discussion_r854830708
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeOptions.java:
##
@@ -115,6 +125,7 @@ public MergeTreeOptions(
[
https://issues.apache.org/jira/browse/FLINK-26772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525441#comment-17525441
]
Matthias Pohl edited comment on FLINK-26772 at 4/21/22 6:37 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-26772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525441#comment-17525441
]
Matthias Pohl commented on FLINK-26772:
---
[~wangyang0918] pointed out that SIGTERM
JingsongLi commented on code in PR #97:
URL: https://github.com/apache/flink-table-store/pull/97#discussion_r854826594
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeOptions.java:
##
@@ -115,6 +125,7 @@ public MergeTreeOptions(
snuyanzin commented on PR #19540:
URL: https://github.com/apache/flink/pull/19540#issuecomment-1104767411
To fix failing it is also required updating versions in NOTICE files in a
way similar to how it was done at https://github.com/apache/flink/pull/16786
--
This is an automated message
dianfu commented on code in PR #526:
URL: https://github.com/apache/flink-web/pull/526#discussion_r854819441
##
_posts/2022-04-11-1.15-announcement.md:
##
@@ -0,0 +1,431 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.15"
+subtitle: ""
+date: 2022-04-11T
[
https://issues.apache.org/jira/browse/FLINK-27247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-27247:
-
Fix Version/s: 1.16.0
> ScalarOperatorGens.numericCasting is not compatible with legacy behavior
[
https://issues.apache.org/jira/browse/FLINK-27247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-27247.
Fix Version/s: 1.15.1
Assignee: xuyang
Resolution: Fixed
Fixed in master: fcbbcf9b
[
https://issues.apache.org/jira/browse/FLINK-27329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525432#comment-17525432
]
Biao Geng commented on FLINK-27329:
---
[~wangyang0918] Reviewing all default values make
twalthr closed pull request #19470: [FLINK-27247][table-planner]
ScalarOperatorGens.numericCasting is not compatible with legacy behavior
URL: https://github.com/apache/flink/pull/19470
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
flinkbot commented on PR #19543:
URL: https://github.com/apache/flink/pull/19543#issuecomment-1104748536
## CI report:
* bcf4ab1a534bc84889d163bd41bf45241240143c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-22857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22857:
---
Labels: auto-unassigned pull-request-available (was: auto-unassigned)
> Add possibility to
twalthr opened a new pull request, #19543:
URL: https://github.com/apache/flink/pull/19543
## What is the purpose of the change
This enables to evaluate arbitrary expressions in `SpecializedFunction`. It
allows to access all built-in functions including code generated ones during
run
[
https://issues.apache.org/jira/browse/FLINK-27335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27335:
---
Labels: pull-request-available (was: )
> Optimize async compaction in MergeTreeWriter
> ---
JingsongLi opened a new pull request, #97:
URL: https://github.com/apache/flink-table-store/pull/97
Currently Full Compaction may cause the writer to be blocked, which has an
impact on LogStore latency.
We need to decouple compact and write, compact completely asynchronous.
But too
Jingsong Lee created FLINK-27335:
Summary: Optimize async compaction in MergeTreeWriter
Key: FLINK-27335
URL: https://issues.apache.org/jira/browse/FLINK-27335
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-27315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-27315:
-
Summary: Fix the demo of MemoryStateBackendMigration (was: [docs] Fix the
demo of MemoryStateBackendMig
[
https://issues.apache.org/jira/browse/FLINK-27315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-27315.
--
Fix Version/s: 1.16.0
1.14.5
Resolution: Fixed
merged in master: f5b2e6177bf
Myasuka merged PR #19525:
URL: https://github.com/apache/flink/pull/19525
--
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.apach
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854753397
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/OperatorConfigOptions.java:
##
@@ -97,4 +97,10 @@ public class Ope
Aitozi created FLINK-27334:
--
Summary: Support auto generate the doc for the
KubernetesOperatorConfigOptions
Key: FLINK-27334
URL: https://issues.apache.org/jira/browse/FLINK-27334
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-27270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-27270:
---
Description:
# Basic operations
# How to support different source jars
> Add document of session job opera
Aitozi commented on PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#issuecomment-1104679360
@wangyang0918 Thanks for your review, I have addressed your comments, Please
take a look again.
--
This is an automated message from the Apache Git Service.
To respond t
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854747142
##
flink-kubernetes-operator/pom.xml:
##
@@ -270,6 +283,13 @@ under the License.
${flink.version}
wangyang0918 commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854745708
##
flink-kubernetes-operator/pom.xml:
##
@@ -270,6 +283,13 @@ under the License.
${flink.version}
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854745556
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/OperatorConfigOptions.java:
##
@@ -97,4 +97,10 @@ public class Ope
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854745008
##
flink-kubernetes-operator/pom.xml:
##
@@ -75,6 +75,12 @@ under the License.
${flink.version}
+
Review Comment:
Th
zoucao commented on PR #19504:
URL: https://github.com/apache/flink/pull/19504#issuecomment-1104666336
@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.
T
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854742318
##
flink-kubernetes-operator/pom.xml:
##
@@ -270,6 +283,13 @@ under the License.
${flink.version}
wangyang0918 commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854742144
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/OperatorConfigOptions.java:
##
@@ -97,4 +97,10 @@ public cla
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854741545
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/artifact/ArtifactManagerTest.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed
wangyang0918 commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854741196
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -204,12 +209,14 @@ private JarRunR
[
https://issues.apache.org/jira/browse/FLINK-27329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525394#comment-17525394
]
Yang Wang commented on FLINK-27329:
---
Could we take this opportunity to review all the
[
https://issues.apache.org/jira/browse/FLINK-27332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525392#comment-17525392
]
Yun Tang commented on FLINK-27332:
--
This is by design, which is introduced by FLINK-251
[
https://issues.apache.org/jira/browse/FLINK-27332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-27332.
Resolution: Information Provided
> org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't r
[
https://issues.apache.org/jira/browse/FLINK-27328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525391#comment-17525391
]
Yang Wang commented on FLINK-27328:
---
If you are using {{"--host", "$POD_IP"}} to make
zoltar9264 commented on code in PR #19441:
URL: https://github.com/apache/flink/pull/19441#discussion_r854735013
##
flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java:
##
@@ -295,6 +349,39 @@ public void close() {
}
CPS794 commented on PR #19389:
URL: https://github.com/apache/flink/pull/19389#issuecomment-1104653048
@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
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854726992
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/OperatorConfigOptions.java:
##
@@ -97,4 +97,10 @@ public class Ope
[
https://issues.apache.org/jira/browse/FLINK-27145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27145.
Resolution: Fixed
master: 27c3f47781f3a9f0b804219c7b8037fe4a00dc75
> The code generated for agg f
JingsongLi merged PR #19418:
URL: https://github.com/apache/flink/pull/19418
--
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
[
https://issues.apache.org/jira/browse/FLINK-27316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27316.
Resolution: Fixed
master: c9feaf5b66d0c87fc228fc1e2b2ead1a7669eb54
release-0.1: 320bf8ce312ba4b1b
[
https://issues.apache.org/jira/browse/FLINK-27316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27316:
---
Labels: pull-request-available (was: )
> Prevent users from changing bucket number
> --
Vancior commented on code in PR #19453:
URL: https://github.com/apache/flink/pull/19453#discussion_r854719409
##
flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java:
##
@@ -190,7 +194,8 @@ public BeamPythonFunctionRunner(
JingsongLi merged PR #96:
URL: https://github.com/apache/flink-table-store/pull/96
--
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...@fl
Vancior commented on code in PR #19453:
URL: https://github.com/apache/flink/pull/19453#discussion_r854718202
##
flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamDataStreamPythonFunctionRunner.java:
##
@@ -102,85 +106,144 @@ public BeamDataStream
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854667241
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/OperatorConfigOptions.java:
##
@@ -97,4 +97,10 @@ public class Ope
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854664914
##
flink-kubernetes-operator/pom.xml:
##
@@ -270,6 +283,13 @@ under the License.
${flink.version}
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854663876
##
flink-kubernetes-operator/pom.xml:
##
@@ -135,6 +141,13 @@ under the License.
${fabric8.version}
test
+
+
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854663797
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -204,12 +209,14 @@ private JarRunRespons
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854662879
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/OperatorConfigOptions.java:
##
@@ -97,4 +97,10 @@ public class Ope
Aitozi commented on code in PR #168:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/168#discussion_r854662627
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/FileSystemBasedArtifactFetcher.java:
##
@@ -0,0 +1,50 @@
+/*
+ *
Aitozi commented on PR #176:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/176#issuecomment-1104562068
I also try to make the ReconcileUtils to a new Object to handle the
`reconciledSucceed`, `reconcileError` and `savepointSucceed`. But I have to
pass the object everywhere
[
https://issues.apache.org/jira/browse/FLINK-27279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27279:
---
Labels: pull-request-available (was: )
> Extract common status interfaces
> ---
Aitozi opened a new pull request, #176:
URL: https://github.com/apache/flink-kubernetes-operator/pull/176
This pr is meant to extract common status interfaces to simplify the
ReconcileUtils
**The brief change log**
1. Introduce the `CommonView` and `SpecView` to describe the co
chinmayms commented on code in PR #19540:
URL: https://github.com/apache/flink/pull/19540#discussion_r854653554
##
flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/S3FileSystemFactory.java:
##
@@ -94,6 +94,11 @@ protected URI getInitURI(URI fsUri,
[
https://issues.apache.org/jira/browse/FLINK-26091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26091:
---
Labels: auto-deprioritized-major test-stability (was: stale-major
test-stability)
Pri
[
https://issues.apache.org/jira/browse/FLINK-26084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26084:
---
Labels: auto-deprioritized-major test-stability (was: stale-major
test-stability)
Pri
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15736:
---
Labels: auto-deprioritized-major pull-request-available stale-assigned
(was: auto-depriorit
[
https://issues.apache.org/jira/browse/FLINK-25691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25691:
---
Labels: auto-deprioritized-critical stale-major test-stability (was:
auto-deprioritized-cri
[
https://issues.apache.org/jira/browse/FLINK-25875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25875:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available stal
[
https://issues.apache.org/jira/browse/FLINK-26082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26082:
---
Labels: auto-deprioritized-major test-stability (was: stale-major
test-stability)
Pri
[
https://issues.apache.org/jira/browse/FLINK-24349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24349:
---
Labels: auto-deprioritized-major pull-request-available stale-assigned
(was: auto-depriorit
[
https://issues.apache.org/jira/browse/FLINK-26083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26083:
---
Labels: auto-deprioritized-major test-stability (was: stale-major
test-stability)
Pri
[
https://issues.apache.org/jira/browse/FLINK-23882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-23882:
---
Labels: auto-deprioritized-major stale-assigned starter (was:
auto-deprioritized-major star
flinkbot commented on PR #19542:
URL: https://github.com/apache/flink/pull/19542#issuecomment-1104519708
## CI report:
* 16754e4febd23885e1ab1ad8d1893e630e6113ae UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
stevenzwu commented on code in PR #19540:
URL: https://github.com/apache/flink/pull/19540#discussion_r854610694
##
flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/S3FileSystemFactory.java:
##
@@ -94,6 +94,11 @@ protected URI getInitURI(URI fsUri,
mans2singh opened a new pull request, #19542:
URL: https://github.com/apache/flink/pull/19542
## What is the purpose of the change
* Doc corrections in incremental checkpoint section
## Brief change log
* Updated ... **checkpoont** is enabled, the `Checkpointed Data S
chinmayms commented on PR #19514:
URL: https://github.com/apache/flink/pull/19514#issuecomment-1104483667
@MartijnVisser These changes will also need some code changes to make it
compile. Please refer to a PR that we opened for those #19540
Can we combine the changes in your PR in
flinkbot commented on PR #19541:
URL: https://github.com/apache/flink/pull/19541#issuecomment-1104481116
## CI report:
* f7338d77d22b41cb8fdfae898f35878427c2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27167:
---
Labels: pull-request-available test-stability (was: test-stability)
> Deploying master snap
JingGe opened a new pull request, #19541:
URL: https://github.com/apache/flink/pull/19541
## What is the purpose of the change
got "javadoc: error - class file for
org.junit.platform.commons.annotation.Testable not found" error while
performing javadoc-plugin.
## Brief cha
GezimSejdiu commented on PR #170:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/170#issuecomment-1104478327
>
> @GezimSejdiu Thanks for your explanation. I still have some questions
before we could merge this PR.
>
> * IIUC, we need to create a `gh-pag
tweise commented on PR #19514:
URL: https://github.com/apache/flink/pull/19514#issuecomment-1104477731
Please see https://github.com/apache/flink/pull/19540
--
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
flinkbot commented on PR #19540:
URL: https://github.com/apache/flink/pull/19540#issuecomment-1104475376
## CI report:
* c36003b4103651f35d414a4eac88e7a3dd3f34e3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27333:
---
Labels: pull-request-available (was: )
> Upgrade flink-filesystems hadoop version to versio
chinmayms opened a new pull request, #19540:
URL: https://github.com/apache/flink/pull/19540
## What is the purpose of the change
This PR upgrades flink-filesystems hadoop version to 3.3.2 and makes the
necessary code changes as part of changes to constructors in hadoop 3.3.2 code.
flinkbot commented on PR #19539:
URL: https://github.com/apache/flink/pull/19539#issuecomment-1104442650
## CI report:
* 5d33da5076a78a68ea55867da16fc37d55fd5782 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-24721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24721:
---
Labels: pull-request-available stale-assigned starter (was: stale-assigned
starter)
> Upda
zentol opened a new pull request, #19539:
URL: https://github.com/apache/flink/pull/19539
The default relativePath works for everything, so there's no need to set it
explicitly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-27287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-27287:
-
Issue Type: Technical Debt (was: Bug)
> Tests use MiniCluster without random ports
> --
[
https://issues.apache.org/jira/browse/FLINK-27287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-27287:
-
Summary: Tests use MiniCluster without random ports (was:
FileExecutionGraphInfoStoreTe
[
https://issues.apache.org/jira/browse/FLINK-27206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27206.
Release Note: Configuring reporters by their class has been deprecated.
Reporter implement
zentol merged PR #19444:
URL: https://github.com/apache/flink/pull/19444
--
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-27333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525270#comment-17525270
]
Sergey Nuyanzin commented on FLINK-27333:
-
Isn't this one a duplicate for
https
rkhachatryan commented on code in PR #19142:
URL: https://github.com/apache/flink/pull/19142#discussion_r854517171
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogStorageView.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-27287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17524967#comment-17524967
]
Chesnay Schepler edited comment on FLINK-27287 at 4/20/22 8:31 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-27317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27317.
Resolution: Fixed
master:
fb82e94d60298ed9aa604ed97cd1f0933c70c51b
07c50aa64965502716ca9f7
[
https://issues.apache.org/jira/browse/FLINK-27325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27325.
Resolution: Fixed
master: e77cd23dff79c7ff93aa0d4a187b8bcd1f617341
> Remove unnecessary f
zentol merged PR #19532:
URL: https://github.com/apache/flink/pull/19532
--
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
zentol merged PR #19524:
URL: https://github.com/apache/flink/pull/19524
--
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
rkhachatryan commented on code in PR #19142:
URL: https://github.com/apache/flink/pull/19142#discussion_r854515976
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationSwitchStateBackendITCase.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed
rkhachatryan commented on code in PR #19142:
URL: https://github.com/apache/flink/pull/19142#discussion_r854505121
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java:
##
@@ -358,17 +360,51 @@ public static boolean
stateBackendFromApplicationOr
rkhachatryan commented on code in PR #19142:
URL: https://github.com/apache/flink/pull/19142#discussion_r854497343
##
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java:
##
@@ -302,4 +354,14 @@ private long
[
https://issues.apache.org/jira/browse/FLINK-27333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chinmay Sumant updated FLINK-27333:
---
Description:
We have a security requirement to client side encrypt flink state for certain
Chinmay Sumant created FLINK-27333:
--
Summary: Upgrade flink-filesystems hadoop version to version 3.3.2
Key: FLINK-27333
URL: https://issues.apache.org/jira/browse/FLINK-27333
Project: Flink
1 - 100 of 370 matches
Mail list logo