jackylau created FLINK-29749:
Summary: flink info command support dynamic properties
Key: FLINK-29749
URL: https://issues.apache.org/jira/browse/FLINK-29749
Project: Flink
Issue Type: Bug
flinkbot commented on PR #21144:
URL: https://github.com/apache/flink/pull/21144#issuecomment-1290004035
## CI report:
* aa898fd31f50a69d8bad471df434fb02ab0f28fa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623561#comment-17623561
]
Durgesh Mishra commented on FLINK-29711:
[~martijnvisser] and [~mason6345] Can you guys help
[
https://issues.apache.org/jira/browse/FLINK-29747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29747:
---
Labels: pull-request-available (was: )
> [UI] Refactor runtime web from module-based to
yangjunhan opened a new pull request, #21144:
URL: https://github.com/apache/flink/pull/21144
## What is the purpose of the change
FLINK-29747
## Brief change log
Refactor module-based app to standalone components with lazy loading.
## Verifying this
JingsongLi commented on code in PR #328:
URL: https://github.com/apache/flink-table-store/pull/328#discussion_r1004006577
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeWriter.java:
##
@@ -137,6 +137,11 @@ public void write(KeyValue
xintongsong commented on PR #20910:
URL: https://github.com/apache/flink/pull/20910#issuecomment-1289993309
@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
xintongsong commented on code in PR #21132:
URL: https://github.com/apache/flink/pull/21132#discussion_r1004004779
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherImpl.java:
##
@@ -148,102 +156,106 @@ private void fetchMetrics()
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29609:
--
Assignee: Sriram Ganesh
> Clean up jobmanager deployment on suspend after recording
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623554#comment-17623554
]
Sriram Ganesh commented on FLINK-29609:
---
[~gyfora] - Please assign this to me.
> Clean up
TanYuxin-tyx commented on PR #21132:
URL: https://github.com/apache/flink/pull/21132#issuecomment-1289958870
@xintongsong @reswqa Thanks for reviewing the change. I have addressed the
comments. Could you take a look again?
--
This is an automated message from the Apache Git Service.
To
flinkbot commented on PR #21143:
URL: https://github.com/apache/flink/pull/21143#issuecomment-1289954801
## CI report:
* a1c7b649082670669fdb9af042171c744e48e8b8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
TanYuxin-tyx commented on code in PR #21132:
URL: https://github.com/apache/flink/pull/21132#discussion_r1003979797
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherTest.java:
##
@@ -263,7 +220,151 @@ public void
reswqa commented on PR #21143:
URL: https://github.com/apache/flink/pull/21143#issuecomment-1289950821
cc @luoyuxia
--
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
reswqa opened a new pull request, #21143:
URL: https://github.com/apache/flink/pull/21143
## What is the purpose of the change
*Fix some typo in HiveOptions.*
## Brief change log
- *Using `withDescription` instead of `withDeprecatedKeys` for some config
options.*
flinkbot commented on PR #21142:
URL: https://github.com/apache/flink/pull/21142#issuecomment-1289946308
## CI report:
* 000fb8030dc23459a3669eb62b54a58691641d06 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623546#comment-17623546
]
chenzihao commented on FLINK-29737:
---
[~fsk119] Thanks for your reply. I have opened the PR, please
[
https://issues.apache.org/jira/browse/FLINK-29737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29737:
---
Labels: pull-request-available (was: )
> Support DataGen on waveform function
>
chenzihao5 opened a new pull request, #21142:
URL: https://github.com/apache/flink/pull/21142
## What is the purpose of the change
Support DataGen on waveform function.
## Brief change log
- add three parameters:
- waveform-function-enabled: Apply the
[
https://issues.apache.org/jira/browse/FLINK-29745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29745:
-
Fix Version/s: table-store-0.3.0
(was: shammon)
> Split reader/writer
[
https://issues.apache.org/jira/browse/FLINK-29745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29745:
Assignee: Shammon
> Split reader/writer factory for compaction in MergeTreeTest
>
[
https://issues.apache.org/jira/browse/FLINK-29745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29745.
Fix Version/s: shammon
Resolution: Fixed
master: 537e8cf4b3733d93720381c65b30024870ece533
JingsongLi merged PR #331:
URL: https://github.com/apache/flink-table-store/pull/331
--
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:
cuibo01 commented on PR #20910:
URL: https://github.com/apache/flink/pull/20910#issuecomment-1289929840
@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.
Aitozi created FLINK-29748:
--
Summary: Expose the optimize phase in the connector context
Key: FLINK-29748
URL: https://issues.apache.org/jira/browse/FLINK-29748
Project: Flink
Issue Type:
yunfengzhou-hub commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r1003935113
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/randomsplitter/RandomSplitterParams.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software
reswqa commented on code in PR #21132:
URL: https://github.com/apache/flink/pull/21132#discussion_r1003944639
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherTest.java:
##
@@ -43,120 +43,77 @@
import org.junit.Test;
Review
flinkbot commented on PR #21141:
URL: https://github.com/apache/flink/pull/21141#issuecomment-1289913250
## CI report:
* 45299902af8abdcc2da247f590416cf657cb9988 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuzelin commented on PR #21133:
URL: https://github.com/apache/flink/pull/21133#issuecomment-1289910411
@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.
[
https://issues.apache.org/jira/browse/FLINK-29742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29742:
---
Labels: pull-request-available (was: )
> Support completing statement in
yuzelin opened a new pull request, #21141:
URL: https://github.com/apache/flink/pull/21141
## 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
luoyuxia commented on PR #20830:
URL: https://github.com/apache/flink/pull/20830#issuecomment-1289904570
@jiangjiguang Also, could you please help rebase the master?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Junhan Yang created FLINK-29747:
---
Summary: [UI] Refactor runtime web from module-based to standalone
components
Key: FLINK-29747
URL: https://issues.apache.org/jira/browse/FLINK-29747
Project: Flink
luoyuxia commented on code in PR #20830:
URL: https://github.com/apache/flink/pull/20830#discussion_r1003945031
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/RunLengthDecoder.java:
##
@@ -265,8 +265,16 @@ void readNextGroup() {
luoyuxia commented on code in PR #20830:
URL: https://github.com/apache/flink/pull/20830#discussion_r1003942184
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/RunLengthDecoder.java:
##
@@ -265,8 +265,16 @@ void readNextGroup() {
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1289898634
@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.
[
https://issues.apache.org/jira/browse/FLINK-29745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29745:
---
Labels: pull-request-available (was: )
> Split reader/writer factory for compaction in
zjureel opened a new pull request, #331:
URL: https://github.com/apache/flink-table-store/pull/331
Use independent reader/writer factory for compaction in `MergeTreeTest`,
otherwise, there may be concurrency problems in the test case
--
This is an automated message from the Apache Git
czy006 commented on code in PR #21012:
URL: https://github.com/apache/flink/pull/21012#discussion_r1003931113
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java:
##
@@ -211,6 +218,37 @@ void testProvideJobId() throws
[
https://issues.apache.org/jira/browse/FLINK-20732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-20732.
-
Resolution: Fixed
> Implement Pulsar Sink on extend Sink API (FLIP-191)
>
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-26027:
--
Parent: (was: FLINK-20732)
Issue Type: Improvement (was: Sub-task)
> Add FLIP-33 metrics
zjureel commented on PR #326:
URL:
https://github.com/apache/flink-table-store/pull/326#issuecomment-1289880133
Hi @JingsongLi I have split the reader/writer factory for compaction in the
micro benchmarks and fix the concurrency problem, please review again, thanks
--
This is an
zhipeng93 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r1003924160
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
libenchao commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1003920728
##
flink-connectors/flink-connector-jdbc/src/test/resources/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.xml:
##
@@ -51,4 +51,22 @@
zhipeng93 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r1003921280
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
zhipeng93 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r1003921280
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/FLINK-29737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623501#comment-17623501
]
Shengkai Fang commented on FLINK-29737:
---
Thanks for your idea. Could you share the PR link here?
[
https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29217:
-
Fix Version/s: 1.16.1
(was: 1.16.0)
>
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r1003917397
##
_posts/2022-10-15-1.16-announcement.md:
##
@@ -0,0 +1,402 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date:
[
https://issues.apache.org/jira/browse/FLINK-28914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-28914.
-
Resolution: Fixed
> Could not find any factories that implement
>
[
https://issues.apache.org/jira/browse/FLINK-27773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623496#comment-17623496
]
Shengkai Fang commented on FLINK-27773:
---
[~martijnvisser] It has been implemented in the 1.16.
>
[
https://issues.apache.org/jira/browse/FLINK-27773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-27773:
--
Fix Version/s: 1.16.0
> Introduce the E2E tests for SQL Gateway
>
[
https://issues.apache.org/jira/browse/FLINK-29732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29732:
-
Assignee: yuzelin
> Support configuring session with SQL statement
>
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r1003914702
##
_posts/2022-10-15-1.16-announcement.md:
##
@@ -0,0 +1,402 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date:
morhidi closed pull request #372: [FLINK-29261] Use
FAIL_ON_UNKNOWN_PROPERTIES=false in ReconciliationUtils
URL: https://github.com/apache/flink-kubernetes-operator/pull/372
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
morhidi commented on PR #410:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/410#issuecomment-1289856878
+1 LGTM
--
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
Shammon created FLINK-29746:
---
Summary: Add workflow in github for micro benchmarks
Key: FLINK-29746
URL: https://issues.apache.org/jira/browse/FLINK-29746
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623481#comment-17623481
]
Benchao Li commented on FLINK-29692:
{quote}'Early fire' would periodically sent intermediate result
Shammon created FLINK-29745:
---
Summary: Split reader/writer factory for compaction in
MergeTreeTest
Key: FLINK-29745
URL: https://issues.apache.org/jira/browse/FLINK-29745
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29744:
---
Labels: pull-request-available (was: )
> Throw DeploymentFailedException on
morhidi opened a new pull request, #411:
URL: https://github.com/apache/flink-kubernetes-operator/pull/411
## What is the purpose of the change
Handle cases when pod is unable to pull images. (a.k.a `ImagePullBackOff`)
## Brief change log
Code is already handling
RocMarshal commented on PR #20990:
URL: https://github.com/apache/flink/pull/20990#issuecomment-1289823623
@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
[
https://issues.apache.org/jira/browse/FLINK-29744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-29744:
--
Affects Version/s: kubernetes-operator-1.3.0
> Throw DeploymentFailedException on
[
https://issues.apache.org/jira/browse/FLINK-29744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-29744:
--
Component/s: Kubernetes Operator
> Throw DeploymentFailedException on ImagePullBackOff
>
Matyas Orhidi created FLINK-29744:
-
Summary: Throw DeploymentFailedException on ImagePullBackOff
Key: FLINK-29744
URL: https://issues.apache.org/jira/browse/FLINK-29744
Project: Flink
Issue
morhidi commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1289657005
> @morhidi
>
> Thanks for the feedback and sharing your test result:
>
> > It resulted in an string, that might not be a valid JSON:
>
> I will do
morhidi commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1289654405
> @morhidi
>
> Thanks for the feedback and sharing your test result:
>
> > It resulted in an string, that might not be a valid JSON:
>
> I will do
darenwkt commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1289640460
@morhidi
Thanks for the feedback and sharing your test result:
>It resulted in an string, that might not be a valid JSON:
I will do some testing on
darenwkt commented on code in PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#discussion_r1003776097
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java:
##
@@ -0,0 +1,118 @@
+/*
+ *
darenwkt commented on code in PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#discussion_r1003775892
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java:
##
@@ -0,0 +1,118 @@
+/*
+ *
darenwkt commented on code in PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#discussion_r1003775450
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java:
##
@@ -0,0 +1,118 @@
+/*
+ *
darenwkt commented on code in PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#discussion_r1003775090
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java:
##
@@ -0,0 +1,118 @@
+/*
+ *
darenwkt commented on code in PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#discussion_r1003773876
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/AbstractFlinkSpec.java:
##
@@ -57,6 +57,9 @@ public abstract
morhidi commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1289601914
Another thing that I found is the structure of the stacktrace probably too
verbose:
```{
"type":
[
https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623369#comment-17623369
]
Sergio Sainz edited comment on FLINK-29235 at 10/24/22 7:45 PM:
Hello
[
https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623369#comment-17623369
]
Sergio Sainz edited comment on FLINK-29235 at 10/24/22 7:45 PM:
Hello
[
https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623369#comment-17623369
]
Sergio Sainz commented on FLINK-29235:
--
Hello [~chesnay]
Noticed the flink-shaded-jackson
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1289455651
Hi @libenchao , thank you very much for your review
I've addressed all of your concern. On the TablePlanTest, do you mind to
check if that's how it supposed to work? I don't
[
https://issues.apache.org/jira/browse/FLINK-29529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29529.
--
Resolution: Fixed
merged to main a978375daeefbf23b548aab940a7ad3c366aa661
> Update flink version in
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003629002
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java:
##
@@ -0,0 +1,104 @@
+/*
+ *
gyfora merged PR #408:
URL: https://github.com/apache/flink-kubernetes-operator/pull/408
--
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:
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003626614
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,144 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-29731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623316#comment-17623316
]
gang ye commented on FLINK-29731:
-
Is this for adding ConfluentSchemaRegistryCoder for Protobuf (like
morhidi commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1289362006
I tested it and it almost works great, apart from the minor things, Gyula
mentioned. There'll be probably issues with JSON encoding: I've tested it with
the following
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003539179
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,216 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003539179
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,216 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003536293
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,179 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003528260
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,144 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003526661
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,179 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003526661
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,179 @@
+/*
+ *
Samrat002 commented on PR #21135:
URL: https://github.com/apache/flink/pull/21135#issuecomment-1289169354
test failed due to
[FLINK-24119](https://issues.apache.org/jira/browse/FLINK-24119)
Please review !
@HuangXingBo
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623232#comment-17623232
]
Samrat Deb commented on FLINK-24119:
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623212#comment-17623212
]
xiaogang zhou commented on FLINK-29545:
---
[~pnowojski] Hi Master, I could clearly find the netty
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r1003354068
##
_config.yml:
##
@@ -244,6 +260,10 @@ component_releases:
release_archive:
flink:
+ -
+version_short: "1.16"
+version_long: 1.16.0
+
RyanSkraba commented on code in PR #20267:
URL: https://github.com/apache/flink/pull/20267#discussion_r1003342134
##
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemBehaviorTest.java:
##
@@ -23,26 +23,25 @@
import org.apache.flink.core.fs.FileSystemKind;
RyanSkraba commented on code in PR #20267:
URL: https://github.com/apache/flink/pull/20267#discussion_r1003341622
##
flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HdfsBehaviorTest.java:
##
@@ -47,19 +43,17 @@ public class HdfsBehaviorTest
ferenc-csaky commented on PR #21127:
URL: https://github.com/apache/flink/pull/21127#issuecomment-1289067927
@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
[
https://issues.apache.org/jira/browse/FLINK-25802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623197#comment-17623197
]
Runkang He commented on FLINK-25802:
Hi, [~TsReaper] is there some update on this issue?
>
RyanSkraba commented on code in PR #20267:
URL: https://github.com/apache/flink/pull/20267#discussion_r1003339435
##
flink-filesystems/flink-azure-fs-hadoop/src/test/java/org/apache/flink/fs/azurefs/AzureFileSystemBehaviorITCase.java:
##
@@ -70,12 +60,30 @@ public class
RyanSkraba commented on code in PR #20267:
URL: https://github.com/apache/flink/pull/20267#discussion_r1003338793
##
flink-filesystems/flink-azure-fs-hadoop/src/test/java/org/apache/flink/fs/azurefs/AzureFileSystemBehaviorITCase.java:
##
@@ -85,9 +93,9 @@ private static boolean
1 - 100 of 234 matches
Mail list logo
