gaoyunhaii commented on PR #21423:
URL: https://github.com/apache/flink/pull/21423#issuecomment-171876
@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
hackeryard commented on code in PR #20377:
URL: https://github.com/apache/flink/pull/20377#discussion_r1036803986
##
docs/content.zh/docs/connectors/table/hive/hive_read_write.md:
##
@@ -150,6 +150,41 @@ Flink 允许你灵活的配置并发推断策略。你可以在 `TableConfig`
+### 读 Hive 表时调整数据分片（Split
[
https://issues.apache.org/jira/browse/FLINK-30072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30072:
Component/s: Runtime / Task
(was: Runtime / Coordination)
> Cannot assign instance of
[
https://issues.apache.org/jira/browse/FLINK-30239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-30239:
--
Assignee: Rui Fan (was: Lijie Wang)
> The flame graph doesn't work due to groupExecutionsByL
[
https://issues.apache.org/jira/browse/FLINK-30239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-30239:
--
Assignee: Lijie Wang
> The flame graph doesn't work due to groupExecutionsByLocation has bug
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641751#comment-17641751
]
Yun Gao commented on FLINK-30081:
-
Hi [~liuml07] the mini-cluster does not start new pr
Martijn Visser created FLINK-30257:
--
Summary: SqlClientITCase#testMatchRecognize failed
Key: FLINK-30257
URL: https://issues.apache.org/jira/browse/FLINK-30257
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641754#comment-17641754
]
Martijn Visser commented on FLINK-29405:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29940.
Resolution: Won't Do
> ExecutionGraph logs job state change at ERROR level when job fails
> --
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641758#comment-17641758
]
Xintong Song commented on FLINK-29940:
--
Agree with [~gaoyunhaii] that the state cha
JingsongLi commented on code in PR #411:
URL: https://github.com/apache/flink-table-store/pull/411#discussion_r1036797509
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/source/snapshot/SnapshotEnumerator.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641760#comment-17641760
]
Yun Gao commented on FLINK-30131:
-
Hi [~landlord] from the attached image, it seems the
[
https://issues.apache.org/jira/browse/FLINK-29934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641761#comment-17641761
]
Xintong Song commented on FLINK-29934:
--
I also cannot reproduce this.
[~jackylau],
XComp commented on PR #21411:
URL: https://github.com/apache/flink/pull/21411#issuecomment-1333408169
@MartijnVisser there is no `v3.0` branch in [apache/flink-connector-pulsar](
https://github.com/apache/flink-connector-pulsar)(,yet?). :thinking:
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641765#comment-17641765
]
Xintong Song commented on FLINK-29925:
--
[~bytesmith], could you explain a bit more
[
https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-29167:
Fix Version/s: (was: 1.14.2)
> Time out-of-order optimization for merging multiple data streams into
wsry commented on code in PR #21217:
URL: https://github.com/apache/flink/pull/21217#discussion_r1036837155
##
flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java:
##
@@ -469,7 +469,9 @@ public static void logEnvironmentInfo(
}
[
https://issues.apache.org/jira/browse/FLINK-29364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641770#comment-17641770
]
Lijie Wang commented on FLINK-29364:
I will close this ticket because it doesn't see
[
https://issues.apache.org/jira/browse/FLINK-29364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-29364.
--
Resolution: Not A Problem
> Root cause of Exceptions thrown in the SourceReader start() method gets
>
[
https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiadong.lu updated FLINK-29925:
---
Description: As shown in the figure below, when the configure value is very
large, the ui of the tab
hackeryard commented on code in PR #20016:
URL: https://github.com/apache/flink/pull/20016#discussion_r1036848127
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java:
##
@@ -257,6 +279,12 @@ public void applyProjection(int
[
https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641771#comment-17641771
]
Zhu Zhu commented on FLINK-29167:
-
The record orders are retained if they are from the s
[
https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-29167.
---
Resolution: Not A Problem
Closing the ticket because it does not seem to be a problem and is not active
for
[
https://issues.apache.org/jira/browse/FLINK-30202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641773#comment-17641773
]
Martijn Visser commented on FLINK-30202:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641775#comment-17641775
]
Martijn Visser commented on FLINK-29461:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641777#comment-17641777
]
jiadong.lu commented on FLINK-29925:
[~xtsong] hello,may be the screenshot is too bi
Xuannan Su created FLINK-30258:
--
Summary: PyFlink supports closing loop back server
Key: FLINK-30258
URL: https://issues.apache.org/jira/browse/FLINK-30258
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-30258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-30258:
---
Description:
Currently, a loopback server will be started whenever a
StreamExecutionEnvironment or
[
https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641778#comment-17641778
]
Xintong Song commented on FLINK-29925:
--
Ok, I see. That's a good point. Do you want
[
https://issues.apache.org/jira/browse/FLINK-30258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-30258:
---
Summary: PyFlink supports closing loopback server (was: PyFlink supports
closing loop back server)
[
https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641780#comment-17641780
]
jiadong.lu commented on FLINK-29925:
[~xtsong] sorry, I don't have enough frontend e
[
https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641785#comment-17641785
]
Martijn Visser commented on FLINK-27916:
1.16:
https://dev.azure.com/apache-fli
[
https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641784#comment-17641784
]
Martijn Visser commented on FLINK-24095:
1.16:
https://dev.azure.com/apache-fli
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641786#comment-17641786
]
Martijn Visser commented on FLINK-27917:
1.15:
https://dev.azure.com/apache-fli
[
https://issues.apache.org/jira/browse/FLINK-28319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641788#comment-17641788
]
Martijn Visser commented on FLINK-28319:
1.15:
https://dev.azure.com/apache-fli
[
https://issues.apache.org/jira/browse/FLINK-28319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28319:
---
Summary: ResumeCheckpointManuallyITCase gets stuck (was: test_ci tests
times out after/duri
MartijnVisser commented on code in PR #23:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/23#discussion_r1036889587
##
docs/content/docs/connectors/datastream/elasticsearch.md:
##
@@ -226,17 +226,60 @@ To use fault tolerant Elasticsearch Sinks, checkpointing
MartijnVisser commented on PR #21411:
URL: https://github.com/apache/flink/pull/21411#issuecomment-1333487912
Meh it's fixed
--
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.
Ran Tao created FLINK-30259:
---
Summary: Using flink Preconditions Util instead of uncertain
Assert keyword to do checking
Key: FLINK-30259
URL: https://issues.apache.org/jira/browse/FLINK-30259
Project: Flin
JingsongLi merged PR #412:
URL: https://github.com/apache/flink-table-store/pull/412
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30259:
Component/s: Deployment / Kubernetes
> Using flink Preconditions Util instead of uncertain Assert keyword
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30259:
Component/s: Table SQL / Planner
(was: Table SQL / API)
> Using flink Preconditions U
Maximilian Michels created FLINK-30260:
--
Summary: FLIP-271: Autoscaling
Key: FLINK-30260
URL: https://issues.apache.org/jira/browse/FLINK-30260
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30259:
Summary: Use flink Preconditions Util instead of uncertain Assert keyword
to do checking (was: Using flin
[
https://issues.apache.org/jira/browse/FLINK-30260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-30260:
---
Summary: FLIP-271: Add Autoscaling implementation (was: FLIP-271:
Autoscaling)
> F
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641802#comment-17641802
]
Ran Tao commented on FLINK-30259:
-
Hi, [~martijnvisser] can u take a look for this? i’m
[
https://issues.apache.org/jira/browse/FLINK-30260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-30260:
---
Summary: FLIP-271: Add initial Autoscaling implementation (was: FLIP-271:
Add Auto
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30259:
Description:
The code of some modules of the current Flink project uses the 'assert' keyword
of java to d
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641803#comment-17641803
]
Martijn Visser commented on FLINK-30259:
[~chesnay] You're better suited to answ
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30259:
Description:
The code of some modules of the current Flink project uses the 'assert' keyword
of java to d
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30259:
Description:
The code of some modules of the current Flink project uses the 'assert' keyword
of java to d
[
https://issues.apache.org/jira/browse/FLINK-30259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30259:
Description:
The code of some modules of the current Flink project uses the 'assert' keyword
of java to d
Zakelly commented on code in PR #21362:
URL: https://github.com/apache/flink/pull/21362#discussion_r1036946214
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/InternalKeyContextImpl.java:
##
@@ -72,6 +73,10 @@ public void setCurrentKey(@Nonnull K currentKey) {
ferenc-csaky commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-hbase/pull/2#discussion_r1036960125
##
pom.xml:
##
@@ -0,0 +1,540 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
Matthias Pohl created FLINK-30261:
-
Summary: PartiallyFinishedSourcesITCase.test timed out while
waiting for tasks to finish
Key: FLINK-30261
URL: https://issues.apache.org/jira/browse/FLINK-30261
Pro
[
https://issues.apache.org/jira/browse/FLINK-28319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641832#comment-17641832
]
Matthias Pohl commented on FLINK-28319:
---
> 1.15:
> https://dev.azure.com/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641832#comment-17641832
]
Matthias Pohl edited comment on FLINK-28319 at 12/1/22 11:04 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641837#comment-17641837
]
Piotr Nowojski commented on FLINK-29634:
Oh, thanks for correcting me [~thw]. Ye
rmetzger commented on PR #21436:
URL: https://github.com/apache/flink/pull/21436#issuecomment-1333609703
Thx for the PR. Can you also update the commit message, for example to the
PR title?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
rmetzger commented on PR #21436:
URL: https://github.com/apache/flink/pull/21436#issuecomment-1333611549
The CI failure seems to be caused by a known instability:
https://issues.apache.org/jira/browse/FLINK-30257
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641844#comment-17641844
]
Robert Metzger commented on FLINK-30257:
Another case:
https://dev.azure.com/ap
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641846#comment-17641846
]
Matthias Pohl commented on FLINK-29427:
---
https://dev.azure.com/apache-flink/apache
Matthias Pohl created FLINK-30262:
-
Summary: UpsertKafkaTableITCase failed when starting the container
because waiting for a port timed out
Key: FLINK-30262
URL: https://issues.apache.org/jira/browse/FLINK-30262
luoyuxia commented on PR #21290:
URL: https://github.com/apache/flink/pull/21290#issuecomment-1333634978
Thanks for contribution, I'll have a look when I'm free.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
boring-cyborg[bot] commented on PR #3:
URL:
https://github.com/apache/flink-connector-pulsar/pull/3#issuecomment-1333639936
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
dannycranmer commented on PR #21407:
URL: https://github.com/apache/flink/pull/21407#issuecomment-1333640951
@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 comme
[
https://issues.apache.org/jira/browse/FLINK-30116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641857#comment-17641857
]
ConradJam commented on FLINK-30116:
---
I was separated by something. It's done this week
reswqa commented on PR #21437:
URL: https://github.com/apache/flink/pull/21437#issuecomment-1333642182
@pnowojski Thank you very much for reminding me.
I'm sorry for forgetting this. I still keep two commits, but add Xiaogang as
a co-author on the second one.
--
This is an automated m
XComp commented on PR #21411:
URL: https://github.com/apache/flink/pull/21411#issuecomment-1333645254
But what's puzzling me now. Shouldn't that change already be in the external
repository? Or didn't you base the external repository on
`apache/flink:master`? :thinking:
The original
gaborgsomogyi opened a new pull request, #459:
URL: https://github.com/apache/flink-kubernetes-operator/pull/459
## What is the purpose of the change
When session jobs are in a specific states and cancel called they throw
exceptions. In this PR I've added test for each state and chang
gaborgsomogyi commented on PR #459:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/459#issuecomment-1333650021
cc @gyfora
--
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 spec
Shammon created FLINK-30263:
---
Summary: Introduce schemas table to table store
Key: FLINK-30263
URL: https://issues.apache.org/jira/browse/FLINK-30263
Project: Flink
Issue Type: New Feature
MartijnVisser commented on PR #21411:
URL: https://github.com/apache/flink/pull/21411#issuecomment-1333684866
> Or didn't you base the external repository on `apache/flink:master`? 🤔
Correct, because `master` has a breaking change in 1.17 (see
https://issues.apache.org/jira/browse/FLI
[
https://issues.apache.org/jira/browse/FLINK-30263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-30263:
Parent: FLINK-29735
Issue Type: Sub-task (was: New Feature)
> Introduce schemas table to table st
[
https://issues.apache.org/jira/browse/FLINK-30263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-30263:
Summary: Introduce schemas meta table (was: Introduce schemas table to
table store)
> Introduce schemas
[
https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641895#comment-17641895
]
Benchao Li commented on FLINK-30158:
bq. Even if I commented out the second column i
ferenc-csaky commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-hbase/pull/2#discussion_r1037073397
##
pom.xml:
##
@@ -0,0 +1,540 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
zentol opened a new pull request, #21438:
URL: https://github.com/apache/flink/pull/21438
Upgrade to the latest stable Zookeeper release. This client is compatible
with 3.5 onwards.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-29420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29420:
---
Labels: pull-request-available (was: )
> Upgrade Zookeeper to 3.7
> ---
Xin Hao created FLINK-30264:
---
Summary: Set session job status to FAILED if already have retried
max attempts
Key: FLINK-30264
URL: https://issues.apache.org/jira/browse/FLINK-30264
Project: Flink
flinkbot commented on PR #21438:
URL: https://github.com/apache/flink/pull/21438#issuecomment-1333737839
## CI report:
* fe9e8639ac54e1ca4e21fdfec43ef590fa58bd0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[ https://issues.apache.org/jira/browse/FLINK-28319 ]
Matthias Pohl deleted comment on FLINK-28319:
---
was (Author: mapohl):
{quote}
1.15:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43637&view=logs&j=4d4a0d10-fca2-55
[
https://issues.apache.org/jira/browse/FLINK-30261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-30261.
-
Resolution: Not A Problem
Closing this issue. I interpreted the thread dump in a wrong way. FLIN
pnowojski merged PR #21437:
URL: https://github.com/apache/flink/pull/21437
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641908#comment-17641908
]
Piotr Nowojski commented on FLINK-27944:
merged commit 20808fd into apache:maste
[ https://issues.apache.org/jira/browse/FLINK-27944 ]
Piotr Nowojski deleted comment on FLINK-27944:
was (Author: pnowojski):
merged commit 20808fd into apache:master
> IO metrics collision happens if a task has union inputs
>
XComp commented on PR #21411:
URL: https://github.com/apache/flink/pull/21411#issuecomment-1333752687
thanks for clarification :+1:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific c
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-27944:
---
Fix Version/s: 1.17.0
1.16.1
1.15.4
> IO metrics colli
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641916#comment-17641916
]
Piotr Nowojski commented on FLINK-27944:
merged to master as 20808fd^ and 20808f
MartijnVisser merged PR #3:
URL: https://github.com/apache/flink-connector-pulsar/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, e-mail: issues-unsubscr
boring-cyborg[bot] commented on PR #3:
URL:
https://github.com/apache/flink-connector-pulsar/pull/3#issuecomment-1333791651
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29830:
---
Fix Version/s: pulsar-3.0.1
> PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar fa
[
https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641928#comment-17641928
]
Martijn Visser commented on FLINK-29830:
Fixed in Pulsar external connector repo
mobuchowski commented on PR #15102:
URL: https://github.com/apache/flink/pull/15102#issuecomment-1333794633
@MartijnVisser thanks - I will spend some time over weekend to check if the
code isn't too far from current main branch, and try to generate some interest
on the mailing lists.
--
zentol commented on code in PR #20919:
URL: https://github.com/apache/flink/pull/20919#discussion_r1037128521
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/inputformat/InputFormatCacheLoader.java:
##
@@ -107,7 +1
dannycranmer merged PR #21370:
URL: https://github.com/apache/flink/pull/21370
--
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.
dannycranmer merged PR #21427:
URL: https://github.com/apache/flink/pull/21427
--
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.
dannycranmer commented on PR #21426:
URL: https://github.com/apache/flink/pull/21426#issuecomment-1333802674
>Error: module "github.com/apache/flink-connector-elasticsearch/docs" not
found; either add it as a Hugo Module or store it in
"/home/vsts/work/1/s/docs/themes".: module does not exi
dannycranmer merged PR #21426:
URL: https://github.com/apache/flink/pull/21426
--
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.
reswqa opened a new pull request, #21439:
URL: https://github.com/apache/flink/pull/21439
## What is the purpose of the change
*If a task has multiple input gates, It will create as many
`InputChannelMetrics` as the number of gates, so the corresponding metrics are
registered repeate
1 - 100 of 220 matches
Mail list logo
