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
[
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
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:
[
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
[
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:
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:
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
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
[
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
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
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
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:
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.
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
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
[
https://issues.apache.org/jira/browse/FLINK-27329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525394#comment-17525394
]
Yang Wang commented on FLINK-27329:
---
Could we take this opportunity to review all the default values?
[
https://issues.apache.org/jira/browse/FLINK-27332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525392#comment-17525392
]
Yun Tang commented on FLINK-27332:
--
This is by design, which is introduced by FLINK-25191. And you can
[
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
[
https://issues.apache.org/jira/browse/FLINK-27328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525391#comment-17525391
]
Yang Wang commented on FLINK-27328:
---
If you are using {{"--host", "$POD_IP"}} to make the JobManager
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
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
[
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
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:
[
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:
[
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:
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
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
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
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
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
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)
[
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)
[
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:
[
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:
[
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
[
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)
[
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
[
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)
[
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:
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
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
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
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
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
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
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)
>
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
[
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:
[
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
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:
[
https://issues.apache.org/jira/browse/FLINK-27333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525270#comment-17525270
]
Sergey Nuyanzin commented on FLINK-27333:
-
Isn't this one a duplicate for
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=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
[
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
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:
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:
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 @@
+/*
+ *
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
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
[
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
rkhachatryan commented on code in PR #19142:
URL: https://github.com/apache/flink/pull/19142#discussion_r854496285
##
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/restore/ChangelogRestoreTarget.java:
##
@@ -0,0 +1,52 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-26926:
--
Assignee: Nicholas Jiang
> Allow users to force upgrade even if savepoint is in progress
>
snuyanzin commented on PR #19467:
URL: https://github.com/apache/flink/pull/19467#issuecomment-1104380485
Thanks for the feedback
I addressed your comments: added `TestLoggerExtension`, removed not
necessary public modifiers
--
This is an automated message from the Apache Git Service.
rkhachatryan commented on PR #19297:
URL: https://github.com/apache/flink/pull/19297#issuecomment-1104349222
Thanks for the PR @hehuiyuan , I'm also not an expert in connectors/JDBC.
@fapaul, @JingsongLi, maybe you could take a look?
--
This is an automated message from the Apache Git
Darcy Lin created FLINK-27332:
-
Summary:
org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't receive
completion notification for savepoint
Key: FLINK-27332
URL:
[
https://issues.apache.org/jira/browse/FLINK-27314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525137#comment-17525137
]
Fuyao Li commented on FLINK-27314:
--
I see. Maybe upstream Flink is the better place. This is not of
snuyanzin commented on PR #19535:
URL: https://github.com/apache/flink/pull/19535#issuecomment-1104203838
@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
snuyanzin commented on code in PR #19467:
URL: https://github.com/apache/flink/pull/19467#discussion_r854370994
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/TableApiIdentifierParsingTest.java:
##
@@ -26,49 +26,44 @@
import
snuyanzin commented on code in PR #19467:
URL: https://github.com/apache/flink/pull/19467#discussion_r854370777
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/CreateTableLikeTest.java:
##
@@ -48,10 +47,8 @@
/** Tests for parsing and validating {@link
snuyanzin commented on code in PR #19467:
URL: https://github.com/apache/flink/pull/19467#discussion_r854370506
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkDDLDataTypeTest.java:
##
@@ -52,195 +52,203 @@
import
snuyanzin commented on code in PR #19467:
URL: https://github.com/apache/flink/pull/19467#discussion_r854370265
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/TableApiIdentifierParsingTest.java:
##
@@ -26,49 +26,44 @@
import
snuyanzin commented on PR #19467:
URL: https://github.com/apache/flink/pull/19467#issuecomment-1104195895
@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
zhuanshenbsj1 commented on PR #19509:
URL: https://github.com/apache/flink/pull/19509#issuecomment-1104147236
> @zhuanshenbsj1 Thanks for this, but I actually think this should not be
removed from the Chinese version but added to the English documentation
@MartijnVisser Thanks for
flinkbot commented on PR #19538:
URL: https://github.com/apache/flink/pull/19538#issuecomment-1104089222
## CI report:
* 5f48c9c1bb7c958c63ca00d245a312c4c9bdcc9a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1 - 100 of 378 matches
Mail list logo
