Jingsong Lee created FLINK-31002:
Summary: Provide data sampling query
Key: FLINK-31002
URL: https://issues.apache.org/jira/browse/FLINK-31002
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-31001:
Summary: Introduce Hive writer
Key: FLINK-31001
URL: https://issues.apache.org/jira/browse/FLINK-31001
Project: Flink
Issue Type: New Feature
Shammon created FLINK-31000:
---
Summary: Upgrade test units in flink-table-store-common to junit5
Key: FLINK-31000
URL: https://issues.apache.org/jira/browse/FLINK-31000
Project: Flink
Issue Type:
Shammon created FLINK-30999:
---
Summary: Introduce flink-table-store-test-utils for table store
Key: FLINK-30999
URL: https://issues.apache.org/jira/browse/FLINK-30999
Project: Flink
Issue Type:
JingsongLi commented on PR #494:
URL:
https://github.com/apache/flink-table-store/pull/494#issuecomment-1425060073
ITCase failed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
[
https://issues.apache.org/jira/browse/FLINK-30986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30986.
Fix Version/s: table-store-0.4.0
Assignee: yuzelin
Resolution: Fixed
master:
JingsongLi merged PR #508:
URL: https://github.com/apache/flink-table-store/pull/508
--
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-30405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-30405.
--
Resolution: Fixed
a9f4045 in main
> Add ResourceLifecycleStatus to CommonStatus and printer
mbalassi merged PR #524:
URL: https://github.com/apache/flink-kubernetes-operator/pull/524
--
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-19065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683749#comment-17683749
]
Harshit Mittal edited comment on FLINK-19065 at 2/10/23 12:08 AM:
--
We
[
https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686802#comment-17686802
]
Leonid Ilyevsky commented on FLINK-30998:
-
I actually looked at the code related to
tzulitai commented on PR #606:
URL: https://github.com/apache/flink-web/pull/606#issuecomment-1424969216
+1 LGTM
Minor reminder: please update the `release_date` to the actual date the
release actually happens.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686787#comment-17686787
]
Leonid Ilyevsky commented on FLINK-30998:
-
I now found that previously the required
Leonid Ilyevsky created FLINK-30998:
---
Summary: Add optional exception handler to
flink-connector-opensearch
Key: FLINK-30998
URL: https://issues.apache.org/jira/browse/FLINK-30998
Project: Flink
zentol commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r110187
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
zentol commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r1101876706
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
zentol commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r110187
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
[
https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686664#comment-17686664
]
Maximilian Michels commented on FLINK-30920:
No objections from my side. It should be a
mxm commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r1101791025
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
flinkbot commented on PR #21908:
URL: https://github.com/apache/flink/pull/21908#issuecomment-1424525972
## CI report:
* afc1bc22c7e45048d565ef6e90cdbd4b6f7d6c34 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30895:
---
Labels: pull-request-available (was: )
> SlotSharingSlotAllocator may waste slots
>
zentol opened a new pull request, #21908:
URL: https://github.com/apache/flink/pull/21908
Fixes an issue where the distribution of slots across slot-sharing groups
did not take the max parallelism of that group into account, due to which some
slots were potentially left unused.
We
[
https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686646#comment-17686646
]
Maximilian Michels commented on FLINK-30773:
Thanks for the pointers! Indeed, the rescaling
[
https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-30773:
---
Summary: Add API for rescaling of jobs based on per-vertex parallelism
overrides
[
https://issues.apache.org/jira/browse/FLINK-30924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686639#comment-17686639
]
Timo Walther commented on FLINK-30924:
--
[~leonard] has put a lot of this. Maybe he has some input?
[
https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686638#comment-17686638
]
Timo Walther commented on FLINK-30959:
--
Better documentation definitely sounds good to me. It
flinkbot commented on PR #21907:
URL: https://github.com/apache/flink/pull/21907#issuecomment-1424455909
## CI report:
* 05ade8d5b16a4dcdb80590c20851202b3371bb41 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-30785:
--
Fix Version/s: 1.17.0
> RocksDB Memory Management end-to-end test failed due to
[
https://issues.apache.org/jira/browse/FLINK-30785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-30785:
-
Assignee: Roman Khachatryan
> RocksDB Memory Management end-to-end test failed
[
https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686629#comment-17686629
]
Piotr Nowojski commented on FLINK-30238:
[~gaoyunhaii], thanks for the explanation, but I'm
[
https://issues.apache.org/jira/browse/FLINK-30785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30785:
---
Labels: pull-request-available test-stability (was: test-stability)
> RocksDB Memory
rkhachatryan opened a new pull request, #21907:
URL: https://github.com/apache/flink/pull/21907
Some stacktraces of passed tests may contain `completeExceptionally`, which
might fail the e2e (bash) tests.
This PR adds `completeExceptionally` to the list of ignored patterns.
Please
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101701294
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitState.java:
##
@@ -0,0 +1,66 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683414#comment-17683414
]
Chesnay Schepler edited comment on FLINK-30887 at 2/9/23 4:05 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-30792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686621#comment-17686621
]
Roman Khachatryan commented on FLINK-30792:
---
Do I understand correctly that the issue is the
[
https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686606#comment-17686606
]
Thomas Weise commented on FLINK-22793:
--
[~lemonjing] given the long time that has passed and all
wanglijie95 commented on PR #21813:
URL: https://github.com/apache/flink/pull/21813#issuecomment-1424392249
@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
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101601871
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686597#comment-17686597
]
Gaurav Miglani commented on FLINK-30920:
[~mxm] [~gyfora] then do i have head's up to make
[
https://issues.apache.org/jira/browse/FLINK-30776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30776:
---
Labels: pull-request-available (was: )
> Move autoscaler code into a separate module
>
mxm opened a new pull request, #529:
URL: https://github.com/apache/flink-kubernetes-operator/pull/529
The autoscaling code is tightly coupled with the main operator code. In an
effort to make it pluggable or run independently, we should move the code
into a
dedicated Maven module.
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101601871
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-30863:
-
Assignee: Yanfei Lei
> Do not delete the local changelog file of aborted
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686588#comment-17686588
]
Roman Khachatryan commented on FLINK-30863:
---
Thanks for filing the ticket and opening the PR
[
https://issues.apache.org/jira/browse/FLINK-30924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686585#comment-17686585
]
Feng Jin commented on FLINK-30924:
--
[~martijnvisser] That's ture, I took a closer look at the
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101601871
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-30776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-30776:
---
Summary: Move autoscaler code into a separate module (was: Move autoscaler
code
[
https://issues.apache.org/jira/browse/FLINK-30976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30976:
--
Assignee: Matthias Pohl
> docs_404_check fails occasionally
>
lincoln-lil commented on code in PR #21545:
URL: https://github.com/apache/flink/pull/21545#discussion_r1101591117
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/alias/ClearLookupJoinHintWithInvalidPropagationShuttleTest.java:
##
@@ -167,8
MartijnVisser commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1424327314
@chucheng92 You need to rebase your PR on the latest `master`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-30924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686577#comment-17686577
]
Martijn Visser commented on FLINK-30924:
[~hackergin] I would argue that "under the ‘UTC+0’ time
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101584861
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed
rkhachatryan commented on code in PR #21679:
URL: https://github.com/apache/flink/pull/21679#discussion_r1101583548
##
flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStreamHandleReaderWithCacheTest.java:
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101583261
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorState.java:
##
@@ -0,0 +1,93 @@
+/*
Shammon created FLINK-30997:
---
Summary: Refactor tests in connector to extends AbstractTestBase
Key: FLINK-30997
URL: https://issues.apache.org/jira/browse/FLINK-30997
Project: Flink
Issue Type:
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101578673
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorState.java:
##
@@ -0,0 +1,93 @@
+/*
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101576215
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorState.java:
##
@@ -0,0 +1,93 @@
+/*
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101575295
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorState.java:
##
@@ -0,0 +1,93 @@
+/*
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101574664
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializerTest.java:
##
@@
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101573610
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitSerializerTest.java:
##
@@ -0,0 +1,43 @@
+/*
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101571880
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/source/split/SplitsGeneratorTest.java:
##
@@ -0,0 +1,55 @@
+/*
+ *
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101570853
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java:
##
@@ -41,139 +41,31 @@ public
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1100252874
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,309 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686571#comment-17686571
]
Feng Jin commented on FLINK-30924:
--
[~martijnvisser]
> I don't think that a BIGINT value is always
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101496694
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplit.java:
##
@@ -48,6 +52,30 @@ public
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101496694
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplit.java:
##
@@ -48,6 +52,30 @@ public
chucheng92 commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1424296845
@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
rkhachatryan commented on code in PR #21679:
URL: https://github.com/apache/flink/pull/21679#discussion_r1101557635
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStreamHandleReaderWithCache.java:
##
@@ -161,23 +161,28 @@ private
Martijn Visser created FLINK-30996:
--
Summary: Sync Kafka 1.17 commits from apache/flink repo to
flink-connector-kafka
Key: FLINK-30996
URL: https://issues.apache.org/jira/browse/FLINK-30996
Project:
WencongLiu commented on PR #21696:
URL: https://github.com/apache/flink/pull/21696#issuecomment-1424274358
@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
WencongLiu commented on PR #21696:
URL: https://github.com/apache/flink/pull/21696#issuecomment-1424273318
@flinkbot re-run
--
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.
flinkbot commented on PR #21906:
URL: https://github.com/apache/flink/pull/21906#issuecomment-1424268946
## CI report:
* 61249c335b437bbf2a7e1f8d01a81423ec0144e7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21905:
URL: https://github.com/apache/flink/pull/21905#issuecomment-1424267556
## CI report:
* 9059ab9c6d6b9a845494162b8b301c4b9cdb7b32 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30976.
---
Fix Version/s: pulsar-4.0.0
Resolution: Fixed
pulsar/main:
SinBex commented on code in PR #21898:
URL: https://github.com/apache/flink/pull/21898#discussion_r1101523809
##
docs/content/docs/deployment/speculative_execution.md:
##
@@ -62,6 +62,15 @@ To make speculative execution work better for different
jobs, you can tune below
-
rkhachatryan commented on code in PR #21812:
URL: https://github.com/apache/flink/pull/21812#discussion_r1101496489
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/TaskChangelogRegistry.java:
##
@@ -46,29 +46,29 @@
@Internal
public interface
[
https://issues.apache.org/jira/browse/FLINK-30993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Wang updated FLINK-30993:
--
Component/s: Table Store
> Introduce FloatSerializer for Table Store
>
Feng Wang created FLINK-30995:
-
Summary: Introduce ByteSerializer for Table Store
Key: FLINK-30995
URL: https://issues.apache.org/jira/browse/FLINK-30995
Project: Flink
Issue Type: New Feature
Feng Wang created FLINK-30994:
-
Summary: Introduce DoubleSerializer for Table Store
Key: FLINK-30994
URL: https://issues.apache.org/jira/browse/FLINK-30994
Project: Flink
Issue Type: New Feature
Feng Wang created FLINK-30993:
-
Summary: Introduce FloatSerializer for Table Store
Key: FLINK-30993
URL: https://issues.apache.org/jira/browse/FLINK-30993
Project: Flink
Issue Type: New Feature
Feng Wang created FLINK-30992:
-
Summary: Introduce ShortSerializer for Table Store
Key: FLINK-30992
URL: https://issues.apache.org/jira/browse/FLINK-30992
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-30991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Wang reassigned FLINK-30991:
-
Assignee: Feng Wang
> Introduce LongSerializer for Table Store
>
Feng Wang created FLINK-30991:
-
Summary: Introduce LongSerializer for Table Store
Key: FLINK-30991
URL: https://issues.apache.org/jira/browse/FLINK-30991
Project: Flink
Issue Type: New Feature
XComp opened a new pull request, #21906:
URL: https://github.com/apache/flink/pull/21906
1.16 backport PR of parent PR #21887
--
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
XComp opened a new pull request, #21905:
URL: https://github.com/apache/flink/pull/21905
1.17 backport PR of parent PR #21887
--
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
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101496694
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplit.java:
##
@@ -48,6 +52,30 @@ public
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1098953393
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686506#comment-17686506
]
Maximilian Michels commented on FLINK-30920:
Task id / Vertex id are used interchangeably.
[
https://issues.apache.org/jira/browse/FLINK-30942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686492#comment-17686492
]
Zhu Zhu commented on FLINK-30942:
-
master:
5a4e0ea31aef51dfc50b9c401c91c7b869a154c4
release-1.17:
[
https://issues.apache.org/jira/browse/FLINK-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30990.
--
Resolution: Not A Problem
> Performance of deployDownstreamTasks.BATCH has worsened
>
[
https://issues.apache.org/jira/browse/FLINK-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686489#comment-17686489
]
Martijn Visser commented on FLINK-30990:
[~zhuzh] OK so this is considered a false-positive.
zhuzhurk closed pull request #21880: [FLINK-30942][runtime] Eagerly sets the
parallelism of job vertices in the parallelism-decided forward groups.
URL: https://github.com/apache/flink/pull/21880
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686485#comment-17686485
]
Zhu Zhu edited comment on FLINK-30990 at 2/9/23 1:21 PM:
-
Thanks for reporting!
[
https://issues.apache.org/jira/browse/FLINK-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686485#comment-17686485
]
Zhu Zhu commented on FLINK-30990:
-
This regression should have been caused by some recent improvements
MartijnVisser closed pull request #3: (Example 1)
URL: https://github.com/apache/flink-connector-kafka/pull/3
--
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,
boring-cyborg[bot] commented on PR #3:
URL:
https://github.com/apache/flink-connector-kafka/pull/3#issuecomment-1424177870
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
eskabetxe commented on PR #18:
URL:
https://github.com/apache/flink-connector-jdbc/pull/18#issuecomment-1424175258
Hi @snuyanzin could you check again, 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
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686464#comment-17686464
]
Martijn Visser commented on FLINK-29427:
[~stayrascal] This was a test stability, not a user
TanYuxin-tyx commented on PR #21843:
URL: https://github.com/apache/flink/pull/21843#issuecomment-1424167893
I rebased the origin/master to trigger ut.
--
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-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-30990:
---
Summary: Performance of deployDownstreamTasks.BATCH has worsened (was:
Performance of
101 - 200 of 327 matches
Mail list logo
