z3d1k opened a new pull request, #139:
URL: https://github.com/apache/flink-connector-aws/pull/139
## Purpose of the change
Change logging level for information about records failed to be written by
Kinesis and Firehose sinks from `debug` to `warn`.
Similar configuration is already
hlteoh37 commented on code in PR #139:
URL:
https://github.com/apache/flink-connector-aws/pull/139#discussion_r1583398674
##
flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java:
##
@@ -22
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1583447345
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/OneInputTransformation.java:
##
@@ -42,7 +42,7 @@
* @param The type of the
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1583446509
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageGraph.java:
##
@@ -20,13 +20,12 @@
package org.apache.flink.streaming.api.line
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1583451354
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/lineage/TableColumnLineageEdge.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Ap
HCTommy opened a new pull request, #24747:
URL: https://github.com/apache/flink/pull/24747
## What is the purpose of the change
This pull request is to show more info in some logs, which helps a lot when
debugging in production environment
## Does this pull request pote
HCTommy commented on PR #24747:
URL: https://github.com/apache/flink/pull/24747#issuecomment-2083286683
Hi @zhuzhurk , I optimized some logs, which I think is helpful for people to
debug in production environment. Could you please review in your available time.
--
This is an automated mes
jeyhunkarimov commented on PR #24659:
URL: https://github.com/apache/flink/pull/24659#issuecomment-2083288208
Hi @empathy87 sorry for the late reply.
--
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
flinkbot commented on PR #24747:
URL: https://github.com/apache/flink/pull/24747#issuecomment-2083291280
## CI report:
* 9a53729a7c3d968977bcbae010246a28269f9359 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jeyhunkarimov commented on code in PR #24659:
URL: https://github.com/apache/flink/pull/24659#discussion_r1583468743
##
flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcFileSystemITCase.java:
##
@@ -208,6 +208,15 @@ void testOrcFilterPushDown() throws ExecutionExcep
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1583475226
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/lineage/ModifyType.java:
##
@@ -0,0 +1,34 @@
+/*
+ * Licensed to the Apache Softwar
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1583476719
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/ValuesSource.java:
##
@@ -52,7 +60,9 @@
* must be 1. RowData is not serializab
HuangZhenQiu commented on PR #24618:
URL: https://github.com/apache/flink/pull/24618#issuecomment-2083346268
@davidradl
Thanks for reviewing this PR. This PR is mainly to handle with source/sink
level lineage, column level lineage will be need a further discussion in
community. Resolved
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1583828939
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1583828939
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1583828939
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1583828939
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
jeyhunkarimov commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1583695410
##
flink-core-api/src/main/java/org/apache/flink/api/common/operators/SlotSharingGroupDescriptor.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Softwar
mas-chen merged PR #97:
URL: https://github.com/apache/flink-connector-kafka/pull/97
--
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...@
boring-cyborg[bot] commented on PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#issuecomment-2083840330
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
xuyangzhong commented on PR #24728:
URL: https://github.com/apache/flink/pull/24728#issuecomment-2084076648
The doc jira is: https://issues.apache.org/jira/browse/FLINK-35271
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
lsyldliu closed pull request #24737: [FLINK-35191][table] Support alter
materialized table related syntaxes: suspend, resume, refresh, set and reset
URL: https://github.com/apache/flink/pull/24737
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
lsyldliu commented on PR #24737:
URL: https://github.com/apache/flink/pull/24737#issuecomment-2084089129
Sorry for forgetting to approve, +1.
--
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 s
lsyldliu closed pull request #24703: [FLINK-35184][table-runtime] fix minibatch
join hash collision
URL: https://github.com/apache/flink/pull/24703
--
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 th
lsyldliu merged PR #24745:
URL: https://github.com/apache/flink/pull/24745
--
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.apac
lsyldliu commented on PR #24744:
URL: https://github.com/apache/flink/pull/24744#issuecomment-2084205892
The CI is failed.
--
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
lsyldliu commented on PR #24743:
URL: https://github.com/apache/flink/pull/24743#issuecomment-2084206324
The CI is failed
--
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
yuchen-ecnu commented on PR #24689:
URL: https://github.com/apache/flink/pull/24689#issuecomment-2084282176
Hi @yeezychao , sorry for the late response.
It's not enough to just change the request type on the front end, you also
need to modify the type of the corresponding REST interface o
fredia opened a new pull request, #24748:
URL: https://github.com/apache/flink/pull/24748
## What is the purpose of the change
This PR introduces Epoch Manager to handle watermark and watermark status
processing under async execution.
Epoch manager segments inputs into dist
flinkbot commented on PR #24748:
URL: https://github.com/apache/flink/pull/24748#issuecomment-2084288856
## CI report:
* 9f3239c4bebe6a60ae8db7892e7df1a58fc868f0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2084313431
cc @SinBex and @JunRuiLee for reviews.
--
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 th
rovboyko opened a new pull request, #24749:
URL: https://github.com/apache/flink/pull/24749
## What is the purpose of the change
This change fixes the possible error because of hash collision in
MiniBatchStreamingJoinOperator
## Brief change log
Currently for
flinkbot commented on PR #24749:
URL: https://github.com/apache/flink/pull/24749#issuecomment-2084336643
## CI report:
* cba2e44d01b250e2de4619ba40af17709feb4786 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingGe merged PR #24746:
URL: https://github.com/apache/flink/pull/24746
--
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
gyfora commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584144759
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,16
yeezychao commented on PR #24689:
URL: https://github.com/apache/flink/pull/24689#issuecomment-2084432438
Hi @yuchen-ecnu, I agreee with you,so I created issues
[YARN-11691](https://issues.apache.org/jira/browse/YARN-11691) to the YARN
community.
--
This is an automated message from the
fredia commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1584188915
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java:
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed to the Apache
lsyldliu closed pull request #24728: [FLINK-35194][table] Support describe job
with job id
URL: https://github.com/apache/flink/pull/24728
--
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 specifi
yunfengzhou-hub commented on code in PR #24698:
URL: https://github.com/apache/flink/pull/24698#discussion_r1584175343
##
flink-core/src/main/java/org/apache/flink/core/state/StateFutureImpl.java:
##
@@ -46,123 +46,169 @@ public class StateFutureImpl implements
InternalStateFut
empathy87 commented on code in PR #24659:
URL: https://github.com/apache/flink/pull/24659#discussion_r1584273004
##
flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcFileSystemITCase.java:
##
@@ -208,6 +208,15 @@ void testOrcFilterPushDown() throws ExecutionException
bgeng777 opened a new pull request, #822:
URL: https://github.com/apache/flink-kubernetes-operator/pull/822
## What is the purpose of the change
According to
[FLINK-35192](https://issues.apache.org/jira/browse/FLINK-35192), the usage of
file.deleteOnExit() will register a hashmap
lsyldliu opened a new pull request, #24750:
URL: https://github.com/apache/flink/pull/24750
## What is the purpose of the change
*Support the execution of create materialized table in continuous refresh
mode*
## Brief change log
- *Support the execution of create m
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584361582
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
flinkbot commented on PR #24750:
URL: https://github.com/apache/flink/pull/24750#issuecomment-2084709081
## CI report:
* 9970141f26ce36804d528727728eb23648a1201f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584364578
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -830,6 +832,8 @@ public CompletableFuture submitTask(
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584375937
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584382431
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void createManagedDi
twalthr merged PR #24724:
URL: https://github.com/apache/flink/pull/24724
--
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
ljz2051 commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1584427802
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java:
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed to the Apache
ljz2051 commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1584431128
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to t
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584443822
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
-->
ljz2051 commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r158208
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStValueState.java:
##
@@ -95,4 +100,32 @@ public V deserializeValue(byte[
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584445284
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
-->
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584451630
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
-->
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584453151
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
-->
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584453635
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
-->
kottmann commented on PR #22789:
URL: https://github.com/apache/flink/pull/22789#issuecomment-2084837876
This is fixed now as well, see new commit.
--
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
jectpro7 commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1584465123
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -74,15 +76,20 @@ public
fredia commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1584477969
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to th
fredia commented on code in PR #24698:
URL: https://github.com/apache/flink/pull/24698#discussion_r1584530942
##
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/StateFuture.java:
##
@@ -49,7 +49,7 @@ public interface StateFuture {
* @param action the acti
boring-cyborg[bot] commented on PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#issuecomment-2084941773
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
yuxiqian opened a new pull request, #3285:
URL: https://github.com/apache/flink-cdc/pull/3285
This closes [FLINK-35272](https://issues.apache.org/jira/browse/FLINK-35272).
Currently, pipeline jobs with transform (including projection and filtering)
are constructed with the following t
eskabetxe commented on code in PR #116:
URL:
https://github.com/apache/flink-connector-jdbc/pull/116#discussion_r1584601921
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java:
##
@@ -88,32 +92,49 @@ public abstract class Abstr
gong commented on PR #3283:
URL: https://github.com/apache/flink-cdc/pull/3283#issuecomment-2085021893
@PatrickRen PTAL
--
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 u
gong commented on PR #3284:
URL: https://github.com/apache/flink-cdc/pull/3284#issuecomment-2085022086
@PatrickRen PTAL
--
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 u
StefanRRichter merged PR #24722:
URL: https://github.com/apache/flink/pull/24722
--
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...@flin
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584685732
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
+
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584685732
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
+
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584710588
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeRowConverter.java:
##
@@ -0,0 +1,45 @@
+/*
+ *
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584685732
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
+
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584710588
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeRowConverter.java:
##
@@ -0,0 +1,45 @@
+/*
+ *
ThisisWilli commented on PR #2494:
URL: https://github.com/apache/flink-cdc/pull/2494#issuecomment-2085275760
> Hi @ThisisWilli, thanks for your great contribution! Could you please
rebase this PR with latest `master` branch? You may need to rename some
packages like from `com.ververica.cdc
gaborgsomogyi commented on code in PR #819:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/819#discussion_r1584790463
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java:
##
@@ -165,13 +194,21 @@ pri
StefanRRichter opened a new pull request, #24751:
URL: https://github.com/apache/flink/pull/24751
Backport of FLINK-35217 for 1.19
(cherry picked from commit 80af4d502318348ba15a8f75a2a622ce9dbdc968)
--
This is an automated message from the Apache Git Service.
To respond to
mbalassi commented on code in PR #819:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/819#discussion_r1584810870
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java:
##
@@ -165,13 +194,21 @@ private
flinkbot commented on PR #24751:
URL: https://github.com/apache/flink/pull/24751#issuecomment-2085320237
## CI report:
* e5d3c1296ac763d40175720c8fff58716ab1a3b1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24752:
URL: https://github.com/apache/flink/pull/24752#issuecomment-2085320637
## CI report:
* 0670f3aec8b7aaa6db1192a8cdead22d9c6b925b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mbalassi commented on code in PR #819:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/819#discussion_r1584812594
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java:
##
@@ -94,6 +101,22 @@ public voi
kottmann commented on PR #22789:
URL: https://github.com/apache/flink/pull/22789#issuecomment-2085392466
@ferenc-csaky Thank you for reviewing my PR and for your helpful feedback! I
really appreciate your support in improving it.
--
This is an automated message from the Apache Git Service
vinlee19 commented on PR #3286:
URL: https://github.com/apache/flink-cdc/pull/3286#issuecomment-2085539643
@ruanhang1993 @gong PTAL
--
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 co
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
gyfora commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585008279
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,16
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585113359
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,
borislitvak commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1585423831
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeRowConverter.java:
##
@@ -0,0 +1,45 @@
+/*
+
borislitvak commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1585425522
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
StefanRRichter merged PR #24751:
URL: https://github.com/apache/flink/pull/24751
--
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...@flin
StefanRRichter merged PR #24752:
URL: https://github.com/apache/flink/pull/24752
--
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...@flin
h12567 commented on PR #24750:
URL: https://github.com/apache/flink/pull/24750#issuecomment-2087873976
May I ask how to find the list of issues/requests I can contribute to?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
JTaky opened a new pull request, #24753:
URL: https://github.com/apache/flink/pull/24753
Provide a way to ingest retrier settings configuration to gcs-cloud-storage
library in use.
## Brief change log
- exposed `gs.retry.max-attempt`, `gs.retry.init-rpc-timeout`,
`
flinkbot commented on PR #24753:
URL: https://github.com/apache/flink/pull/24753#issuecomment-2088082229
## CI report:
* 1fb740aaac47908e4162fb8cef213c965841288f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on PR #24741:
URL: https://github.com/apache/flink/pull/24741#issuecomment-2088277865
@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
davidradl commented on PR #24741:
URL: https://github.com/apache/flink/pull/24741#issuecomment-2088287202
@reswqa junit errors in the pr build - I will investigate
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
101 - 200 of 1780 matches
Mail list logo
