[
https://issues.apache.org/jira/browse/FLINK-33862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33862:
--
Affects Version/s: 1.19.0
> Flink Unit Test Failures on 1.18.0
>
flinkbot commented on PR #23938:
URL: https://github.com/apache/flink/pull/23938#issuecomment-1858739524
## CI report:
* 052dab59db8f519765c51228f87277bd85b83a45 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33863:
---
Labels: pull-request-available (was: )
> Compressed Operator state restore failed
>
ruibinx opened a new pull request, #23938:
URL: https://github.com/apache/flink/pull/23938
## What is the purpose of the change
This PR fixes an issue related to restoring multiple operator states when
snapshot compression is enabled. see:
Ruibin Xing created FLINK-33863:
---
Summary: Compressed Operator state restore failed
Key: FLINK-33863
URL: https://issues.apache.org/jira/browse/FLINK-33863
Project: Flink
Issue Type: Bug
Prabhu Joseph created FLINK-33862:
-
Summary: Flink Unit Test Failures on 1.18.0
Key: FLINK-33862
URL: https://issues.apache.org/jira/browse/FLINK-33862
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33565:
Fix Version/s: 1.19.0
> The concurrentExceptions doesn't work
> -
>
>
snuyanzin commented on PR #38:
URL:
https://github.com/apache/flink-connector-opensearch/pull/38#issuecomment-1858607663
I'm curius whether multirelease jar supports cases when for the same Flink
cluster there is a necessity to use both Opensearch v1 and OpenSearch v2
connectors and both
sharath1709 commented on PR #23937:
URL: https://github.com/apache/flink/pull/23937#issuecomment-1858595168
@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 #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428571302
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
snuyanzin closed pull request #36: Make connector being tested against latest
OpenSearch 1.x and 2.x
URL: https://github.com/apache/flink-connector-opensearch/pull/36
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-33825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797333#comment-17797333
]
Jing Ge commented on FLINK-33825:
-
thanks!
> Create a new version in JIRA
>
snuyanzin commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428571302
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
[
https://issues.apache.org/jira/browse/FLINK-33779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797332#comment-17797332
]
Sergey Nuyanzin commented on FLINK-33779:
-
Merged to master as
[
https://issues.apache.org/jira/browse/FLINK-33779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33779.
-
Resolution: Fixed
> Cleanup usage of deprecated BaseExpressions#cast(TypeInformation)
>
[
https://issues.apache.org/jira/browse/FLINK-33779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33779.
---
> Cleanup usage of deprecated BaseExpressions#cast(TypeInformation)
>
[
https://issues.apache.org/jira/browse/FLINK-33779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-33779:
---
Assignee: Jacky Lau
> Cleanup usage of deprecated
snuyanzin merged PR #23895:
URL: https://github.com/apache/flink/pull/23895
--
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-33787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33787.
-
Fix Version/s: jdbc-3.2.0
Resolution: Fixed
> Java 17 support for jdbc connector
[
https://issues.apache.org/jira/browse/FLINK-33787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797330#comment-17797330
]
Sergey Nuyanzin commented on FLINK-33787:
-
Merged as
dependabot[bot] opened a new pull request, #84:
URL: https://github.com/apache/flink-connector-jdbc/pull/84
Bumps org.apache.commons:commons-compress from 1.23.0 to 1.24.0.
[![Dependabot compatibility
snuyanzin merged PR #82:
URL: https://github.com/apache/flink-connector-jdbc/pull/82
--
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:
flinkbot commented on PR #23937:
URL: https://github.com/apache/flink/pull/23937#issuecomment-1858559404
## CI report:
* e474d8114a2328c5d529d8e1084d685906ee502e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33611:
---
Labels: pull-request-available (was: )
> Support Large Protobuf Schemas
>
sharath1709 opened a new pull request, #23937:
URL: https://github.com/apache/flink/pull/23937
## What is the purpose of the change
This change is made to support large Protobuf schemas
## Brief change log
- [FLINK-33611] [flink-protobuf] Reuse
snuyanzin commented on PR #23935:
URL: https://github.com/apache/flink/pull/23935#issuecomment-1858552817
>Unchanged backport of https://github.com/apache/flink/pull/2383
is this a really correct link?
for me it shows something from 2016...
--
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sai Sharath Dandi updated FLINK-33611:
--
Summary: Support Large Protobuf Schemas (was: Add the ability to reuse
variable
JingGe commented on PR #23870:
URL: https://github.com/apache/flink/pull/23870#issuecomment-1858528411
@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.
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33858:
---
Assignee: (was: Jing Ge)
> CI fails with No space left on device
>
flinkbot commented on PR #23936:
URL: https://github.com/apache/flink/pull/23936#issuecomment-1858509241
## CI report:
* 48235d00b884cb7fbd7704556b8f8014c4350e0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
bvarghese1 commented on code in PR #23936:
URL: https://github.com/apache/flink/pull/23936#discussion_r1428498415
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest.java:
##
@@ -1,210 +0,0 @@
bvarghese1 commented on code in PR #23936:
URL: https://github.com/apache/flink/pull/23936#discussion_r1428498126
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest.java:
##
@@ -1,210 +0,0 @@
bvarghese1 commented on code in PR #23936:
URL: https://github.com/apache/flink/pull/23936#discussion_r1428498672
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest.java:
##
@@ -1,210 +0,0 @@
bvarghese1 commented on code in PR #23936:
URL: https://github.com/apache/flink/pull/23936#discussion_r1428498672
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest.java:
##
@@ -1,210 +0,0 @@
bvarghese1 commented on code in PR #23936:
URL: https://github.com/apache/flink/pull/23936#discussion_r1428498415
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest.java:
##
@@ -1,210 +0,0 @@
[
https://issues.apache.org/jira/browse/FLINK-33860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33860:
---
Labels: pull-request-available (was: )
> Implement restore tests for WindowTableFunction
bvarghese1 opened a new pull request, #23936:
URL: https://github.com/apache/flink/pull/23936
## What is the purpose of the change
*Add restore tests for WindowTableFunction node*
## Verifying this change
This change added tests and can be verified as follows:
bvarghese1 commented on code in PR #23936:
URL: https://github.com/apache/flink/pull/23936#discussion_r1428498126
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest.java:
##
@@ -1,210 +0,0 @@
Bonnie Varghese created FLINK-33861:
---
Summary: Implement restore tests for WindowRank node
Key: FLINK-33861
URL: https://issues.apache.org/jira/browse/FLINK-33861
Project: Flink
Issue
Bonnie Varghese created FLINK-33860:
---
Summary: Implement restore tests for WindowTableFunction node
Key: FLINK-33860
URL: https://issues.apache.org/jira/browse/FLINK-33860
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33859:
---
Labels: pull-request-available (was: )
> Support OpenSearch v2
> -
>
>
snuyanzin opened a new pull request, #38:
URL: https://github.com/apache/flink-connector-opensearch/pull/38
The PR adds support for OpenSearch v2
Since there are breking changes introduced in OpenSearch there is no way to
support one jar working for both v1 and v2.
For that reason
Sergey Nuyanzin created FLINK-33859:
---
Summary: Support OpenSearch v2
Key: FLINK-33859
URL: https://issues.apache.org/jira/browse/FLINK-33859
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797288#comment-17797288
]
Ricky Saltzer commented on FLINK-32212:
---
Hitting this same error after moving our jobs from being
snuyanzin commented on PR #82:
URL:
https://github.com/apache/flink-connector-jdbc/pull/82#issuecomment-1858347970
looks like gha fails to download flink, will retry a bit later
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
snuyanzin commented on code in PR #82:
URL:
https://github.com/apache/flink-connector-jdbc/pull/82#discussion_r1428365706
##
.github/workflows/weekly.yml:
##
@@ -45,6 +45,14 @@ jobs:
flink: 1.18.0,
branch: v3.1
}]
+jdk: [ 8, 11 ]
+
bvarghese1 commented on code in PR #23923:
URL: https://github.com/apache/flink/pull/23923#discussion_r1428333474
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowDeduplicateTestPrograms.java:
##
@@ -0,0 +1,287 @@
+/*
afedulov opened a new pull request, #735:
URL: https://github.com/apache/flink-kubernetes-operator/pull/735
This PR contains the following improvements to the restart tracking logic:
* Adds more debug logs
* Stores restart Duration directly instead of the endTime Instant
* Fixes a
eskabetxe commented on code in PR #82:
URL:
https://github.com/apache/flink-connector-jdbc/pull/82#discussion_r1428247514
##
.github/workflows/weekly.yml:
##
@@ -45,6 +45,14 @@ jobs:
flink: 1.18.0,
branch: v3.1
}]
+jdk: [ 8, 11 ]
+
eskabetxe commented on code in PR #82:
URL:
https://github.com/apache/flink-connector-jdbc/pull/82#discussion_r1428247514
##
.github/workflows/weekly.yml:
##
@@ -45,6 +45,14 @@ jobs:
flink: 1.18.0,
branch: v3.1
}]
+jdk: [ 8, 11 ]
+
eskabetxe commented on code in PR #82:
URL:
https://github.com/apache/flink-connector-jdbc/pull/82#discussion_r1428247514
##
.github/workflows/weekly.yml:
##
@@ -45,6 +45,14 @@ jobs:
flink: 1.18.0,
branch: v3.1
}]
+jdk: [ 8, 11 ]
+
eskabetxe commented on code in PR #82:
URL:
https://github.com/apache/flink-connector-jdbc/pull/82#discussion_r1428247514
##
.github/workflows/weekly.yml:
##
@@ -45,6 +45,14 @@ jobs:
flink: 1.18.0,
branch: v3.1
}]
+jdk: [ 8, 11 ]
+
Jiabao-Sun commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428219337
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
Jiabao-Sun commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428209269
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
snuyanzin commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428204897
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
snuyanzin commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428204897
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
snuyanzin commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428199378
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
Jiabao-Sun commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1428188735
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
singhravidutt commented on PR #23489:
URL: https://github.com/apache/flink/pull/23489#issuecomment-1858146657
Licensing issue is fixed in the latest commit but I still feel we should
exclude guava specific jars coming from `flink-fs-hadoop-shaded`. @JingGe
@MartijnVisser
singhravidutt commented on code in PR #23489:
URL: https://github.com/apache/flink/pull/23489#discussion_r1428174024
##
flink-filesystems/flink-gs-fs-hadoop/pom.xml:
##
@@ -188,6 +212,29 @@ under the License.
shade
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797237#comment-17797237
]
Jing Ge edited comment on FLINK-33858 at 12/15/23 4:19 PM:
---
I don't have the
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797237#comment-17797237
]
Jing Ge edited comment on FLINK-33858 at 12/15/23 4:12 PM:
---
I don't have the
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797237#comment-17797237
]
Jing Ge edited comment on FLINK-33858 at 12/15/23 4:12 PM:
---
I don't have the
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797237#comment-17797237
]
Jing Ge commented on FLINK-33858:
-
I don't have the access right and need to reach out the right one,
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33858:
---
Assignee: Jing Ge
> CI fails with No space left on device
> -
flinkbot commented on PR #23935:
URL: https://github.com/apache/flink/pull/23935#issuecomment-1858069389
## CI report:
* a6d11e1c44779d0f2a0f5f1901323999283410a7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on code in PR #23930:
URL: https://github.com/apache/flink/pull/23930#discussion_r1428109606
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java:
##
@@ -632,12 +633,16 @@ private static
CompletableFuture parseResponse(
MartijnVisser opened a new pull request, #23935:
URL: https://github.com/apache/flink/pull/23935
Unchanged backport of https://github.com/apache/flink/pull/2383
Verified locally with `mvn clean package -DskipTests -Pfast
-Pskip-webui-build -U -T4`, changing `flink-conf.yaml` to
[
https://issues.apache.org/jira/browse/FLINK-33541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li resolved FLINK-33541.
Fix Version/s: 1.19.0
1.18.1
1.17.3
Assignee:
libenchao closed pull request #23779: [FLINK-33541][table-planner] function
RAND and RAND_INTEGER should return type nullable if the arguments are nullable
URL: https://github.com/apache/flink/pull/23779
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797224#comment-17797224
]
Rui Fan commented on FLINK-33853:
-
Merged to master 1.19 via 1136ed50311a18c0b5773ae982330cc2936eba3d
>
[
https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33853.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> [JUnit5 Migration] Migrate Junit5 for
1996fanrui merged PR #23932:
URL: https://github.com/apache/flink/pull/23932
--
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-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33853:
---
Assignee: RocMarshal
> [JUnit5 Migration] Migrate Junit5 for DeclarativeSlotPoolBridge test
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797222#comment-17797222
]
Jing Ge commented on FLINK-33858:
-
Thanks for the heads-up, checking...
> CI fails with No space
[
https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Schulz updated FLINK-33857:
-
Description:
There's [a bug|https://github.com/elastic/elasticsearch/issues/103406] in
singhravidutt commented on PR #23933:
URL: https://github.com/apache/flink/pull/23933#issuecomment-1858012528
@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
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33858:
Description:
AlibabaCI003-agent01
AlibabaCI003-agent03
AlibabaCI003-agent05
[
https://issues.apache.org/jira/browse/FLINK-33858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797208#comment-17797208
]
Sergey Nuyanzin commented on FLINK-33858:
-
[~jingge] could you please have a look since you are
mxm commented on PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#issuecomment-1857974906
Thanks for the ping. Looks good!
--
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
Sergey Nuyanzin created FLINK-33858:
---
Summary: CI fails with No space left on device
Key: FLINK-33858
URL: https://issues.apache.org/jira/browse/FLINK-33858
Project: Flink
Issue Type: Bug
flinkbot commented on PR #23934:
URL: https://github.com/apache/flink/pull/23934#issuecomment-1857948911
## CI report:
* 877cfe2e3147c893829fd944ed5eba157c2f029a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33688:
---
Labels: pull-request-available (was: )
> Reuse Channels in RestClient to save connection
xiangyuf opened a new pull request, #23934:
URL: https://github.com/apache/flink/pull/23934
## What is the purpose of the change
Reuse connections in RestClient to save connection establish time.
## Brief change log
- Add connection reuse options
- Reuse channels
[
https://issues.apache.org/jira/browse/FLINK-33704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser resolved FLINK-33704.
Resolution: Fixed
> Update GCS filesystems to latest available versions
>
MartijnVisser commented on PR #23489:
URL: https://github.com/apache/flink/pull/23489#issuecomment-1857914683
There are two possibilities to solve this:
1. Backport https://issues.apache.org/jira/browse/FLINK-33704 to
`release-1.18` - This resolves the issue for 1.18
2. Merge the
[
https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Schulz updated FLINK-33857:
-
Description:
There's a bug in elasticsearch that may lead to underestimated bulk request
[
https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Schulz updated FLINK-33857:
-
Description:
There's [a bug|https://github.com/elastic/elasticsearch/issues/103406] in
[
https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Schulz updated FLINK-33857:
-
Description:
There's a bug in elasticsearch that may lead to underestimated bulk request
[
https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33857:
---
Labels: pull-request-available (was: )
> Expose BulkProcessor.flush via RequestIndexer to
Peter Schulz created FLINK-33857:
Summary: Expose BulkProcessor.flush via RequestIndexer to allow
custom flush logic
Key: FLINK-33857
URL: https://issues.apache.org/jira/browse/FLINK-33857
Project:
1996fanrui commented on PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#issuecomment-1857868649
Thanks @gyfora for the ping.
I don't have any comments, and I have approved.
--
This is an automated message from the Apache Git Service.
To respond to the
gyfora commented on PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#issuecomment-1857864814
Do you have any further comments / concerns @1996fanrui @mxm ?
The thresholds have been adjusted so by default we do not ever block, and we
plan to iterate and
dawidwys commented on code in PR #23923:
URL: https://github.com/apache/flink/pull/23923#discussion_r1427958337
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowDeduplicateTestPrograms.java:
##
@@ -0,0 +1,287 @@
+/*
+
echauchot merged PR #31:
URL: https://github.com/apache/flink-connector-shared-utils/pull/31
--
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:
echauchot commented on PR #31:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/31#issuecomment-1857840750
@snuyanzin regarding [our version
question](https://github.com/apache/flink-connector-shared-utils/pull/28#issuecomment-1845318521)
let's not bother @zentol, I found
Jiabao-Sun commented on code in PR #23917:
URL: https://github.com/apache/flink/pull/23917#discussion_r1427932231
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -68,8 +69,8 @@ class
singhravidutt commented on PR #23933:
URL: https://github.com/apache/flink/pull/23933#issuecomment-185775
@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
RocMarshal commented on code in PR #23932:
URL: https://github.com/apache/flink/pull/23932#discussion_r1427882696
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridgeResourceDeclarationTest.java:
##
@@ -141,40 +137,38 @@ public
mxm commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1426756716
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/AutoScalerUtils.java:
##
@@ -94,4 +99,106 @@ public static boolean
1 - 100 of 153 matches
Mail list logo
