[
https://issues.apache.org/jira/browse/FLINK-34192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34192:
--
Assignee: Jiabao Sun
> Update flink-connector-kafka to be compatible with updated Sin
[
https://issues.apache.org/jira/browse/FLINK-34244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-34244.
--
Resolution: Fixed
Fixed in apache/flink-connector-kafka
main: cfb275b478ff97e9105c5ffaf20224f
MartijnVisser merged PR #81:
URL: https://github.com/apache/flink-connector-kafka/pull/81
--
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-unsubsc
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815943#comment-17815943
]
Martijn Visser commented on FLINK-33365:
[~rahulchundeth] See the Dev mailing li
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815934#comment-17815934
]
Rahul Raj commented on FLINK-33365:
---
Hi Team,
when we can expect next version of flink
hejufang commented on PR #24274:
URL: https://github.com/apache/flink/pull/24274#issuecomment-1935352424
@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.
mtfelisb commented on code in PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1483760795
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriterITCase.java:
##
@@ -0,0 +1,27
mtfelisb commented on PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1935170882
> > This pull request is working on every Flink version but `1.19-SNAPSHOT`
>
> I'm suspecting that's because of
https://issues.apache.org/jira/browse/FLINK-2585
[
https://issues.apache.org/jira/browse/FLINK-34413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34413:
--
Assignee: Ferenc Csaky
> Drop support for HBase v1
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-34344:
--
Fix Version/s: 1.18.2
> Wrong JobID in CheckpointStatsTracker
> --
[
https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-34344:
--
Fix Version/s: 1.20.0
> Wrong JobID in CheckpointStatsTracker
> --
[
https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-34344:
--
Affects Version/s: 1.18.1
1.20.0
> Wrong JobID in CheckpointSta
rkhachatryan merged PR #24254:
URL: https://github.com/apache/flink/pull/24254
--
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.
rkhachatryan commented on PR #24254:
URL: https://github.com/apache/flink/pull/24254#issuecomment-1934827477
Thanks for the review!
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
rkhachatryan commented on code in PR #24254:
URL: https://github.com/apache/flink/pull/24254#discussion_r1483515377
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -112,8 +112,9 @@ public class CheckpointStatsTracker {
flinkbot commented on PR #24292:
URL: https://github.com/apache/flink/pull/24292#issuecomment-1934796687
## CI report:
* 605d23d07cc51916ac746b9760a400dd363c0044 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34417:
---
Labels: pull-request-available (was: )
> Add JobID to logging MDC
> ---
rkhachatryan opened a new pull request, #24292:
URL: https://github.com/apache/flink/pull/24292
## What is the purpose of the change
Add Flink JobID to logging MDC to make analysing the logs easier.
## Verifying this change
- added `JobIdLoggingMainThreadExecu
Roman Khachatryan created FLINK-34417:
-
Summary: Add JobID to logging MDC
Key: FLINK-34417
URL: https://issues.apache.org/jira/browse/FLINK-34417
Project: Flink
Issue Type: Improvement
bvarghese1 commented on code in PR #24219:
URL: https://github.com/apache/flink/pull/24219#discussion_r1483474513
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java:
##
@@ -0,0 +1,130 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-34393.
---
Resolution: Fixed
> Release Testing Instructions: Verify FLINK-20767 Add nested field support for
> Support
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815791#comment-17815791
]
Jing Ge commented on FLINK-34393:
-
Thanks for the clarification.
> Release Testing Inst
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815786#comment-17815786
]
Venkata krishnan Sowrirajan commented on FLINK-34393:
-
Looks like I
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815785#comment-17815785
]
Venkata krishnan Sowrirajan edited comment on FLINK-34393 at 2/8/24 6:42 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815785#comment-17815785
]
Venkata krishnan Sowrirajan commented on FLINK-34393:
-
It won't be r
XComp commented on PR #24285:
URL: https://github.com/apache/flink/pull/24285#issuecomment-1934710721
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815766#comment-17815766
]
Piotr Nowojski commented on FLINK-34289:
That definitely would prevent my confus
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815765#comment-17815765
]
Alan Sheinberg commented on FLINK-34404:
I did recently add a test, so if for so
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-34200.
---
Resolution: Fixed
master:
[1b95b191922829fd8e7a76e5c9d8de68bb57ae7d|https://github.com/apac
XComp merged PR #24286:
URL: https://github.com/apache/flink/pull/24286
--
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.
hejufang commented on PR #24274:
URL: https://github.com/apache/flink/pull/24274#issuecomment-1934485237
@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-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815746#comment-17815746
]
Ferenc Csaky commented on FLINK-34411:
--
The current [dev-1.19|https://github.com/ap
[
https://issues.apache.org/jira/browse/FLINK-34413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815744#comment-17815744
]
Ferenc Csaky commented on FLINK-34413:
--
Thanks for creating this ticket, feel free
[
https://issues.apache.org/jira/browse/FLINK-34285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34285:
Description:
This is an umbrella ticket for the Flink 1.19 testing efforts.
There're two kinds of
[
https://issues.apache.org/jira/browse/FLINK-34285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34285:
Description:
This is an umbrella ticket for the Flink 1.19 testing efforts.
RM opened a release
XComp commented on code in PR #24285:
URL: https://github.com/apache/flink/pull/24285#discussion_r1483225410
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java:
##
@@ -105,7 +103,6 @@
*
*/
@RunWith(Parameterized.class)
-@Categor
JingGe commented on code in PR #24279:
URL: https://github.com/apache/flink/pull/24279#discussion_r1483214554
##
docs/content.zh/docs/ops/debugging/flame_graphs.md:
##
@@ -27,36 +27,37 @@ under the License.
# Flame Graphs
-[Flame Graphs](http://www.brendangregg.com/flamegra
[
https://issues.apache.org/jira/browse/FLINK-34416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815738#comment-17815738
]
Matthias Pohl commented on FLINK-34416:
---
We should investigate whether that could
Matthias Pohl created FLINK-34416:
-
Summary: "Local recovery and sticky scheduling end-to-end test"
still doesn't work with AdaptiveScheduler
Key: FLINK-34416
URL: https://issues.apache.org/jira/browse/FLINK-34416
[
https://issues.apache.org/jira/browse/FLINK-34285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34285:
Attachment: screenshot-3.png
> [Umbrella] Test Flink Release 1.19
> --
[
https://issues.apache.org/jira/browse/FLINK-34415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34415:
---
Description:
The current Flink Kafka connector still uses Zookeeper for Kafka-based testing.
[
https://issues.apache.org/jira/browse/FLINK-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815735#comment-17815735
]
lincoln lee commented on FLINK-34289:
-
[~pnowojski] Really appreciate for your valua
[
https://issues.apache.org/jira/browse/FLINK-34391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815731#comment-17815731
]
Jing Ge commented on FLINK-34391:
-
pinged [~xiangyu0xf] in the Slack, waiting for the fe
[
https://issues.apache.org/jira/browse/FLINK-34395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815730#comment-17815730
]
Jing Ge commented on FLINK-34395:
-
pinged [~yunfengzhou] in the Slack, waiting for the f
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815728#comment-17815728
]
Jing Ge commented on FLINK-34393:
-
pinged [~vsowrirajan] in the Slack, waiting for the
[
https://issues.apache.org/jira/browse/FLINK-34367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815727#comment-17815727
]
Jing Ge commented on FLINK-34367:
-
Hi [~asheinberg] would you like to create a release t
MartijnVisser commented on code in PR #81:
URL:
https://github.com/apache/flink-connector-kafka/pull/81#discussion_r1483192402
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/DockerImageVersions.java:
##
@@ -24,7 +24,9 @@
*/
public class Doc
Martijn Visser created FLINK-34415:
--
Summary: Move away from Kafka-Zookeeper based tests in favor of
Kafka-KRaft
Key: FLINK-34415
URL: https://issues.apache.org/jira/browse/FLINK-34415
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-34399:
Labels: release-testing (was: )
> Release Testing: Verify FLINK-33644 Make QueryOperations SQL serializab
MartijnVisser commented on code in PR #81:
URL:
https://github.com/apache/flink-connector-kafka/pull/81#discussion_r1483185495
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/DockerImageVersions.java:
##
@@ -24,7 +24,9 @@
*/
public class Doc
[
https://issues.apache.org/jira/browse/FLINK-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34289:
Attachment: screenshot-2.png
> Release Testing Instructions: Verify FLINK-33695 Introduce TraceRep
snuyanzin commented on code in PR #81:
URL:
https://github.com/apache/flink-connector-kafka/pull/81#discussion_r1483182849
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/DockerImageVersions.java:
##
@@ -24,7 +24,9 @@
*/
public class DockerI
[
https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815724#comment-17815724
]
Jing Ge commented on FLINK-34305:
-
Hi [~sudewei.sdw] I have assigned this ticket to you
[
https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-34305:
---
Assignee: SuDewei (was: Zhanghao Chen)
> Release Testing Instructions: Verify FLINK-33261 Support
[
https://issues.apache.org/jira/browse/FLINK-34244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34244:
---
Fix Version/s: kafka-3.1.1
> Upgrade Confluent Platform to latest compatible version
> -
MartijnVisser merged PR #24202:
URL: https://github.com/apache/flink/pull/24202
--
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-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815719#comment-17815719
]
Martijn Visser commented on FLINK-34252:
[~fanrui] I'm curious on your thoughts
Jiabao-Sun commented on code in PR #84:
URL:
https://github.com/apache/flink-connector-kafka/pull/84#discussion_r1483154745
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/YamlFileMetadataService.java:
##
@@ -23,20 +23,19 @@
import org.apache.
MartijnVisser commented on code in PR #84:
URL:
https://github.com/apache/flink-connector-kafka/pull/84#discussion_r1483132533
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/YamlFileMetadataService.java:
##
@@ -23,20 +23,19 @@
import org.apac
Rafał Trójczak created FLINK-34414:
--
Summary: EXACTLY_ONCE guarantee doesn't work properly for
Flink/Pulsar connector
Key: FLINK-34414
URL: https://issues.apache.org/jira/browse/FLINK-34414
Project:
[
https://issues.apache.org/jira/browse/FLINK-24239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-24239.
Resolution: Implemented
Implemented in 01cdc703ee6fa56bdfdf799d016c0e882e9e5d99
> Event t
dawidwys merged PR #24253:
URL: https://github.com/apache/flink/pull/24253
--
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
snuyanzin commented on PR #24253:
URL: https://github.com/apache/flink/pull/24253#issuecomment-1934213444
yes, also played locally , seems working, thanks
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815685#comment-17815685
]
Piotr Nowojski commented on FLINK-34403:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-34403:
---
Priority: Critical (was: Major)
> VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM
pnowojski commented on PR #24274:
URL: https://github.com/apache/flink/pull/24274#issuecomment-1934175386
@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.
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1483002425
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -314,13 +315,19 @@ protected static Map evaluateGlobalMetr
pvary commented on PR #34:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/34#issuecomment-1934091836
> @pvary do you remember why we added the old conda version here?
IIRC the issue was to run the python tests on Mac with the new Python
versions
--
This is an aut
pvary commented on PR #84:
URL:
https://github.com/apache/flink-connector-kafka/pull/84#issuecomment-1934089389
The SinkV2 related changes are ok (There is some extra casts which are
needed)
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Jiabao-Sun commented on code in PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1482924435
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriterITCase.java:
##
@@ -0,0 +1,
Jiabao-Sun commented on PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1934031525
> Hi, @MartijnVisser. I have a question regarding compatibility. This pull
request is working on every Flink version but `1.19-SNAPSHOT`. I've checked
[this
issue](
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815660#comment-17815660
]
Matthias Pohl commented on FLINK-34404:
---
I attached the debug logs for the failed
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: FLINK-34404.failure.log
> GroupWindowAggregateProcTimeRestoreTest#testRestore time
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: (was: FLINK-34404.log)
> GroupWindowAggregateProcTimeRestoreTest#testRestore t
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: FLINK-34404.success.log
> GroupWindowAggregateProcTimeRestoreTest#testRestore time
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: FLINK-34404.log
> GroupWindowAggregateProcTimeRestoreTest#testRestore times out
>
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815654#comment-17815654
]
Matthias Pohl commented on FLINK-34273:
---
https://dev.azure.com/apache-flink/apache
gyfora commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482812605
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -314,13 +315,19 @@ protected static Map evaluateGlobalM
gyfora commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482812605
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -314,13 +315,19 @@ protected static Map evaluateGlobalM
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482810083
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Software Fo
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482809329
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Software Fo
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482802937
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java:
##
@@ -250,6 +251,31 @@ private static ConfigOptions.OptionBui
[
https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815475#comment-17815475
]
Rui Fan edited comment on FLINK-33960 at 2/8/24 10:57 AM:
--
Merg
1996fanrui merged PR #24287:
URL: https://github.com/apache/flink/pull/24287
--
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.ap
1996fanrui commented on PR #24288:
URL: https://github.com/apache/flink/pull/24288#issuecomment-1933823128
@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
XComp commented on PR #24286:
URL: https://github.com/apache/flink/pull/24286#issuecomment-1933821366
@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.
To
XComp commented on PR #24286:
URL: https://github.com/apache/flink/pull/24286#issuecomment-1933821158
The [CI
failure](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=57393)
is due to another issue which is documented in FLINK-34411
--
This
gyfora commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482771329
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815626#comment-17815626
]
Matthias Pohl commented on FLINK-34411:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33960:
Fix Version/s: 1.19.0
1.18.2
1.20.0
> Adaptive Scheduler doesn't res
dawidwys commented on code in PR #24253:
URL: https://github.com/apache/flink/pull/24253#discussion_r1482693914
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinTestPrograms.java:
##
@@ -84,6 +130,36 @@ public cla
dawidwys commented on PR #24253:
URL: https://github.com/apache/flink/pull/24253#issuecomment-1933701764
@snuyanzin There is a test for using an entry from a map:
```
INSERT INTO MySink
SELECT amount * r.rate
FROM OrdersNestedId AS o
JOIN RatesHistory FOR SYSTEM_TIME AS OF
Martijn Visser created FLINK-34413:
--
Summary: Drop support for HBase v1
Key: FLINK-34413
URL: https://issues.apache.org/jira/browse/FLINK-34413
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-34381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34381:
-
Assignee: xuyang
> `RelDataType#getFullTypeString` should be used to print in
> `RelTreeWriter
snuyanzin commented on PR #24253:
URL: https://github.com/apache/flink/pull/24253#issuecomment-1933613412
Out of curiocity: I didn't find tests for nested arrays/maps/row... Are they
out of scope?
I mean e.g. this
```sql
CREATE TABLE A (
a MAP>,
ts TI
[
https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815577#comment-17815577
]
Matthias Pohl commented on FLINK-34403:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815576#comment-17815576
]
Matthias Pohl commented on FLINK-34202:
---
1.17:
https://dev.azure.com/apache-flink
Matthias Pohl created FLINK-34412:
-
Summary: ResultPartitionDeploymentDescriptorTest fails due to
fatal error (239 exit code)
Key: FLINK-34412
URL: https://issues.apache.org/jira/browse/FLINK-34412
Pr
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-22765:
--
Affects Version/s: 1.20.0
> ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable
>
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815573#comment-17815573
]
Matthias Pohl commented on FLINK-22765:
---
https://dev.azure.com/apache-flink/apache
1 - 100 of 104 matches
Mail list logo