luoyuxia commented on PR #5:
URL:
https://github.com/apache/flink-connector-hive/pull/5#issuecomment-1837025511
Cool! @snuyanzin Thanks for the pr. Sorry for the late response for I'm
busy with other things. I'll definitely have a look in next week.
--
This is an automated message from
gyfora commented on PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#issuecomment-1837021377
@mxm i would like to take a look tomorrow or Monday morning because today
I’m traveling.
--
This is an automated message from the Apache Git Service.
To respond to the m
alpinegizmo merged PR #66:
URL: https://github.com/apache/flink-training/pull/66
--
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
alpinegizmo commented on PR #66:
URL: https://github.com/apache/flink-training/pull/66#issuecomment-1837007643
Thanks for the update!
--
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
[
https://issues.apache.org/jira/browse/FLINK-33698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-33698.
---
Fix Version/s: 1.19.0
Resolution: Fixed
fixed in master: 5da214c963c219c8b3da727ffde5d6995b37
lincoln-lil merged PR #23830:
URL: https://github.com/apache/flink/pull/23830
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.a
tzulitai closed pull request #700: Add Kafka connector v3.0.2 release
URL: https://github.com/apache/flink-web/pull/700
--
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 unsub
[
https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-33638.
---
Resolution: Fixed
> Support variable-length data generation for variable-length data types
> ---
[
https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-33638:
Component/s: (was: Connectors / Common)
> Support variable-length data generation for variable
[
https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-33638:
Component/s: Table SQL / Ecosystem
> Support variable-length data generation for variable-length d
[
https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792277#comment-17792277
]
lincoln lee commented on FLINK-33638:
-
fixed in master: ac707cfeb24585ec4d68ee3dee22
[
https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-33638:
Fix Version/s: 1.19.0
> Support variable-length data generation for variable-length data types
> -
lincoln-lil merged PR #23810:
URL: https://github.com/apache/flink/pull/23810
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.a
lincoln-lil commented on PR #23810:
URL: https://github.com/apache/flink/pull/23810#issuecomment-1836961492
looks good, merging.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comme
jnh5y commented on code in PR #23821:
URL: https://github.com/apache/flink/pull/23821#discussion_r1412552616
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java:
##
@@ -0,0 +1,221 @@
+/*
+ * Licen
dependabot[bot] opened a new pull request, #37:
URL: https://github.com/apache/flink-connector-opensearch/pull/37
Bumps
[org.opensearch:opensearch](https://github.com/opensearch-project/OpenSearch)
from 1.3.0 to 2.11.1.
Release notes
Sourced from https://github.com/opensearch-proj
flinkbot commented on PR #23855:
URL: https://github.com/apache/flink/pull/23855#issuecomment-1836512337
## CI report:
* ef1b449c5654fb6430d486a5e16a00cbe7d93101 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33672:
---
Labels: pull-request-available (was: )
> Use MapState.entries() instead of keys() and get()
Zakelly opened a new pull request, #23855:
URL: https://github.com/apache/flink/pull/23855
## What is the purpose of the change
This PR replaces any combination of key iteration and getting the value for
iterated key from MapState with a entry iteration followed by getKey() and
getVa
snuyanzin commented on code in PR #23844:
URL: https://github.com/apache/flink/pull/23844#discussion_r1412350731
##
flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/HadoopS3AccessHelper.java:
##
@@ -68,7 +68,7 @@ public HadoopS3AccessHelper(S3AFile
afedulov commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412305985
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180
mxm commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412287210
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180,13 +
mxm commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412278454
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180,13 +
mxm commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412274565
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -137,7 +1
[
https://issues.apache.org/jira/browse/FLINK-33470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-33470.
Resolution: Implemented
Implemented in
e886dfdda6cd927548c8af0a88e78171e7ba34a8..5edc7d7b
dawidwys merged PR #23680:
URL: https://github.com/apache/flink/pull/23680
--
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
[
https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32878.
--
Resolution: Fixed
> Add entropy to gcs path for better scalability
> -
[
https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792115#comment-17792115
]
Martijn Visser commented on FLINK-32878:
I reverted this change via c7da98f23c3f
flinkbot commented on PR #23854:
URL: https://github.com/apache/flink/pull/23854#issuecomment-1836316123
## CI report:
* 6fee7e7286b062c51a2153322fab684baadfd813 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiangyu feng updated FLINK-33702:
-
Summary: Add IncrementalDelayRetryStrategy implementation of RetryStrategy
(was: Add Incrementa
[
https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiangyu feng updated FLINK-33702:
-
Description:
RetryStrategy now supports FixedRetryStrategy and
ExponentialBackoffRetryStrategy.
[
https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiangyu feng reopened FLINK-33702:
--
`RetryStrategy` in org.apache.flink.util.concurrent can be used in
`CollectResultFetcher`.
> Add
dawidwys commented on code in PR #23821:
URL: https://github.com/apache/flink/pull/23821#discussion_r1412233154
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java:
##
@@ -0,0 +1,221 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reopened FLINK-32878:
> Add entropy to gcs path for better scalability
> ---
1996fanrui commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412210561
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -1
liyubin117 commented on PR #23810:
URL: https://github.com/apache/flink/pull/23810#issuecomment-1836237987
@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
MartijnVisser commented on PR #23184:
URL: https://github.com/apache/flink/pull/23184#issuecomment-1836233132
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
gyfora commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412198646
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180,1
MartijnVisser closed pull request #23184: [BP-1.17][FLINK-32815][table] Add
HASHCODE function.
URL: https://github.com/apache/flink/pull/23184
--
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 spe
1996fanrui commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412192687
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -1
MartijnVisser commented on PR #23190:
URL: https://github.com/apache/flink/pull/23190#issuecomment-1836227462
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser commented on PR #23189:
URL: https://github.com/apache/flink/pull/23189#issuecomment-1836227280
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23176: [BP-1.17][FLINK-32264][table]
Add-built-in FIELD-function.
URL: https://github.com/apache/flink/pull/23176
--
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 t
MartijnVisser commented on PR #23188:
URL: https://github.com/apache/flink/pull/23188#issuecomment-1836227209
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser commented on PR #23176:
URL: https://github.com/apache/flink/pull/23176#issuecomment-1836226643
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser commented on PR #23175:
URL: https://github.com/apache/flink/pull/23175#issuecomment-1836226568
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23175:
[BP-1.17][FLINK-32263][table]Add-ELT-function
URL: https://github.com/apache/flink/pull/23175
--
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 c
MartijnVisser commented on PR #23186:
URL: https://github.com/apache/flink/pull/23186#issuecomment-1836226201
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23190: [BP1.17][FLINK-32720][table] Add
built-in GENERATE_SERIES function
URL: https://github.com/apache/flink/pull/23190
--
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
MartijnVisser closed pull request #23177: [BP-1.17][FLINK-32706][table] Add
built-in SPLIT_STRING function
URL: https://github.com/apache/flink/pull/23177
--
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 g
MartijnVisser commented on PR #23177:
URL: https://github.com/apache/flink/pull/23177#issuecomment-1836227367
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23189: [BP-1.17][FLINK-32565][table] Support
Cast From NUMBER to BYTES
URL: https://github.com/apache/flink/pull/23189
--
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
MartijnVisser closed pull request #23188: [BP-1.17][FLINK-32564][table] Support
Cast From BYTES to NUMBER
URL: https://github.com/apache/flink/pull/23188
--
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
MartijnVisser commented on PR #23151:
URL: https://github.com/apache/flink/pull/23151#issuecomment-1836225820
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23151: [BP-1.17][FLINK-32256][table] Add
built-in ARRAY_ MIN function.
URL: https://github.com/apache/flink/pull/23151
--
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
MartijnVisser commented on PR #23194:
URL: https://github.com/apache/flink/pull/23194#issuecomment-1836225515
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser commented on PR #23144:
URL: https://github.com/apache/flink/pull/23144#issuecomment-1836226481
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23144: [BP-1.17][FLINK-32261][table] Add
built-in MAP_UNION function.
URL: https://github.com/apache/flink/pull/23144
--
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
MartijnVisser closed pull request #23186: [BP-1.17][FLINK-31664][table]Add
ARRAY_INTERSECT function
URL: https://github.com/apache/flink/pull/23186
--
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
MartijnVisser commented on PR #23185:
URL: https://github.com/apache/flink/pull/23185#issuecomment-1836226100
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23185: [BP-1.17][FLINK-31663][table]
Add-ARRAY_EXCEPT-function.
URL: https://github.com/apache/flink/pull/23185
--
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
MartijnVisser commented on PR #23158:
URL: https://github.com/apache/flink/pull/23158#issuecomment-1836225967
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23158: [BP-1.17] [FLINK-26948][table]
Add-ARRAY_SORT-function.
URL: https://github.com/apache/flink/pull/23158
--
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
MartijnVisser commented on PR #23149:
URL: https://github.com/apache/flink/pull/23149#issuecomment-1836225680
Closing this PR since we don't backport new features into existing releases
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
MartijnVisser closed pull request #23194: [BP-1.17]historgram
URL: https://github.com/apache/flink/pull/23194
--
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-
mxm commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412183304
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180,13 +
MartijnVisser commented on PR #23149:
URL: https://github.com/apache/flink/pull/23149#issuecomment-1836221184
Closing since we don't backport new functions into existing releases, only
into new ones
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
MartijnVisser closed pull request #23149: [BP-1.17][FLINK-32257][table] Add
built-in ARRAY_MAX function.
URL: https://github.com/apache/flink/pull/23149
--
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
MartijnVisser commented on PR #23145:
URL: https://github.com/apache/flink/pull/23145#issuecomment-1836220874
Closing since we don't backport new functions into existing releases, only
into new ones
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
MartijnVisser closed pull request #23145: [BP-1.17][FLINK-31665] [table] Add
ARRAY_CONCAT function
URL: https://github.com/apache/flink/pull/23145
--
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
mxm commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412176016
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180,13 +
jnh5y commented on code in PR #23821:
URL: https://github.com/apache/flink/pull/23821#discussion_r1412167278
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java:
##
@@ -0,0 +1,221 @@
+/*
+ * Licen
gyfora commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412164693
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -137,7
gyfora commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412161793
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180,1
liyubin117 commented on code in PR #23810:
URL: https://github.com/apache/flink/pull/23810#discussion_r1412149258
##
docs/content.zh/docs/connectors/table/datagen.md:
##
@@ -29,51 +29,202 @@ under the License.
{{< label "Scan Source: 有界" >}}
{{< label "Scan Source: 无界" >}}
-
liyubin117 commented on code in PR #23810:
URL: https://github.com/apache/flink/pull/23810#discussion_r1412147094
##
docs/content.zh/docs/connectors/table/datagen.md:
##
@@ -29,51 +29,202 @@ under the License.
{{< label "Scan Source: 有界" >}}
{{< label "Scan Source: 无界" >}}
-
[
https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiangyu feng closed FLINK-33702.
Resolution: Not A Problem
`AsyncRetryStrategy` is designed for AsyncWaitOperator to use. It may no
lincoln-lil commented on code in PR #23810:
URL: https://github.com/apache/flink/pull/23810#discussion_r1412107586
##
docs/content.zh/docs/connectors/table/datagen.md:
##
@@ -29,51 +29,202 @@ under the License.
{{< label "Scan Source: 有界" >}}
{{< label "Scan Source: 无界" >}}
afedulov commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412106299
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180
afedulov commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412106299
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180
afedulov commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1412106299
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -180
MartijnVisser commented on PR #23226:
URL: https://github.com/apache/flink/pull/23226#issuecomment-1836116534
Also @singhravidutt what's your Jira user name, so I can assign this ticket
to you?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
MartijnVisser commented on PR #23226:
URL: https://github.com/apache/flink/pull/23226#issuecomment-1836115444
@singhravidutt Could you please squash your commits and rebase? Your commit
message should start `[FLINK-32877][Filesystem]` as well.
--
This is an automated message from the Apa
[
https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32878.
--
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed in apache/flink:master dc1db12137ecad921a
[
https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-32878:
--
Assignee: Cheena (was: Jayadeep Jayaraman)
> Add entropy to gcs path for better scal
MartijnVisser merged PR #23729:
URL: https://github.com/apache/flink/pull/23729
--
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
[
https://issues.apache.org/jira/browse/FLINK-32878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-32878:
--
Assignee: Jayadeep Jayaraman
> Add entropy to gcs path for better scalability
> -
[
https://issues.apache.org/jira/browse/FLINK-33508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-33508:
--
Assignee: Jayadeep Jayaraman
> Support for wildcard paths in Flink History Server for
dawidwys commented on code in PR #23821:
URL: https://github.com/apache/flink/pull/23821#discussion_r1412092205
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeTestPrograms.java:
##
@@ -0,0 +1,221 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-33694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792050#comment-17792050
]
Patrick Lucas commented on FLINK-33694:
---
[~martijnvisser] my comment is perhaps no
mxm commented on PR #720:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/720#issuecomment-1836099166
No harm done @1996fanrui! Thanks for the quick review!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
tagarr commented on PR #712:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/712#issuecomment-1836094102
@gaborgsomogyi are my changes what you expected ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Myasuka commented on code in PR #23820:
URL: https://github.com/apache/flink/pull/23820#discussion_r1412050762
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/ProfilingService.java:
##
@@ -0,0 +1,194 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
[
https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792024#comment-17792024
]
Peter Schulz commented on FLINK-32028:
--
I gave it [a
try|https://github.com/apache
echauchot commented on code in PR #25:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/25#discussion_r1412014261
##
pom.xml:
##
@@ -558,6 +563,8 @@ under the License.
US
en
echauchot commented on PR #25:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/25#issuecomment-1835994166
>> @snuyanzin can you elaborate on the use cases you have in mind for
systemPropertyVariable surefire.module.config ?
> The use case is testing against jdk17/21
[
https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32028:
---
Labels: pull-request-available (was: )
> Error handling for the new Elasticsearch sink
> --
boring-cyborg[bot] commented on PR #83:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/83#issuecomment-1835980923
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
T
schulzp opened a new pull request, #83:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/83
Extracted `BulkResponseInspector` interface to allow custom handling of
(partially) failed bulk requests. If not overridden, default behaviour remains
unchanged and partial failures
Jes Cok created FLINK-33725:
---
Summary: MathUtils.isPowerOf2 does not cover the case of value=0
Key: FLINK-33725
URL: https://issues.apache.org/jira/browse/FLINK-33725
Project: Flink
Issue Type: Im
1 - 100 of 158 matches
Mail list logo
