JingsongLi commented on code in PR #519:
URL: https://github.com/apache/flink-table-store/pull/519#discussion_r1104106559
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/ContinuousFileSplitEnumeratorTest.java:
##
@@ -0,0 +1,154 @@
+/*
+
wuchong commented on PR #21675:
URL: https://github.com/apache/flink/pull/21675#issuecomment-1427522105
Please check the CI pipeline, it seems the
`FlinkSqlParserImplTest.testCreateFunction` failed.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
MartijnVisser commented on PR #25:
URL:
https://github.com/apache/flink-connector-pulsar/pull/25#issuecomment-1427524199
> @MartijnVisser Any ideas on this? The new Pulsar docker instance running
in JDK 17 may require more memory than the limit?
Flink doesn't support Java 17 so I'm n
syhily commented on PR #25:
URL:
https://github.com/apache/flink-connector-pulsar/pull/25#issuecomment-1427525624
> > @MartijnVisser Any ideas on this? The new Pulsar docker instance running
in JDK 17 may require more memory than the limit?
>
> Flink doesn't support Java 17 so I'm no
JingsongLi commented on code in PR #522:
URL: https://github.com/apache/flink-table-store/pull/522#discussion_r1104117049
##
docs/layouts/shortcodes/generated/flink_connector_configuration.html:
##
@@ -20,6 +20,12 @@
Integer
Define a custom parallelism
liming30 commented on code in PR #519:
URL: https://github.com/apache/flink-table-store/pull/519#discussion_r1104127249
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/ContinuousFileSplitEnumeratorTest.java:
##
@@ -0,0 +1,154 @@
+/*
+ *
XComp merged PR #21905:
URL: https://github.com/apache/flink/pull/21905
--
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.
XComp merged PR #21906:
URL: https://github.com/apache/flink/pull/21906
--
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.
link3280 commented on code in PR #21912:
URL: https://github.com/apache/flink/pull/21912#discussion_r1104131821
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -812,4 +812,35 @@ Flink SQL> RESET pipeline.name;
If the option `pipeline.name` is not specified, SQL Client will
[
https://issues.apache.org/jira/browse/FLINK-30944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30944:
--
Affects Version/s: (was: 1.18.0)
> ExecutionGraphPartitionReleaseTest leaks threads
>
[
https://issues.apache.org/jira/browse/FLINK-31015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687796#comment-17687796
]
Ran Tao commented on FLINK-31015:
-
[~mapohl] I think you are right. Can you assign this
xuzifu666 opened a new pull request, #21914:
URL: https://github.com/apache/flink/pull/21914
## 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-23563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Han Yin closed FLINK-23563.
---
Resolution: Abandoned
> Sometimes ‘Stop’ cannot stop the job
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-30944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30944.
---
Fix Version/s: 1.17.0
1.16.2
Resolution: Fixed
* master: df23acfc0
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31003.
--
Resolution: Duplicate
> Flink SQL IF / CASE WHEN Funcation incorrect
> ---
[
https://issues.apache.org/jira/browse/FLINK-31015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687796#comment-17687796
]
Ran Tao edited comment on FLINK-31015 at 2/13/23 8:32 AM:
--
[~ma
xuzifu666 commented on PR #21914:
URL: https://github.com/apache/flink/pull/21914#issuecomment-1427539886
@reswqa have a review plz，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 to go to the spec
wuchong commented on code in PR #21675:
URL: https://github.com/apache/flink/pull/21675#discussion_r1104129280
##
pom.xml:
##
@@ -1500,6 +1500,8 @@ under the License.
flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations
[
https://issues.apache.org/jira/browse/FLINK-30703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687799#comment-17687799
]
Matthias Pohl commented on FLINK-30703:
---
Sure, considering that the connectors are
MartijnVisser commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-jdbc/pull/18#discussion_r1104137704
##
flink-connector-jdbc/pom.xml:
##
@@ -39,7 +39,7 @@ under the License.
2.12.7
3.23.1
42.5.1
-
XComp commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1102601255
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarPartitionSplitReader.java:
##
@@ -231,7 +232,11 @@ public void
flinkbot commented on PR #21914:
URL: https://github.com/apache/flink/pull/21914#issuecomment-1427547541
## CI report:
* 26ae9f133d74775fd40a1642d7d83a07b11f34c3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa closed pull request #607: Add Weijie Guo to the committer list
URL: https://github.com/apache/flink-web/pull/607
--
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 unsub
XComp commented on code in PR #21742:
URL: https://github.com/apache/flink/pull/21742#discussion_r1104142315
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java:
##
@@ -100,6 +100,7 @@ public final void stop() throws Exception
lsyldliu commented on PR #21896:
URL: https://github.com/apache/flink/pull/21896#issuecomment-1427547841
@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.
eskabetxe commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-jdbc/pull/18#discussion_r1104143374
##
flink-connector-jdbc/pom.xml:
##
@@ -39,7 +39,7 @@ under the License.
2.12.7
3.23.1
42.5.1
-
[
https://issues.apache.org/jira/browse/FLINK-31031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-31031.
---
Fix Version/s: 1.17.0
1.15.4
1.16.2
Resolution: Fixed
Fixed in:
dannycranmer commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1104151987
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchAsyncWriter.java:
##
@@ -0,0 +1,308 @@
+/*
+ * Licen
reswqa commented on PR #21914:
URL: https://github.com/apache/flink/pull/21914#issuecomment-1427558724
@xuzifu666 Thanks for creating this. Could you explain why it is necessary
to print warn-level logs here? Personally, this only happens when the `ZNode`
is modified concurrently. The frame
Shammon created FLINK-31032:
---
Summary: Supports AND predicate in orc format for table store
Key: FLINK-31032
URL: https://issues.apache.org/jira/browse/FLINK-31032
Project: Flink
Issue Type: Improv
FangYongs opened a new pull request, #527:
URL: https://github.com/apache/flink-table-store/pull/527
This PR aims to supports `AND` push down in orc format.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-31032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31032:
---
Labels: pull-request-available (was: )
> Supports AND predicate in orc format for table sto
xuzifu666 commented on PR #21914:
URL: https://github.com/apache/flink/pull/21914#issuecomment-1427566862
> @xuzifu666 Thanks for creating this. Could you explain why it is necessary
to print warn-level logs here? Personally, this only happens when the `ZNode`
is modified concurrently. The
[
https://issues.apache.org/jira/browse/FLINK-31015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687813#comment-17687813
]
Matthias Pohl commented on FLINK-31015:
---
Thanks for picking it up. I would treat {
[
https://issues.apache.org/jira/browse/FLINK-31015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-31015:
-
Assignee: Ran Tao
> SplitReader doesn't extend AutoCloseable but implements close
> ---
Matthias Pohl created FLINK-31033:
-
Summary: UsingRemoteJarITCase.testUdfInRemoteJar failed with
assertion
Key: FLINK-31033
URL: https://issues.apache.org/jira/browse/FLINK-31033
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686895#comment-17686895
]
Matthias Pohl edited comment on FLINK-30972 at 2/13/23 9:05 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687821#comment-17687821
]
Matthias Pohl commented on FLINK-18356:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687818#comment-17687818
]
Matthias Pohl commented on FLINK-30629:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687820#comment-17687820
]
Matthias Pohl commented on FLINK-30629:
---
[~Jiangang] can you have a look at this o
zentol commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r1104175505
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
determinePar
[
https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687822#comment-17687822
]
Dian Fu commented on FLINK-18235:
-
[~pnowojski] Thanks a lot for the advice! This is als
[
https://issues.apache.org/jira/browse/FLINK-30136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687823#comment-17687823
]
Matthias Pohl commented on FLINK-30136:
---
https://dev.azure.com/apache-flink/apache
Matthias Pohl created FLINK-31034:
-
Summary: Deploy Maven Snapshot failed
Key: FLINK-31034
URL: https://issues.apache.org/jira/browse/FLINK-31034
Project: Flink
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/FLINK-31034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687824#comment-17687824
]
Matthias Pohl commented on FLINK-31034:
---
It shouldn't be related to FLINK-30869 bu
[
https://issues.apache.org/jira/browse/FLINK-31034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687824#comment-17687824
]
Matthias Pohl edited comment on FLINK-31034 at 2/13/23 9:14 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687827#comment-17687827
]
Matthias Pohl commented on FLINK-30629:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687826#comment-17687826
]
Matthias Pohl commented on FLINK-18356:
---
https://dev.azure.com/apache-flink/apache
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1104184317
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/source/reader/CassandraQueryTest.java:
##
@@ -0,0 +1,140 @@
+/*
+ * Licen
xy created FLINK-31035:
--
Summary: add warn info to user when NoNodeException happend
Key: FLINK-31035
URL: https://issues.apache.org/jira/browse/FLINK-31035
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-31015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687830#comment-17687830
]
Ran Tao commented on FLINK-31015:
-
[~mapohl] Thanks. Got it.
> SplitReader doesn't exte
Matthias Pohl created FLINK-31036:
-
Summary: StateCheckpointedITCase timed out due to deadlock
Key: FLINK-31036
URL: https://issues.apache.org/jira/browse/FLINK-31036
Project: Flink
Issue Typ
link3280 commented on PR #21912:
URL: https://github.com/apache/flink/pull/21912#issuecomment-1427606282
> Could you also to modify the Chinese page
Sure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687833#comment-17687833
]
Matthias Pohl commented on FLINK-31036:
---
[~roman] [~ym] can you help identifying t
gaoyunhaii commented on code in PR #21736:
URL: https://github.com/apache/flink/pull/21736#discussion_r1104194388
##
flink-test-utils-parent/flink-migration-test-utils/src/main/java/org/apache/flink/test/migration/MigrationTestsSnapshotGenerator.java:
##
@@ -0,0 +1,152 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-30965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687834#comment-17687834
]
Matthias Pohl commented on FLINK-30965:
---
1.15 doesn't get updated anymore: We see
vacaly commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1104201701
##
flink-ml-lib/src/test/java/org/apache/flink/ml/recommendation/SwingTest.java:
##
@@ -0,0 +1,236 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1104204559
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/source/reader/CassandraQueryTest.java:
##
@@ -0,0 +1,140 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687835#comment-17687835
]
Weijie Guo commented on FLINK-30629:
[~mapohl] It seems that the recent failed test
[
https://issues.apache.org/jira/browse/FLINK-30972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686895#comment-17686895
]
Matthias Pohl edited comment on FLINK-30972 at 2/13/23 9:36 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687835#comment-17687835
]
Weijie Guo edited comment on FLINK-30629 at 2/13/23 9:37 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687838#comment-17687838
]
Matthias Pohl commented on FLINK-30629:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687837#comment-17687837
]
Matthias Pohl commented on FLINK-30629:
---
Thanks for looking into it, [~Weijie Guo]
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687839#comment-17687839
]
Matthias Pohl commented on FLINK-28440:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687840#comment-17687840
]
Matthias Pohl commented on FLINK-18356:
---
https://dev.azure.com/apache-flink/apache
chucheng92 opened a new pull request, #21915:
URL: https://github.com/apache/flink/pull/21915
## What is the purpose of the change
SplitReader doesn't extend AutoCloseable but implements close method. We
need to let it extends AutoCloseable which could enable us to utilize Java's
tr
[
https://issues.apache.org/jira/browse/FLINK-31015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31015:
---
Labels: pull-request-available (was: )
> SplitReader doesn't extend AutoCloseable but imple
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687838#comment-17687838
]
Matthias Pohl edited comment on FLINK-30629 at 2/13/23 9:43 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687842#comment-17687842
]
Matthias Pohl commented on FLINK-30629:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687841#comment-17687841
]
Matthias Pohl commented on FLINK-18356:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687843#comment-17687843
]
Leonard Xu commented on FLINK-30960:
[~ShawnHx] Would you like to look into this tic
[
https://issues.apache.org/jira/browse/FLINK-30822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687844#comment-17687844
]
Matthias Pohl commented on FLINK-30822:
---
https://dev.azure.com/apache-flink/apache
ruanhang1993 commented on PR #21889:
URL: https://github.com/apache/flink/pull/21889#issuecomment-1427636736
@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
chucheng92 closed pull request #21915: [FLINK-31015][connectors/common] Fix
SplitReader doesn't extends AutoCloseable but implements close method
URL: https://github.com/apache/flink/pull/21915
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-31036:
--
Component/s: (was: Runtime / State Backends)
> StateCheckpointedITCase timed out d
reswqa opened a new pull request, #21916:
URL: https://github.com/apache/flink/pull/21916
## What is the purpose of the change
*`ClientHeartbeatTest#testJobCancelledIfClientHeartbeatTimeout` gave an
inappropriate timeout value(1s), which will make it very unstable. Since we
should no
[
https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687845#comment-17687845
]
Matthias Pohl commented on FLINK-28424:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687847#comment-17687847
]
Matthias Pohl commented on FLINK-30629:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687849#comment-17687849
]
Matthias Pohl commented on FLINK-18356:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687847#comment-17687847
]
Matthias Pohl edited comment on FLINK-30629 at 2/13/23 9:53 AM:
--
gaoyunhaii commented on code in PR #21736:
URL: https://github.com/apache/flink/pull/21736#discussion_r1104224520
##
flink-test-utils-parent/flink-migration-test-utils/src/main/java/org/apache/flink/test/migration/MigrationTestsSnapshotGenerator.java:
##
@@ -0,0 +1,152 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687850#comment-17687850
]
Matthias Pohl commented on FLINK-26974:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687851#comment-17687851
]
Roman Khachatryan commented on FLINK-31036:
---
Thanks [~mapohl] ,
I briefly loo
flinkbot commented on PR #21916:
URL: https://github.com/apache/flink/pull/21916#issuecomment-1427652074
## CI report:
* 294159b3b585b0f2e6daf2d243be42b7ec7dd90c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-15550:
---
Could you also provide backports for the most-recent fix? It looks like the
test stability stil
[
https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687854#comment-17687854
]
Matthias Pohl commented on FLINK-27916:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687851#comment-17687851
]
Roman Khachatryan edited comment on FLINK-31036 at 2/13/23 10:00 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687855#comment-17687855
]
Weijie Guo commented on FLINK-30629:
I have opened a pr([https://github.com/apache/f
rkhachatryan merged PR #21812:
URL: https://github.com/apache/flink/pull/21812
--
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-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687856#comment-17687856
]
Matthias Pohl commented on FLINK-30629:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687857#comment-17687857
]
Matthias Pohl commented on FLINK-18356:
---
https://dev.azure.com/apache-flink/apache
chucheng92 opened a new pull request, #21917:
URL: https://github.com/apache/flink/pull/21917
## What is the purpose of the change
SplitReader doesn't extend AutoCloseable but implements close method. We
need to let it extends AutoCloseable which could enable us to utilize Java's
tr
gaoyunhaii commented on code in PR #21736:
URL: https://github.com/apache/flink/pull/21736#discussion_r1104224520
##
flink-test-utils-parent/flink-migration-test-utils/src/main/java/org/apache/flink/test/migration/MigrationTestsSnapshotGenerator.java:
##
@@ -0,0 +1,152 @@
+/*
+
gaoyunhaii commented on code in PR #21736:
URL: https://github.com/apache/flink/pull/21736#discussion_r1104239366
##
flink-core/pom.xml:
##
@@ -18,148 +18,203 @@ specific language governing permissions and limitations
under the License.
-->
http://maven.apache.org/POM/4.0.0";
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-28440.
-
Fix Version/s: 1.17.0
1.16.2
Resolution: Fixed
Thanks Feifan W
Jingsong Lee created FLINK-31037:
Summary: Table Store supports streaming reading a whole snapshot
in one checkpoint
Key: FLINK-31037
URL: https://issues.apache.org/jira/browse/FLINK-31037
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687864#comment-17687864
]
Rui Fan commented on FLINK-31036:
-
Thanks [~mapohl] reports this issue, and thanks [~ro
[
https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-24302:
Description:
Running the Pulsar connector with multiple split readers on Java 11 could throw
{{a
[
https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-24302:
Description:
Running the Pulsar connector with multiple split readers on Java 11 could throw
{{a
[
https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-24302:
Description:
Running the Pulsar connector with multiple split readers on Java 11 could throw
{{a
1 - 100 of 365 matches
Mail list logo
