1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566817400
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837533#comment-17837533
]
Vadim Vararu commented on FLINK-35115:
--
FYI it's reproducible in Kinesis -> Flink -
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566812379
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the License.
Xiqian YU created FLINK-35120:
-
Summary: Add Doris Pipeline connector integration test cases
Key: FLINK-35120
URL: https://issues.apache.org/jira/browse/FLINK-35120
Project: Flink
Issue Type: Imp
1996fanrui commented on code in PR #814:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/814#discussion_r1566801016
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/JobListFetcher.java:
##
@@ -19,12 +19,19 @@
import org.apache
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837531#comment-17837531
]
Muhammet Orazov commented on FLINK-34508:
-
Hey [~mapohl],
On the GitHub CI, the
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837530#comment-17837530
]
Muhammet Orazov commented on FLINK-34508:
-
In the Azure Pipeline the YarnFileSta
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35089:
---
Description:
Currently the `lastRecordAttributes1` and `lastRecordAttributes2` in the
`AbstractStre
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30081.
Fix Version/s: 1.20.0
Resolution: Fixed
master (1.20): 9cc5ab9caf368ef336599e7d48f679c8c975
liuml07 commented on PR #96:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/96#issuecomment-2058320749
Have you checked this PR?
https://github.com/apache/flink-connector-elasticsearch/pull/91
--
This is an automated message from the Apache Git Service.
To respond to t
xintongsong closed pull request #22547: [FLINK-30081][runtime] Reset unused
options like jvm-overhead.min/max for local executor
URL: https://github.com/apache/flink/pull/22547
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
xintongsong commented on code in PR #22547:
URL: https://github.com/apache/flink/pull/22547#discussion_r1566773890
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java:
##
@@ -285,4 +286,15 @@ private static void setConfigOptionToD
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486
]
Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 6:19 AM:
liuml07 commented on PR #91:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/91#issuecomment-2058316069
@reta Thanks for the advice. I have updated the patch accordingly. I think
the `allowInsecure` and the `sslContextSupplier` are mutually exclusive, so I
added some vali
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1566767092
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/input/FirstInputOfTwoInput.java:
##
@@ -54,4 +57,17 @@ public voi
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-35089:
Assignee: Xuannan Su
> Two input AbstractStreamOperator may throw NPE when receiving Reco
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1566744878
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -1085,6 +1085,54 @@ public void setUseSnapshotCompression(boolean
useSnapsh
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1566742123
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -181,4 +182,73 @@ public class ExecutionOptions {
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1566744878
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -1085,6 +1085,54 @@ public void setUseSnapshotCompression(boolean
useSnapsh
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837512#comment-17837512
]
Dian Fu commented on FLINK-35112:
-
Sounds reasonable for me. [~wzorgdrager] Do you want
[
https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35028:
---
Summary: Timer firing under async execution model (was: Processing timer
firing under async executi
[
https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-34127:
--
Assignee: Mason Chen
> Kafka connector repo runs a duplicate of `IntegrationTests` framework
[
https://issues.apache.org/jira/browse/FLINK-34320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-34320:
--
Assignee: (was: Mason Chen)
> Flink Kafka connector tests time out
>
[
https://issues.apache.org/jira/browse/FLINK-34320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-34320:
--
Assignee: Mason Chen
> Flink Kafka connector tests time out
> ---
[
https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35119:
---
Labels: pull-request-available (was: )
> UPDATE DataChangeEvent deserialized data is incorr
zhongqishang opened a new pull request, #3226:
URL: https://github.com/apache/flink-cdc/pull/3226
(no comment)
--
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 unsubscrib
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1566670603
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
Exception
Qishang Zhong created FLINK-35119:
-
Summary: UPDATE DataChangeEvent deserialized data is incorrect
Key: FLINK-35119
URL: https://issues.apache.org/jira/browse/FLINK-35119
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qishang Zhong updated FLINK-35119:
--
Description:
When DebeziumChangelogMode is upsert, the before of DataChangeEvent is null,
des
fredia commented on PR #24667:
URL: https://github.com/apache/flink/pull/24667#issuecomment-2058174500
@Zakelly @ljz2051 would you please take a look?
--
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
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r155895
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
Exception>
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r154885
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/input/FirstInputOfTwoInput.java:
##
@@ -54,4 +57,17 @@ public vo
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r153205
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -0,0 +1,140 @@
+/*
+ * L
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1566645709
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/input/FirstInputOfTwoInput.java:
##
@@ -54,4 +57,17 @@ public voi
fredia commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1566649212
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java:
##
@@ -349,6 +3
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486
]
Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 2:51 AM:
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486
]
Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 2:49 AM:
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486
]
Muhammet Orazov commented on FLINK-34508:
-
Hey all,
I have add changes to remov
roland created FLINK-35118:
--
Summary: StreamingHiveSource cannot track tables that have more
than 32,767 partitions
Key: FLINK-35118
URL: https://issues.apache.org/jira/browse/FLINK-35118
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837485#comment-17837485
]
ude commented on FLINK-35111:
-
[~dannycranmer] Thank you for your reply, but I found
Zakelly commented on PR #24644:
URL: https://github.com/apache/flink/pull/24644#issuecomment-2058127691
> Thanks for this pr! Overall, LGTM. I have one question:
>
> If a subtask completes its checkpoint but the job's overall checkpoint
fails, the FileMergingSnapshotManager will still
Zakelly commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1566633317
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java:
##
@@ -349,6 +
masteryhx commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1566625643
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -0,0 +1,153 @@
+/*
+ * Licensed to the
roland created FLINK-35117:
--
Summary: AsyncScalarFunction has a dependency issue.
Key: FLINK-35117
URL: https://issues.apache.org/jira/browse/FLINK-35117
Project: Flink
Issue Type: Bug
Com
Zakelly commented on code in PR #24663:
URL: https://github.com/apache/flink/pull/24663#discussion_r1566625619
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/AsyncKeyedStateBackend.java:
##
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
reswqa merged PR #24666:
URL: https://github.com/apache/flink/pull/24666
--
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
yuxiqian commented on code in PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221#discussion_r1566596993
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask
yuxiqian commented on code in PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221#discussion_r1566596993
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask
[
https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837471#comment-17837471
]
Jiabao Sun commented on FLINK-25537:
master: 138f1f9d17b7a58b092ee7d9fc4c20d968a7b33
Jiabao-Sun merged PR #24612:
URL: https://github.com/apache/flink/pull/24612
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.ap
Márton Balassi created FLINK-35116:
--
Summary: Upgrade JOSDK dependency to 4.8.3
Key: FLINK-35116
URL: https://issues.apache.org/jira/browse/FLINK-35116
Project: Flink
Issue Type: Improvement
jeyhunkarimov commented on PR #24658:
URL: https://github.com/apache/flink/pull/24658#issuecomment-2057338536
Ah no worries at all, there was a misunderstanding in communication.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
snuyanzin commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-aws/pull/115#discussion_r1566124545
##
flink-connector-aws/flink-connector-dynamodb/pom.xml:
##
@@ -34,6 +34,9 @@ under the License.
jar
+
+
--add-opens=java.base/java.u
[
https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837354#comment-17837354
]
Ricky Saltzer commented on FLINK-32212:
---
Verified we started hitting this pretty c
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837327#comment-17837327
]
Aleksandr Pilipenko commented on FLINK-35115:
-
[~dannycranmer] Agree, trying
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35094:
Fix Version/s: opensearch-1.2.0
> SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAP
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837324#comment-17837324
]
Sergey Nuyanzin commented on FLINK-35094:
-
Opensearch connector was fixed within
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837323#comment-17837323
]
Sergey Nuyanzin commented on FLINK-35094:
-
Merged as
[516a89864b38e35261675f873
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-35094:
---
Assignee: Sergey Nuyanzin
> SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNA
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-35094.
-
Fix Version/s: elasticsearch-3.2.0
Resolution: Fixed
> SinkTestSuiteBase.testScal
snuyanzin commented on PR #97:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/97#issuecomment-2057107944
Thanks for taking a look
--
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
snuyanzin merged PR #97:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/97
--
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-uns
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837319#comment-17837319
]
Hong Liang Teoh commented on FLINK-35115:
-
[~dannycranmer] That is true, unless
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837318#comment-17837318
]
Danny Cranmer commented on FLINK-35115:
---
Stop with savepoint checkpointing logic i
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837315#comment-17837315
]
Hong Liang Teoh commented on FLINK-35115:
-
[~a.pilipenko] Assigned to you, as y
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-35115:
---
Assignee: Aleksandr Pilipenko
> Kinesis connector writes wrong Kinesis sequence num
klam-shop commented on code in PR #24482:
URL: https://github.com/apache/flink/pull/24482#discussion_r1565935343
##
flink-formats/flink-protobuf-confluent-registry/src/test/java/org/apache/flink/formats/protobuf/registry/confluent/utils/FlinkToProtoSchemaConverterTest.java:
##
@
d20162416 commented on PR #24593:
URL: https://github.com/apache/flink/pull/24593#issuecomment-2057057881
@reswqa Excuse me, could you please help me check this PR? I appreciate your
support very much.
--
This is an automated message from the Apache Git Service.
To respond to the message,
boring-cyborg[bot] commented on PR #24:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/24#issuecomment-2057011070
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 lo
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vadim Vararu updated FLINK-35115:
-
Summary: Kinesis connector writes wrong Kinesis sequence number at stop
with savepoint (was: Ki
snuyanzin merged PR #24:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/24
--
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-unsubs
snuyanzin commented on PR #24:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/24#issuecomment-2057010314
thanks for taking a look
--
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
Vadim Vararu created FLINK-35115:
Summary: Kinesis connector writes wrong sequence number at stop
with savepoint
Key: FLINK-35115
URL: https://issues.apache.org/jira/browse/FLINK-35115
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vadim Vararu updated FLINK-35115:
-
Affects Version/s: 1.18.1
> Kinesis connector writes wrong sequence number at stop with savepoin
ferenc-csaky commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2056968781
Thanks, it passed now! is it okay to merge this change at this point for now?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837271#comment-17837271
]
Ryan Skraba commented on FLINK-31472:
-
1.20 Hadoop 3.1.3: Test (module: connect)
ht
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837272#comment-17837272
]
Ryan Skraba commented on FLINK-35041:
-
* 1.20 Test (module:core)
https://github.com
caicancai commented on PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#issuecomment-2056898849
cc @1996fanrui
--
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
[
https://issues.apache.org/jira/browse/FLINK-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837273#comment-17837273
]
Ryan Skraba commented on FLINK-35095:
-
1.20 Java 17: Test (module: misc)
https://gi
caicancai commented on PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#issuecomment-2056897700
@RocMarshal PATL，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
URL above to go
MartijnVisser commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2056886905
> @MartijnVisser can that one case be retriggered? Or of not, I hope another
run would be green.
Re-triggered all failing jobs!
--
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837268#comment-17837268
]
David Perkins commented on FLINK-35097:
---
Great! Thanks for the fast response.
> T
[
https://issues.apache.org/jira/browse/FLINK-35073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837259#comment-17837259
]
Julien Tournay edited comment on FLINK-35073 at 4/15/24 1:32 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-35073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Tournay closed FLINK-35073.
--
Resolution: Workaround
> Deadlock in LocalBufferPool when segments become available in the glo
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837260#comment-17837260
]
Martijn Visser commented on FLINK-35111:
Do note that grammar/spelling doesn't n
ferenc-csaky commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2056866715
After I took a look at the logs, the error was environmental, it failed to
connect to the Dockerized Kudu:
```
ERROR org.apache.kudu.client.Connection [] - [peer
master
[
https://issues.apache.org/jira/browse/FLINK-35073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837259#comment-17837259
]
Julien Tournay commented on FLINK-35073:
Closing this issue because even though
dannycranmer merged PR #661:
URL: https://github.com/apache/flink-web/pull/661
--
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-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837257#comment-17837257
]
Martijn Visser commented on FLINK-35112:
[~dianfu] [~hxbks2ks] WDYT?
> Membersh
dannycranmer merged PR #688:
URL: https://github.com/apache/flink-web/pull/688
--
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-35114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-35114:
-
Component/s: Connectors / Kudu
> Remove old Table API implementations
>
[
https://issues.apache.org/jira/browse/FLINK-34928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-34928:
-
Component/s: Connectors / Kudu
> FLIP-439: Externalize Kudu Connector from Bahir
> -
Ferenc Csaky created FLINK-35114:
Summary: Remove old Table API implementations
Key: FLINK-35114
URL: https://issues.apache.org/jira/browse/FLINK-35114
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-34931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-34931:
-
Summary: Update Kudu connector DataStream Sink implementation (was: Update
Kudu connector DataS
[
https://issues.apache.org/jira/browse/FLINK-35113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837249#comment-17837249
]
Danny Cranmer commented on FLINK-35113:
---
Merged commit
[{{6717cba}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-35113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35113.
---
Resolution: Fixed
> Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink
dannycranmer merged PR #137:
URL: https://github.com/apache/flink-connector-aws/pull/137
--
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
dannycranmer commented on PR #689:
URL: https://github.com/apache/flink-web/pull/689#issuecomment-2056822474
https://github.com/apache/flink-web/commit/eb6412b02e85c9dc7291e5759bb2fb02a259e774
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
dannycranmer merged PR #689:
URL: https://github.com/apache/flink-web/pull/689
--
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 #689:
URL: https://github.com/apache/flink-web/pull/689#issuecomment-2056812919
Since there is no reply here, I will merge this and fix the CN myself
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
1 - 100 of 253 matches
Mail list logo
