[
https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Smirnov updated FLINK-31729:
--
Attachment: image-2023-04-06-13-56-21-971.png
> Unexpected UPDATE_BEFORE output record
[
https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Smirnov updated FLINK-31729:
--
Attachment: image-2023-04-06-13-56-08-998.png
> Unexpected UPDATE_BEFORE output record
[
https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Smirnov updated FLINK-31729:
--
Attachment: image-2023-04-06-13-55-42-242.png
> Unexpected UPDATE_BEFORE output record
XComp commented on code in PR #21736:
URL: https://github.com/apache/flink/pull/21736#discussion_r1159348658
##
flink-test-utils-parent/flink-migration-test-utils/src/main/java/org/apache/flink/test/migration/MigrationTestsSnapshotGenerator.java:
##
@@ -0,0 +1,253 @@
+/*
+ * Lic
xuzhiwen1255 commented on PR #22208:
URL: https://github.com/apache/flink/pull/22208#issuecomment-1498565719
@wuchong If you have time, please check back. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
xuzhiwen1255 commented on PR #28:
URL:
https://github.com/apache/flink-connector-jdbc/pull/28#issuecomment-1498564999
@MartijnVisser His description is correct, but his configuration key is
incorrectly named.
Because he's using the old key.
But when I look at the code,jdbc collec
reswqa merged PR #22347:
URL: https://github.com/apache/flink/pull/22347
--
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
reswqa commented on PR #22347:
URL: https://github.com/apache/flink/pull/22347#issuecomment-1498553229
Thanks @TanYuxin-tyx for the review, merged.
--
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
reswqa merged PR #22361:
URL: https://github.com/apache/flink/pull/22361
--
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
reswqa commented on PR #22361:
URL: https://github.com/apache/flink/pull/22361#issuecomment-1498552494
Thanks @TanYuxin-tyx for the review, merged.
--
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
[
https://issues.apache.org/jira/browse/FLINK-31544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-31544:
--
Assignee: Fang Yong
> Introduce FlinkDatabaseMetaData for jdbc driver
> -
FangYongs commented on PR #22362:
URL: https://github.com/apache/flink/pull/22362#issuecomment-1498529894
Hi @libenchao Please help to review this PR when you're free, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
liuyongvs commented on code in PR #19873:
URL: https://github.com/apache/flink/pull/19873#discussion_r1159302878
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayAppendPrependTypeStrategy.java:
##
@@ -0,0 +1,55 @@
+/*
+ * Lic
mas-chen commented on PR #22291:
URL: https://github.com/apache/flink/pull/22291#issuecomment-1498516945
> > arithmetic overflow when the source is idle" or something similar?
>
> Absolutely!
"[[FLINK-31632](https://issues.apache.org/jira/browse/FLINK-31632)] Fix
maxAllowedWatermark
mas-chen commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1159300038
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java:
##
@@ -167,6 +167,9 @@ public void testWatermarkAlignm
[
https://issues.apache.org/jira/browse/FLINK-24785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709211#comment-17709211
]
jinghaihang commented on FLINK-24785:
-
[~yunta] ,Thanks for your reply.
I agree wit
[
https://issues.apache.org/jira/browse/FLINK-31742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709210#comment-17709210
]
Ran Tao commented on FLINK-31742:
-
[~icshuo] Yes. i changed the issue name. we can repla
[
https://issues.apache.org/jira/browse/FLINK-31742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31742:
Description: we can try to remove deprecated TableSchema and use Schema &
ResolvedSchema to replace it. (
[
https://issues.apache.org/jira/browse/FLINK-31742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31742:
Summary: Replace deprecated TableSchema in flink-table-planner test (was:
Remove deprecated TableSchema i
flinkbot commented on PR #22362:
URL: https://github.com/apache/flink/pull/22362#issuecomment-1498505826
## CI report:
* e37ef659f2937d871f9e26af1235edd142d736e8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709203#comment-17709203
]
Shuo Cheng commented on FLINK-31742:
Hi, [~lemonjing] , changes of public API genera
[
https://issues.apache.org/jira/browse/FLINK-31544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31544:
---
Labels: pull-request-available (was: )
> Introduce FlinkDatabaseMetaData for jdbc driver
>
FangYongs opened a new pull request, #22362:
URL: https://github.com/apache/flink/pull/22362
## What is the purpose of the change
This PR aims to introduce database meta for jdbc driver
## Brief change log
- Added `FlinkDatabaseMeta`
- Added `CloseableResultIterato
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reopened FLINK-28198:
-
> CassandraConnectorITCase fails with timeout
> ---
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709197#comment-17709197
]
Sergey Nuyanzin commented on FLINK-28198:
-
still reproduced for 1.16
https://dev
flinkbot commented on PR #22361:
URL: https://github.com/apache/flink/pull/22361#issuecomment-1498462140
## CI report:
* a1679e3923606de92788a5837e9142b27b1d4a47 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
huwh commented on code in PR #22308:
URL: https://github.com/apache/flink/pull/22308#discussion_r1159255563
##
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DefaultDispatcherResourceManagerComponentFactory.java:
##
@@ -176,6 +176,10 @@ public Dispatch
haishui126 commented on PR #22291:
URL: https://github.com/apache/flink/pull/22291#issuecomment-1498458381
> @haishui126 can we add a more meaningful commit message such as
"[FLINK-XYZ] Fix maxAllowedWatermark arithmetic overflow when the source is
idle" or something similar?
Absolut
[
https://issues.apache.org/jira/browse/FLINK-31670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31670:
---
Labels: pull-request-available (was: )
> ElasticSearch connector's document was not incorre
reswqa opened a new pull request, #22361:
URL: https://github.com/apache/flink/pull/22361
## What is the purpose of the change
*In the
[doc](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/elasticsearch/),
It still use "flink-version" for flink-connect
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709178#comment-17709178
]
luoyuxia commented on FLINK-31689:
--
[~jirawech.s] Assign to you~ You can tried in your
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-31689:
Assignee: jirawech.s (was: luoyuxia)
> Filesystem sink fails when parallelism of compactor opera
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-31689:
Assignee: luoyuxia
> Filesystem sink fails when parallelism of compactor operator changed
> -
[
https://issues.apache.org/jira/browse/FLINK-31741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-31741:
--
Assignee: Fang Yong
> Supports data conversion according to type for executor
> -
flinkbot commented on PR #22360:
URL: https://github.com/apache/flink/pull/22360#issuecomment-1498449680
## CI report:
* dcbaa06d17c31c7d5f9eaff064ea3849fd1b1670 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
FangYongs commented on PR #22360:
URL: https://github.com/apache/flink/pull/22360#issuecomment-1498448558
Hi @libenchao Please help to review this PR when you're free, thanks
--
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-31741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31741:
---
Labels: pull-request-available (was: )
> Supports data conversion according to type for exe
FangYongs opened a new pull request, #22360:
URL: https://github.com/apache/flink/pull/22360
## What is the purpose of the change
This PR aims to convert string value in `StatementResult` to different value
for `ResultSet`
## Brief change log
- Added `DataConverter
Ran Tao created FLINK-31742:
---
Summary: Remove deprecated TableSchema in flink-table-planner test
Key: FLINK-31742
URL: https://issues.apache.org/jira/browse/FLINK-31742
Project: Flink
Issue Type: T
[
https://issues.apache.org/jira/browse/FLINK-31732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-31732:
--
Component/s: Library / Machine Learning
> flink-ml-uber module should include statefun as a de
[
https://issues.apache.org/jira/browse/FLINK-31732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang closed FLINK-31732.
-
Resolution: Won't Fix
We leave state-fun as a third party dependency for now.
> flink-ml-uber m
[
https://issues.apache.org/jira/browse/FLINK-31610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709173#comment-17709173
]
Rui Fan commented on FLINK-31610:
-
Thanks [~akalash] driving this JIRA, and thanks [~We
huwh commented on code in PR #22305:
URL: https://github.com/apache/flink/pull/22305#discussion_r1159241282
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/RequiredRedundantResource.java:
##
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Soft
haishui126 commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1159239249
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java:
##
@@ -167,6 +167,9 @@ public void testWatermarkAlig
[
https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709170#comment-17709170
]
xingyuan cheng commented on FLINK-31530:
[~jark] Hello, when we implement the CD
[
https://issues.apache.org/jira/browse/FLINK-27128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709167#comment-17709167
]
LiJun commented on FLINK-27128:
---
it is apparently a bug from my point of view. why is th
xintongsong commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1159213039
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the
reswqa commented on code in PR #22306:
URL: https://github.com/apache/flink/pull/22306#discussion_r1159228040
##
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultSlotStatusSyncerTest.java:
##
@@ -114,6 +114,64 @@ void testAllocateSlot() thr
huwh commented on PR #22306:
URL: https://github.com/apache/flink/pull/22306#issuecomment-1498409854
Thanks @reswqa , I have updated this pr.
--
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 t
Fang Yong created FLINK-31741:
-
Summary: Supports data conversion according to type for executor
Key: FLINK-31741
URL: https://issues.apache.org/jira/browse/FLINK-31741
Project: Flink
Issue Type:
mas-chen commented on PR #22291:
URL: https://github.com/apache/flink/pull/22291#issuecomment-1498406007
@haishui126 can we add a more meaningful commit message such as "[FLINK-XYZ]
Fix maxAllowedWatermark arithmetic overflow when the source is idle" or
something similar?
--
This is an a
mas-chen commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1159221918
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java:
##
@@ -167,6 +167,9 @@ public void testWatermarkAlignm
[
https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709152#comment-17709152
]
luoyuxia commented on FLINK-31729:
--
[~smiralex] Thanks for reporting. But I'm wondering
zoltar9264 commented on PR #21822:
URL: https://github.com/apache/flink/pull/21822#issuecomment-1498381893
Hi @curcur and @rkhachatryan , can you help us review this pr ?
--
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-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-31301:
---
Assignee: Aitozi
> Unsupported nested columns in column list of insert statement
>
[
https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709149#comment-17709149
]
lincoln lee commented on FLINK-31301:
-
[~aitozi] welcome for contributing! assigned
gaoyunhaii commented on code in PR #21736:
URL: https://github.com/apache/flink/pull/21736#discussion_r1159187859
##
flink-test-utils-parent/flink-migration-test-utils/src/main/java/org/apache/flink/test/migration/MigrationTestsSnapshotGenerator.java:
##
@@ -0,0 +1,253 @@
+/*
+
mas-chen commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1159178247
##
flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorAlignmentTest.java:
##
@@ -83,6 +83,22 @@ void testWatermarkAlignmentWithId
tzulitai commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159168995
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java:
##
@@ -388,6 +391,201 @@ public void t
tzulitai commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159168995
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java:
##
@@ -388,6 +391,201 @@ public void t
mas-chen commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1159166591
##
flink-formats-confluent/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroFormatFactory.java:
###
tzulitai commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159161297
##
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java:
##
@@ -145,7 +145,7 @@ public stati
tzulitai commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159159130
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java:
##
@@ -388,6 +391,201 @@ public void t
tzulitai commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159159130
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java:
##
@@ -388,6 +391,201 @@ public void t
Ge commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159155943
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java:
##
@@ -388,6 +391,201 @@ public void tes
Ge commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159122981
##
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java:
##
@@ -145,7 +145,7 @@ public static
tzulitai commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#discussion_r1159113822
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java:
##
@@ -388,6 +391,201 @@ public void t
tzulitai commented on PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#issuecomment-1498264961
cc @twalthr @dawidwys @Ge for review, thank you :)
--
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-31740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31740:
---
Labels: pull-request-available (was: )
> Allow setting boundedness for upsert-kafka SQL con
tzulitai opened a new pull request, #22:
URL: https://github.com/apache/flink-connector-kafka/pull/22
This is a "follow-up" to previous work in
https://github.com/apache/flink/pull/21808 that added boundedness options for
the SQL Kafka Connector. This PR does the same for the SQL Upsert Kaf
Tzu-Li (Gordon) Tai created FLINK-31740:
---
Summary: Allow setting boundedness for upsert-kafka SQL connector
Key: FLINK-31740
URL: https://issues.apache.org/jira/browse/FLINK-31740
Project: Flink
nateab closed pull request #22313: [FLINK-31660][connector-kafka] fix kafka
connector pom so ITCases run in IDE
URL: https://github.com/apache/flink/pull/22313
--
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
nateab commented on PR #22313:
URL: https://github.com/apache/flink/pull/22313#issuecomment-1498155014
@zentol Thanks for the suggestion, i was able to get it working now after
building it on the command line.
@twalthr Yes I believe you are correct.
Here is a new PR that has a
nateab commented on code in PR #22313:
URL: https://github.com/apache/flink/pull/22313#discussion_r1159018047
##
flink-connectors/flink-connector-kafka/pom.xml:
##
@@ -225,6 +241,23 @@ under the License.
+
+
flinkbot commented on PR #22359:
URL: https://github.com/apache/flink/pull/22359#issuecomment-1498148518
## CI report:
* c96df5042093ce7ee8ab284888d627a554c5746e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
nateab opened a new pull request, #22359:
URL: https://github.com/apache/flink/pull/22359
## What is the purpose of the change
This PR adds the `json-path` dependency to the table-planner pom so that
`ITCases` in the kafka connector module can run in the Intellij IDE. This is
due to
tzulitai commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1158843434
##
flink-formats-confluent/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroFormatFactory.java:
###
mas-chen commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1158835180
##
flink-formats-confluent/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroFormatFactory.java:
###
tzulitai commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1158798008
##
flink-formats-confluent/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroFormatFactory.java:
###
dmvk commented on PR #22350:
URL: https://github.com/apache/flink/pull/22350#issuecomment-1497788210
For the UX comments: I'm not a UX person, and this is good enough for the
demo purpose (it was not meant for serious usage, that's what REST API is for).
We touched on this a few weeks back
reswqa closed pull request #56: [Do Not Merge] Test V3.0 CI
URL: https://github.com/apache/flink-connector-elasticsearch/pull/56
--
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-31739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31739:
---
Labels: pull-request-available (was: )
> ElasticSearch and Cassandra connector v3.0 branch'
boring-cyborg[bot] commented on PR #6:
URL:
https://github.com/apache/flink-connector-cassandra/pull/6#issuecomment-1497771418
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
reswqa opened a new pull request, #6:
URL: https://github.com/apache/flink-connector-cassandra/pull/6
Use the common `ci.yml` in `flink-connector-shared-utils` for v3.0 branch's
workflows instead of standalone yml.
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-31518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708995#comment-17708995
]
Samrat Deb commented on FLINK-31518:
[~huwh] please review the pr in free time
> H
[
https://issues.apache.org/jira/browse/FLINK-31214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb resolved FLINK-31214.
Resolution: Fixed
master :- f8b0834fb83b7d17ac9eeaf09f2f6cea070c978a
> Add support for new comman
Weijie Guo created FLINK-31739:
--
Summary: ElasticSearch and Cassandra connector v3.0 branch's CI is
not working properly
Key: FLINK-31739
URL: https://issues.apache.org/jira/browse/FLINK-31739
Project: F
Samrat002 commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-1497724491
> 2. Can we create e2e tests using localstack or something similar? I have
not looked to see if anything exist
created separate jira to add e2e
https://issues.apache
JosemyAB closed pull request #57: Implementation of oficial exercises
URL: https://github.com/apache/flink-training/pull/57
--
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 u
mohsenrezaeithe commented on PR #21849:
URL: https://github.com/apache/flink/pull/21849#issuecomment-1497710031
@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 co
akalash closed pull request #19018: [FLINK-25819][runtime] Reordered requesting
and recycling buffers in order to avoid race condition in
testIsAvailableOrNotAfterRequestAndRecycleMultiSegments
URL: https://github.com/apache/flink/pull/19018
--
This is an automated message from the Apache Gi
akalash closed pull request #17825: Test case for remapping keygroups
URL: https://github.com/apache/flink/pull/17825
--
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 unsubsc
akalash closed pull request #16471: [FLINK-22893][tests] Wait for all task
running before externalized ch…
URL: https://github.com/apache/flink/pull/16471
--
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 g
akalash closed pull request #16224: Added LoadRebalancePartitioner in order to
select the freest subparti…
URL: https://github.com/apache/flink/pull/16224
--
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 g
reta commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1158673505
##
.github/workflows/weekly.yml:
##
@@ -26,7 +26,7 @@ jobs:
if: github.repository_owner == 'apache'
strategy:
matrix:
-flink: [1.1
reta opened a new pull request, #16:
URL: https://github.com/apache/flink-connector-opensearch/pull/16
Fixing the compilation issue for 1.18 (see please
https://github.com/apache/flink-connector-opensearch/actions/runs/4615625503/jobs/8159702829).
```
Error:
/home/runner/work/fli
[
https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708948#comment-17708948
]
Aitozi commented on FLINK-31301:
Hello [~lincoln.86xy], I want to contribute to this tic
reswqa commented on PR #42:
URL:
https://github.com/apache/flink-connector-pulsar/pull/42#issuecomment-1497627697
Thanks @tisonkun, the explanation of the `Concurrency strategy` in this PR
is very useful 👍
--
This is an automated message from the Apache Git Service.
To respond to the me
dmvk commented on PR #22350:
URL: https://github.com/apache/flink/pull/22350#issuecomment-1497623195
Thanks for the review Chesnay, I've addressed the comments and scheduled
some follow-ups. PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
flinkbot commented on PR #22358:
URL: https://github.com/apache/flink/pull/22358#issuecomment-1497621576
## CI report:
* 8db2f4bab4db12d8c90208cbb4b09b8ff3d61a30 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1 - 100 of 214 matches
Mail list logo
