[
https://issues.apache.org/jira/browse/FLINK-29594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630831#comment-17630831
]
Matthias Pohl commented on FLINK-29594:
---
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017559683
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumState.java:
##
@@ -0,0 +1,95 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630829#comment-17630829
]
Weihua Hu commented on FLINK-8712:
--
[~xtsong], JobGraph::getMaximumParallelism is only used for
yuzelin commented on code in PR #21229:
URL: https://github.com/apache/flink/pull/21229#discussion_r1017558571
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointITCase.java:
##
@@ -595,6 +598,27 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-29954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-29954:
-
Assignee: Danny Cranmer
> Improve DynamoDB Connector Sample Code
>
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630827#comment-17630827
]
Matthias Pohl edited comment on FLINK-24119 at 11/9/22 7:56 AM:
Thanks
Danny Cranmer created FLINK-29954:
-
Summary: Improve DynamoDB Connector Sample Code
Key: FLINK-29954
URL: https://issues.apache.org/jira/browse/FLINK-29954
Project: Flink
Issue Type:
Jingsong Lee created FLINK-29953:
Summary: Get rid of flink-connector-hive dependency in
flink-table-store-hive
Key: FLINK-29953
URL: https://issues.apache.org/jira/browse/FLINK-29953
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630827#comment-17630827
]
Matthias Pohl edited comment on FLINK-24119 at 11/9/22 7:55 AM:
Thanks
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630827#comment-17630827
]
Matthias Pohl commented on FLINK-24119:
---
Thanks [~gaborgsomogyi], I'm gonna have a look.
In the
JingsongLi commented on PR #367:
URL:
https://github.com/apache/flink-table-store/pull/367#issuecomment-1308348802
Hi @LadyForest
I doubt whether to support this command: `mvn clean install
-Dmaven.test.skip=true -P hive-3.1,flink-1.15`.
JingsongLi opened a new pull request, #368:
URL: https://github.com/apache/flink-table-store/pull/368
We can use hive 2.3.9 for all flink versions.
--
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
houhang1005 commented on PR #21268:
URL: https://github.com/apache/flink/pull/21268#issuecomment-1308347909
@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
yunfengzhou-hub commented on code in PR #172:
URL: https://github.com/apache/flink-ml/pull/172#discussion_r1017456006
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasRelativeError.java:
##
@@ -36,7 +36,7 @@ default double getRelativeError() {
return
MartijnVisser commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1308346997
@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-29952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630823#comment-17630823
]
yuzelin commented on FLINK-29952:
-
Currently, dropping a temporary table should add the keyword
[
https://issues.apache.org/jira/browse/FLINK-29951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630819#comment-17630819
]
Martijn Visser commented on FLINK-29951:
[~xuannan] Thanks for the ticket, but it's a duplicate.
[
https://issues.apache.org/jira/browse/FLINK-29951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29951.
--
Resolution: Duplicate
> Kafka SQL connector supports setting end offset/timestamp
>
flinkbot commented on PR #21268:
URL: https://github.com/apache/flink/pull/21268#issuecomment-1308343601
## CI report:
* 90722de6f300366a5f3b91527feed423863ebebe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630813#comment-17630813
]
Weihao Chen commented on FLINK-23545:
-
[https://github.com/apache/flink/pull/16721]
This PR
[
https://issues.apache.org/jira/browse/FLINK-29952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29952:
---
Labels: pull-request-available (was: )
> Using DROP TABLE XXX to drop a temporary table
houhang1005 opened a new pull request, #21268:
URL: https://github.com/apache/flink/pull/21268
Append the detail of the exception when drop tamporary table.
Signed-off-by: houhang
## What is the purpose of the change
Make the exception more clear when failed to
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630805#comment-17630805
]
Xintong Song commented on FLINK-8712:
-
[~huwh], could you please explain a bit more about how do you
Hang HOU created FLINK-29952:
Summary: Using DROP TABLE XXX to drop a temporary table （or view）
in sql-client can get an exception with incomplete explaination.
Key: FLINK-29952
URL:
LadyForest opened a new pull request, #367:
URL: https://github.com/apache/flink-table-store/pull/367
Reverts apache/flink-table-store#355
`mvn clean install -Dmaven.test.skip=true -P hive-3.1,flink-1.15` failed
after introducing this change.
I think we'd better add more CI build
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017041964
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java:
##
@@ -0,0 +1,681 @@
+/*
+ *
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017512361
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java:
##
@@ -0,0 +1,681 @@
+/*
+ *
tsreaper commented on code in PR #361:
URL: https://github.com/apache/flink-table-store/pull/361#discussion_r1017509266
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FullChangelogStoreWriteOperator.java:
##
@@ -0,0 +1,224 @@
+/*
+ *
LadyForest commented on PR #355:
URL:
https://github.com/apache/flink-table-store/pull/355#issuecomment-1308310681
I found that It's failed to build hive-3.1 with flink-1.15 after introduce
this change.
--
This is an automated message from the Apache Git Service.
To respond to the
tsreaper opened a new pull request, #366:
URL: https://github.com/apache/flink-table-store/pull/366
(Cherry-picked from #354)
Consider the following scenario when snapshot committing is slow:
* A writer produces some records at checkpoint T.
* It produces no record at checkpoint
[
https://issues.apache.org/jira/browse/FLINK-29860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630792#comment-17630792
]
Noel O'Connor commented on FLINK-29860:
---
[~syhily] yep I'll do that today
> Pulsar connector bug
yuzelin commented on code in PR #21229:
URL: https://github.com/apache/flink/pull/21229#discussion_r1017497037
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointITCase.java:
##
@@ -595,6 +598,27 @@ public void
yuzelin commented on PR #21187:
URL: https://github.com/apache/flink/pull/21187#issuecomment-1308294522
cc @fsk119
--
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
yuzelin commented on PR #21133:
URL: https://github.com/apache/flink/pull/21133#issuecomment-1308294143
cc @fsk119
--
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
yuzelin commented on PR #21141:
URL: https://github.com/apache/flink/pull/21141#issuecomment-1308290084
cc @fsk119
--
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
[
https://issues.apache.org/jira/browse/FLINK-15358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630787#comment-17630787
]
Weihua Hu commented on FLINK-15358:
---
[~chesnay] [~mxm]
As[
fsk119 commented on code in PR #21229:
URL: https://github.com/apache/flink/pull/21229#discussion_r1017475905
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointITCase.java:
##
@@ -595,6 +598,27 @@ public void
Xuannan Su created FLINK-29951:
--
Summary: Kafka SQL connector supports setting end offset/timestamp
Key: FLINK-29951
URL: https://issues.apache.org/jira/browse/FLINK-29951
Project: Flink
Issue
luoyuxia commented on PR #21257:
URL: https://github.com/apache/flink/pull/21257#issuecomment-1308280707
@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.
yuzelin created FLINK-29950:
---
Summary: Add 'contentType' and 'FieldFormat' to 'ResultSet' for
improvement
Key: FLINK-29950
URL: https://issues.apache.org/jira/browse/FLINK-29950
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630777#comment-17630777
]
luoyuxia commented on FLINK-29944:
--
Thanks for contributing. From the pr, seems it changes the public
[
https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-29913:
---
Description:
When maxConcurrentCheckpoint>1, the shared state of Incremental rocksdb state
backend
yuzelin created FLINK-29949:
---
Summary: Implement 'RemoteExecutor' to perform the communication
with Gateway
Key: FLINK-29949
URL: https://issues.apache.org/jira/browse/FLINK-29949
Project: Flink
yuzelin created FLINK-29948:
---
Summary: Introduce ErrorResponse in Gateway RestEndpoint.
Key: FLINK-29948
URL: https://issues.apache.org/jira/browse/FLINK-29948
Project: Flink
Issue Type: Sub-task
tsreaper merged PR #365:
URL: https://github.com/apache/flink-table-store/pull/365
--
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:
SteNicholas commented on code in PR #357:
URL: https://github.com/apache/flink-table-store/pull/357#discussion_r1016658666
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/CatalogOptions.java:
##
@@ -49,6 +49,12 @@ private CatalogOptions() {}
imaffe commented on PR #21249:
URL: https://github.com/apache/flink/pull/21249#issuecomment-1308242332
LGTM~ Great job~
--
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
tisonkun commented on code in PR #21249:
URL: https://github.com/apache/flink/pull/21249#discussion_r1017435136
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/TopicProducerRegister.java:
##
@@ -150,7 +181,13 @@
tisonkun commented on code in PR #21249:
URL: https://github.com/apache/flink/pull/21249#discussion_r1017434788
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/TopicProducerRegister.java:
##
@@ -150,7 +181,13 @@
tisonkun commented on PR #21249:
URL: https://github.com/apache/flink/pull/21249#issuecomment-1308220753
@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.
syhily commented on code in PR #21249:
URL: https://github.com/apache/flink/pull/21249#discussion_r1017429944
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics/ProducerMetricsInterceptor.java:
##
@@ -0,0 +1,67 @@
+/*
+ *
syhily commented on code in PR #21249:
URL: https://github.com/apache/flink/pull/21249#discussion_r1017429516
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/TopicProducerRegister.java:
##
@@ -150,7 +181,13 @@ private
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630750#comment-17630750
]
Weihua Hu commented on FLINK-8712:
--
Hi, [~trohrmann] [~xtsong] Could you help take a look at this issue
yuzelin created FLINK-29947:
---
Summary: Support configuring session API in Gateway RestEndpoint
Key: FLINK-29947
URL: https://issues.apache.org/jira/browse/FLINK-29947
Project: Flink
Issue Type:
yuzelin created FLINK-29946:
---
Summary: Introduce ‘ErrorDetail’ in SQL Gateway Rest Endpoint for
error handling
Key: FLINK-29946
URL: https://issues.apache.org/jira/browse/FLINK-29946
Project: Flink
yuzelin created FLINK-29945:
---
Summary: Refactor ‘Executor’ interface to work with Gateway API
Key: FLINK-29945
URL: https://issues.apache.org/jira/browse/FLINK-29945
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630740#comment-17630740
]
Weijie Guo commented on FLINK-8712:
---
[~huwh] Thank you for your willingness to help, but I do not have
[
https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630738#comment-17630738
]
Weijie Guo commented on FLINK-29639:
Hi [~Jiangang], how is the progress of this work? If you don't
[
https://issues.apache.org/jira/browse/FLINK-29751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29751:
Component/s: (was: Table SQL / Gateway)
Affects Version/s: 1.17.0
Description:
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-29486:
Parent Issue: FLINK-29941 (was: FLINK-29073)
> Introduce Client Parser to get statement type
>
[
https://issues.apache.org/jira/browse/FLINK-29941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-29941:
Description:
This is an umbrella issue to track the effort to support SQL Client connects to
SQL
[
https://issues.apache.org/jira/browse/FLINK-29751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-29751:
Parent Issue: FLINK-29941 (was: FLINK-29073)
> Migrate SQL Client Embedded Mode to use sql gateway
>
[
https://issues.apache.org/jira/browse/FLINK-29944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hk__lrzy updated FLINK-29944:
-
Component/s: API / DataStream
(was: API / Core)
Docs
[
https://issues.apache.org/jira/browse/FLINK-29944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hk__lrzy updated FLINK-29944:
-
External issue URL: https://github.com/apache/flink/pull/21258
> Support accumulator in source reader
>
[
https://issues.apache.org/jira/browse/FLINK-29944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630726#comment-17630726
]
hk__lrzy commented on FLINK-29944:
--
https://github.com/apache/flink/pull/21258
> Support accumulator
[
https://issues.apache.org/jira/browse/FLINK-29944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hk__lrzy updated FLINK-29944:
-
Summary: Support accumulator in source reader (was: Support accumaltor in
source reader)
> Support
hk__lrzy created FLINK-29944:
Summary: Support accumaltor in source reader
Key: FLINK-29944
URL: https://issues.apache.org/jira/browse/FLINK-29944
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29943:
---
Labels: pull-request-available (was: )
> Bump Table Store 0.2 Flink version to 1.15.2
>
tsreaper opened a new pull request, #365:
URL: https://github.com/apache/flink-table-store/pull/365
As the title suggests.
--
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.
Caizhi Weng created FLINK-29943:
---
Summary: Bump Table Store 0.2 Flink version to 1.15.2
Key: FLINK-29943
URL: https://issues.apache.org/jira/browse/FLINK-29943
Project: Flink
Issue Type:
Jark Wu created FLINK-29942:
---
Summary: Improve average performance for TPC-DS
Key: FLINK-29942
URL: https://issues.apache.org/jira/browse/FLINK-29942
Project: Flink
Issue Type: New Feature
muggleChen commented on PR #21263:
URL: https://github.com/apache/flink/pull/21263#issuecomment-1308145566
@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
muggleChen commented on PR #21263:
URL: https://github.com/apache/flink/pull/21263#issuecomment-1308145375
hi , @MartijnVisser Could you please help merge this fix ,thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Jark Wu created FLINK-29941:
---
Summary: Support SQL Client connects to SQL Gateway
Key: FLINK-29941
URL: https://issues.apache.org/jira/browse/FLINK-29941
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-29751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29751:
Summary: Migrate SQL Client Embedded Mode to use sql gateway (was: Migrate
SQL Client Local Mode to use
[
https://issues.apache.org/jira/browse/FLINK-27846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630703#comment-17630703
]
Jingsong Lee commented on FLINK-27846:
--
[~zjureel] (y) Assigned to u.
> Schema evolution for data
[
https://issues.apache.org/jira/browse/FLINK-27846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-27846:
Assignee: Shammon
> Schema evolution for data file reading
>
tisonkun commented on code in PR #21249:
URL: https://github.com/apache/flink/pull/21249#discussion_r1017344322
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics/ProducerMetricsInterceptor.java:
##
@@ -0,0 +1,67 @@
+/*
+ *
tisonkun commented on code in PR #21249:
URL: https://github.com/apache/flink/pull/21249#discussion_r1017342375
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderBase.java:
##
@@ -222,6
[
https://issues.apache.org/jira/browse/FLINK-29920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-29920.
---
Fix Version/s: 1.17.0
Assignee: Mingliang Liu
Resolution: Fixed
Fixed in master:
wuchong merged PR #21253:
URL: https://github.com/apache/flink/pull/21253
--
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:
tisonkun commented on code in PR #21249:
URL: https://github.com/apache/flink/pull/21249#discussion_r1017322603
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java:
##
@@ -96,12 +98,18 @@
[
https://issues.apache.org/jira/browse/FLINK-27846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630689#comment-17630689
]
Shammon commented on FLINK-27846:
-
Thanks [~lzljs3620320] , then we can transform different data columns
flinkbot commented on PR #21267:
URL: https://github.com/apache/flink/pull/21267#issuecomment-1308066922
## CI report:
* 5168afb3142198a1d0e822722723b9ce6fa39ac5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yangjf2019 commented on PR #432:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/432#issuecomment-1308065409
> You have to commit all the generated files. That’s very important
otherwise CI will fail
Okay, I'll submit it.
--
This is an automated message from the
dependabot[bot] opened a new pull request, #21267:
URL: https://github.com/apache/flink/pull/21267
Bumps [loader-utils](https://github.com/webpack/loader-utils) from 2.0.2 to
2.0.3.
Release notes
Sourced from https://github.com/webpack/loader-utils/releases;>loader-utils's
flinkbot commented on PR #21266:
URL: https://github.com/apache/flink/pull/21266#issuecomment-1308050555
## CI report:
* 1cc88e559c8e15903cc227d90eb2b530298ac884 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29940:
---
Labels: pull-request-available (was: )
> ExecutionGraph logs job state change at ERROR
liuml07 opened a new pull request, #21266:
URL: https://github.com/apache/flink/pull/21266
## What is the purpose of the change
When job switched to FAILED state, the log is very useful to understand why
it failed along with the root cause exception stack. However, the current log
Mingliang Liu created FLINK-29940:
-
Summary: ExecutionGraph logs job state change at ERROR level when
job fails
Key: FLINK-29940
URL: https://issues.apache.org/jira/browse/FLINK-29940
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhou Jiang updated FLINK-29939:
---
Description:
Operator now publishes k8s client response count by response code. In addition
to the
Zhou Jiang created FLINK-29939:
--
Summary: Add metrics for Kubernetes Client Response 5xx count and
rate
Key: FLINK-29939
URL: https://issues.apache.org/jira/browse/FLINK-29939
Project: Flink
flinkbot commented on PR #21265:
URL: https://github.com/apache/flink/pull/21265#issuecomment-1307969436
## CI report:
* c991be58d637f6083389df29d12d4a28c74eface UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29938:
---
Labels: pull-request-available (was: )
> Add open() Method to AsyncSink ElementConverter
>
dannycranmer opened a new pull request, #21265:
URL: https://github.com/apache/flink/pull/21265
## What is the purpose of the change
Add an `open()` method to the `ElementConverter` used with `AsyncSink`. This
gives element converters a hook to use for construction on TM without
[
https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-29938:
-
Assignee: Danny Cranmer
> Add open() Method to AsyncSink ElementConverter
>
[
https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29938:
--
Description:
The {{ElementConverter}} is used to convert records to objects that a Sink can
[
https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29938:
--
Description:
The {{ElementConverter}} is used to convert records to objects that a Sink can
dannycranmer commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-aws/pull/16#discussion_r1017185669
##
flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDBEnhancedElementConverter.java:
##
@@ -0,0 +1,71 @@
+/*
+ *
Danny Cranmer created FLINK-29938:
-
Summary: Add open() Method to AsyncSink ElementConverter
Key: FLINK-29938
URL: https://issues.apache.org/jira/browse/FLINK-29938
Project: Flink
Issue
1 - 100 of 311 matches
Mail list logo
