Baibaiwuguo commented on PR #22805:
URL: https://github.com/apache/flink/pull/22805#issuecomment-1596649244
@luoyuxia I also think tasks can be configured more rationally. I will
refine this issue.
--
This is an automated message from the Apache Git Service.
To respond to the message,
Baibaiwuguo commented on PR #22805:
URL: https://github.com/apache/flink/pull/22805#issuecomment-1596650060
@luoyuxia I also think tasks can be configured more rationally. I will
refine this issue.
--
This is an automated message from the Apache Git Service.
To respond to the message,
snuyanzin merged PR #69:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/69
--
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:
Tomas Witzany created FLINK-32375:
-
Summary: Flink AWS Source AssumeRole in VPC
Key: FLINK-32375
URL: https://issues.apache.org/jira/browse/FLINK-32375
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-32371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32371:
-
Assignee: Ryan Skraba
> Bump snappy-java to 1.1.10.1
>
>
reswqa closed pull request #22799: [FLINK-25872][state/changelog] Hotfix! Fix
the description of Changel…
URL: https://github.com/apache/flink/pull/22799
--
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
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Witzany updated FLINK-32375:
--
Environment:
Flink 1.15.4
running on Amazon KDA (managed flink)
runtime is running inside a
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Witzany updated FLINK-32375:
--
Description:
Current way to configure auth against AWS supports assuming a role, but when
XComp merged PR #22811:
URL: https://github.com/apache/flink/pull/22811
--
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:
XComp commented on PR #22812:
URL: https://github.com/apache/flink/pull/22812#issuecomment-1596601094
Merging - the parent PR was approved, CI succeeded and there were no
conflicts during backport
--
This is an automated message from the Apache Git Service.
To respond to the message,
XComp merged PR #22812:
URL: https://github.com/apache/flink/pull/22812
--
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:
XComp commented on PR #22811:
URL: https://github.com/apache/flink/pull/22811#issuecomment-1596601321
Merging - the parent PR was approved, CI succeeded and there were no
conflicts during backport
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Witzany updated FLINK-32375:
--
Description:
Current way to configure auth against AWS supports assuming a role, but when
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Witzany updated FLINK-32375:
--
Description:
Current way to configure auth against AWS supports assuming a role, but when
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Witzany updated FLINK-32375:
--
Description:
Current way to configure auth against AWS supports assuming a role, but when
[
https://issues.apache.org/jira/browse/FLINK-32368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733565#comment-17733565
]
Matthias Pohl edited comment on FLINK-32368 at 6/19/23 6:46 AM:
master:
[
https://issues.apache.org/jira/browse/FLINK-32368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32368.
---
Fix Version/s: 1.16.3
1.17.2
Resolution: Fixed
>
TanYuxin-tyx commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234664689
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TestingTierFactory.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed
zhuzhurk closed pull request #22798: [FLINK-32288][runtime] Improve the
scheduling performance of AdaptiveBatchScheduler
URL: https://github.com/apache/flink/pull/22798
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
luoyuxia commented on code in PR #22721:
URL: https://github.com/apache/flink/pull/22721#discussion_r1234691322
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowPartitionsOperation.java:
##
@@ -66,10 +66,6 @@ public CatalogPartitionSpec
FangYongs commented on PR #22768:
URL: https://github.com/apache/flink/pull/22768#issuecomment-1598082695
Hi @fsk119 Please help to review this PR when you are free, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
snuyanzin commented on PR #17867:
URL: https://github.com/apache/flink/pull/17867#issuecomment-1598142720
Thanks for having a look @reswqa , @fsk119
I've rebased, tests are passed
will merge soon
--
This is an automated message from the Apache Git Service.
To respond to the
TanYuxin-tyx commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234664689
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TestingTierFactory.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed
LoveHeat commented on code in PR #22806:
URL: https://github.com/apache/flink/pull/22806#discussion_r1234672707
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -195,9 +195,19 @@ void announceCombinedWatermark() {
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687374
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java:
##
@@ -158,9 +166,34 @@ public SingleInputGate
[
https://issues.apache.org/jira/browse/FLINK-32370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li closed FLINK-32370.
--
Assignee: Fang Yong
Resolution: Fixed
Fixed via
Weihua Hu created FLINK-32385:
-
Summary: Introduce a struct SerializedShuffleDescriptorAndIndices
to identify a group of ShuffleDescriptorAndIndex
Key: FLINK-32385
URL:
[
https://issues.apache.org/jira/browse/FLINK-32370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-32370:
---
Component/s: Tests
> JDBC SQl gateway e2e test is unstable
> -
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687042
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java:
##
@@ -217,6 +222,12 @@ public class SingleInputGate
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687515
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkBenchmarkEnvironment.java:
##
@@ -280,7 +281,8 @@ private
Weihua Hu created FLINK-32386:
-
Summary: Add ShuffleDescriptorsCache in TaskExecutor to cache
ShuffleDescriptors
Key: FLINK-32386
URL: https://issues.apache.org/jira/browse/FLINK-32386
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735128#comment-17735128
]
Rui Fan commented on FLINK-32137:
-
A mistake has just occurred about assignee.
Hi [~netvl] , thanks a
Zhu Zhu created FLINK-32384:
---
Summary: Remove deprecated configuration keys which violate YAML
spec
Key: FLINK-32384
URL: https://issues.apache.org/jira/browse/FLINK-32384
Project: Flink
Issue
LoveHeat commented on code in PR #22806:
URL: https://github.com/apache/flink/pull/22806#discussion_r1234672707
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -195,9 +195,19 @@ void announceCombinedWatermark() {
Weihua Hu created FLINK-32387:
-
Summary: InputGateDeploymentDescriptor uses cache to avoid
deserializing shuffle descriptors multiple times
Key: FLINK-32387
URL: https://issues.apache.org/jira/browse/FLINK-32387
curcur commented on PR #22590:
URL: https://github.com/apache/flink/pull/22590#issuecomment-1598107276
@Zakelly Thanks for the efforts! I've gone through another pass, LGTM.
A couple of things left:
1. squash the commits (address comments e.t.c)
2. run the bot again (the
LoveHeat commented on PR #22808:
URL: https://github.com/apache/flink/pull/22808#issuecomment-1598030633
The first path is(just simple call stack not full):
[create JobMaster for each recovered job, and will init a scheduler object
in jobmaster construct
[
https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-32137:
---
Assignee: Rui Fan (was: Vladimir Matveev)
> Flame graph is hard to use with many task managers
>
[
https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-32137:
---
Assignee: Vladimir Matveev (was: Rui Fan)
> Flame graph is hard to use with many task managers
>
Samrat002 commented on PR #83:
URL:
https://github.com/apache/flink-connector-aws/pull/83#issuecomment-1598036360
Hi @dannycranmer , @hlteoh37 !
Please validate if we want to add newly released minor version of flink
(1.16.2 and 1.17.1) in the PR build pipeline.
Thank you
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687955
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java:
##
@@ -813,6 +813,11 @@ private void
WencongLiu commented on PR #22733:
URL: https://github.com/apache/flink/pull/22733#issuecomment-1598052498
Thanks for the review from @TanYuxin-tyx and @reswqa ! I've made a round of
changes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-32310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735108#comment-17735108
]
luoyuxia commented on FLINK-32310:
--
[~lemonjing] Sorry to bother you. I'm wondering there's any
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Witzany updated FLINK-32375:
--
Description:
Current way to configure auth against AWS supports assuming a role, but when
snuyanzin commented on PR #22717:
URL: https://github.com/apache/flink/pull/22717#issuecomment-1596713498
Thanks for the work @hanyuzheng7
--
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
snuyanzin merged PR #22717:
URL: https://github.com/apache/flink/pull/22717
--
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-32371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734063#comment-17734063
]
Matthias Pohl commented on FLINK-32371:
---
master: ba47237a0a44222a275ba7a1d144822466d20f15
1.17:
[
https://issues.apache.org/jira/browse/FLINK-32371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32371:
--
Fix Version/s: 1.18.0
> Bump snappy-java to 1.1.10.1
>
>
>
flinkbot commented on PR #22822:
URL: https://github.com/apache/flink/pull/22822#issuecomment-1596773801
## CI report:
* 763d7627f08132791aef0351dfc551fb791dcd2f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22823:
URL: https://github.com/apache/flink/pull/22823#issuecomment-1596793069
## CI report:
* bc32acd3331fe6faf9777a4ec0ae93b5b7d67712 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7957:
Parent: FLINK-32378
Issue Type: Sub-task (was: Improvement)
> Add
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6053:
Parent: FLINK-32378
Issue Type: Sub-task (was: Improvement)
> Gauge should only
[
https://issues.apache.org/jira/browse/FLINK-14350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-14350:
-
Parent: FLINK-32378
Issue Type: Sub-task (was: Improvement)
> Introduce
LadyForest opened a new pull request, #22825:
URL: https://github.com/apache/flink/pull/22825
## What is the purpose of the change
This pull request is cherry-picked from commit
f69ed3454f2ab200310edee230da292ee2408503
## Brief change log
Please see #22820
XComp merged PR #22640:
URL: https://github.com/apache/flink/pull/22640
--
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-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Witzany updated FLINK-32375:
--
Description:
Current way to configure auth against AWS supports assuming a role, but when
TanYuxin-tyx commented on code in PR #22804:
URL: https://github.com/apache/flink/pull/22804#discussion_r1233853583
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/file/PartitionFileIndexImpl.java:
##
@@ -0,0 +1,159 @@
+/*
+ *
dannycranmer commented on PR #81:
URL:
https://github.com/apache/flink-connector-aws/pull/81#issuecomment-1596921636
> > I believe the failure is due to the Maven version not supporting the
shading config.
>
> What's the plan to address this, given that Flink and other connectors
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734109#comment-17734109
]
Danny Cranmer commented on FLINK-32375:
---
Hello. This is fixed in Flink 1.17 (FLINK-29496).
[
https://issues.apache.org/jira/browse/FLINK-32375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-32375.
---
Resolution: Duplicate
> Flink AWS Source AssumeRole in VPC
>
XComp commented on PR #22822:
URL: https://github.com/apache/flink/pull/22822#issuecomment-1596786411
Force-push: I fixed the commit message typo
([FLINK-32271](https://issues.apache.org/jira/browse/FLINK-32271) ->
[FLINK-32371](https://issues.apache.org/jira/browse/FLINK-32371))
--
XComp commented on PR #22823:
URL: https://github.com/apache/flink/pull/22823#issuecomment-1596784737
I fixed the commit message typo (FLINK-32271 -> FLINK-32371)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
luoyuxia merged PR #22820:
URL: https://github.com/apache/flink/pull/22820
--
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 commented on PR #22656:
URL: https://github.com/apache/flink/pull/22656#issuecomment-1596826669
> we should do that in a separate (followup-)ticket after the migration is
done.
sounds good.
--
This is an automated message from the Apache Git Service.
To respond to the
luoyuxia commented on PR #22820:
URL: https://github.com/apache/flink/pull/22820#issuecomment-1596827971
@LadyForest Could you please backport to 1.17 & 1.16. Thx.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
LadyForest commented on PR #22820:
URL: https://github.com/apache/flink/pull/22820#issuecomment-1596832437
> @LadyForest Could you please backport to 1.17 & 1.16. Thx.
Sure :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Chesnay Schepler created FLINK-32380:
Summary: Serialization of Java records fails
Key: FLINK-32380
URL: https://issues.apache.org/jira/browse/FLINK-32380
Project: Flink
Issue Type:
LadyForest opened a new pull request, #22826:
URL: https://github.com/apache/flink/pull/22826
## What is the purpose of the change
This pull request is cherry-picked from commit
https://github.com/apache/flink/commit/f69ed3454f2ab200310edee230da292ee2408503
## Brief change
flinkbot commented on PR #22826:
URL: https://github.com/apache/flink/pull/22826#issuecomment-1596899346
## CI report:
* dbc3813eb6075a53e5823c019e39c737c1c0a04e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
TanYuxin-tyx commented on code in PR #22804:
URL: https://github.com/apache/flink/pull/22804#discussion_r1233843144
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/file/PartitionFileWriter.java:
##
@@ -0,0 +1,41 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22804:
URL: https://github.com/apache/flink/pull/22804#discussion_r1233849891
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/file/PartitionFileIndex.java:
##
@@ -0,0 +1,109 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22804:
URL: https://github.com/apache/flink/pull/22804#discussion_r1233854834
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/file/ProducerMergePartitionFileWriter.java:
##
@@ -0,0 +1,182
TanYuxin-tyx commented on PR #22804:
URL: https://github.com/apache/flink/pull/22804#issuecomment-1596932123
@xintongsong Thanks for reviewing.
I have refactored the commits of the PR. The partition file reader API is
also submitted. PTAL
--
This is an automated message from the
xushsh163 commented on PR #63:
URL:
https://github.com/apache/flink-connector-jdbc/pull/63#issuecomment-1596932037
@MartijnVisser
In postgresql 13.10
`CREATE TABLE TEST(
"LEFT" CHAR(20)
);`
In Flink 1.16.0 SQL-Client
`CREATE TABLE test
(
`LEFT` STRING
) WITH
[
https://issues.apache.org/jira/browse/FLINK-32371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32371:
---
Labels: pull-request-available (was: )
> Bump snappy-java to 1.1.10.1
>
[
https://issues.apache.org/jira/browse/FLINK-32378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32378:
-
Fix Version/s: 2.0.0
(was: 1.18.0)
> 2.0 Breaking Metric system
[
https://issues.apache.org/jira/browse/FLINK-24078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-24078:
-
Parent: FLINK-32378
Issue Type: Sub-task (was: Technical Debt)
> Remove
luoyuxia opened a new pull request, #22824:
URL: https://github.com/apache/flink/pull/22824
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-32377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32377:
-
Component/s: Runtime / REST
> 2.0 Breaking REST API changes
>
Chesnay Schepler created FLINK-32378:
Summary: 2.0 Breaking Metric system changes
Key: FLINK-32378
URL: https://issues.apache.org/jira/browse/FLINK-32378
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-32379:
Summary: Skip archunit tests in java1X-target profiles
Key: FLINK-32379
URL: https://issues.apache.org/jira/browse/FLINK-32379
Project: Flink
Issue
MartijnVisser commented on PR #81:
URL:
https://github.com/apache/flink-connector-aws/pull/81#issuecomment-1596838891
> I believe the failure is due to the Maven version not supporting the
shading config.
What's the plan to address this, given that Flink and other connectors now
[
https://issues.apache.org/jira/browse/FLINK-32379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734091#comment-17734091
]
Sergey Nuyanzin commented on FLINK-32379:
-
Do you happen to know how to reproduce locally?
[
https://issues.apache.org/jira/browse/FLINK-32334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32334.
--
Fix Version/s: kubernetes-operator-1.6.0
Resolution: Fixed
merged to main
TanYuxin-tyx commented on code in PR #22804:
URL: https://github.com/apache/flink/pull/22804#discussion_r1233845440
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/file/SegmentNettyPayload.java:
##
@@ -0,0 +1,55 @@
+/*
+ *
TanYuxin-tyx commented on PR #22804:
URL: https://github.com/apache/flink/pull/22804#issuecomment-1596938547
@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
MartijnVisser closed pull request #47: [FLINK-28347][Test infrastructure]
Update testcontainers dependency to v1.18.0
URL: https://github.com/apache/flink-connector-elasticsearch/pull/47
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
João Boto created FLINK-32376:
-
Summary: [FLIP-287] Extend Sink#InitContext to expose
TypeSerializer, ObjectReuse and JobID
Key: FLINK-32376
URL: https://issues.apache.org/jira/browse/FLINK-32376
[
https://issues.apache.org/jira/browse/FLINK-32371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32371:
--
Affects Version/s: 1.17.1
1.16.2
1.18.0
> Bump
LadyForest commented on code in PR #22620:
URL: https://github.com/apache/flink/pull/22620#discussion_r1233641141
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/utils/FlinkTypeUtils.java:
##
@@ -0,0 +1,160 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-20887:
---
Assignee: lincoln lee
> Non-deterministic functions return different values even if it is
flinkbot commented on PR #22824:
URL: https://github.com/apache/flink/pull/22824#issuecomment-1596804220
## CI report:
* d05f164c1fbc368260db5313a276cababeab197f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on PR #70:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/70#issuecomment-1596825114
also passed nightly on my fork
https://github.com/snuyanzin/flink-connector-elasticsearch/actions/runs/5309751461
--
This is an automated message from the Apache
FangYongs commented on PR #22819:
URL: https://github.com/apache/flink/pull/22819#issuecomment-1596834032
Hi @libenchao Please help to review this PR for test case in JDBC and Sql
Gateway when you're free, thanks
--
This is an automated message from the Apache Git Service.
To respond to
luoyuxia commented on PR #22692:
URL: https://github.com/apache/flink/pull/22692#issuecomment-1596836696
@LadyForest Thanks for reviwing. 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
luoyuxia merged PR #22692:
URL: https://github.com/apache/flink/pull/22692
--
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-32233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-32233.
Resolution: Fixed
master: 1a3151b5b9f1df8aaa221b2febfae0431a69b95d
> Introduce SupportsTruncate
Matthias Pohl created FLINK-32381:
-
Summary: Replaces error handling functionality with onError method
in MultipleComponentLeaderElectionDriver.Listener interface
Key: FLINK-32381
URL:
TanYuxin-tyx commented on code in PR #22804:
URL: https://github.com/apache/flink/pull/22804#discussion_r1233855266
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskCacheManager.java:
##
@@ -0,0 +1,157 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-31665.
-
Resolution: Fixed
Merged to master as
1 - 100 of 190 matches
Mail list logo
