yanghua commented on a change in pull request #8871: [FLINK-12976] Bump Kafka
client version to 2.3.0 for universal Kafka connector
URL: https://github.com/apache/flink/pull/8871#discussion_r298900461
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/fli
[
https://issues.apache.org/jira/browse/FLINK-12953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875970#comment-16875970
]
vinoyang commented on FLINK-12953:
--
[~chadrik] Thanks for clarifying my questions. They
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298897378
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/upsert/QueryE
wuchong commented on issue #7550: [FLINK-10245] [Streaming Connector] Add Pojo,
Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase
URL: https://github.com/apache/flink/pull/7550#issuecomment-507135403
@Clark do you have time to update the pull request?
--
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298892482
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/upsert/Que
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298891291
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsert
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298891195
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsert
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298890782
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsert
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298889986
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsert
JingsongLi commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table
sink for JDBC
URL: https://github.com/apache/flink/pull/8867#issuecomment-507119365
>Why we should expose JdbcDialect to users? IMO, this is an internal
interface to handle different databases (well-know databa
asfgit closed pull request #8919: [FLINK-13022][table][hive] unify catalog
function implementations
URL: https://github.com/apache/flink/pull/8919
This is an automated message from the Apache Git Service.
To respond to the m
bowenli86 commented on issue #8919: [FLINK-13022][table][hive] unify catalog
function implementations
URL: https://github.com/apache/flink/pull/8919#issuecomment-507116655
The Travis failure is unrelated.
Merging
This
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298877631
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/AbstractJD
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298877518
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/AbstractJD
JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298877538
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/AbstractJD
wuchong edited a comment on issue #8867: [FLINK-12956][jdbc] Introduce upsert
table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#issuecomment-507110081
> 1.The only difference between databases is just quoteIdentifier and the
upsert mechanism now.
Maybe we will encou
wuchong commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table
sink for JDBC
URL: https://github.com/apache/flink/pull/8867#issuecomment-507110081
> 1.The only difference between databases is just quoteIdentifier and the
upsert mechanism now.
Maybe we will encounter the sa
[
https://issues.apache.org/jira/browse/FLINK-12897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-12897.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in master: 534d53bf828404ef3dcd7aad9e7a8b6528606
asfgit closed pull request #8916: [FLINK-12897][python][docs] Improve the
Python Table API docs by adding more examples
URL: https://github.com/apache/flink/pull/8916
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-12953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875930#comment-16875930
]
Chad Dombrova commented on FLINK-12953:
---
{quote}Does the web UI you showed is not
JingsongLi commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table
sink for JDBC
URL: https://github.com/apache/flink/pull/8867#issuecomment-507106994
Thanks @wuchong 's great code and review, The reason why I don't introduce
JdbcDialect first is:
1.The only difference betw
[
https://issues.apache.org/jira/browse/FLINK-12953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875916#comment-16875916
]
vinoyang commented on FLINK-12953:
--
Hi [~chadrik], thanks for providing a clear gif exa
zhuzhurk commented on a change in pull request #8922: [FLINK-12876][runtime]
Add an adapter of region failover NG for legacy scheduler
URL: https://github.com/apache/flink/pull/8922#discussion_r298865535
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongr
[
https://issues.apache.org/jira/browse/FLINK-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875909#comment-16875909
]
vinoyang commented on FLINK-13032:
--
Do you meet some scenarios which need to this featu
[
https://issues.apache.org/jira/browse/FLINK-13034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875905#comment-16875905
]
Jark Wu commented on FLINK-13034:
-
+1 to {{isEmtpy()}}.
> Improve the performance when
flinkbot edited a comment on issue #8916: [FLINK-12897][python][docs] Improve
the Python Table API docs by adding more examples
URL: https://github.com/apache/flink/pull/8916#issuecomment-506327371
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help th
sunjincheng121 commented on a change in pull request #8916:
[FLINK-12897][python][docs] Improve the Python Table API docs by adding more
examples
URL: https://github.com/apache/flink/pull/8916#discussion_r298852934
##
File path: docs/dev/table/common.md
##
@@ -202,10 +259
Yun Tang created FLINK-13034:
Summary: Improve the performance when checking whether mapstate is
empty for RocksDBStateBackend
Key: FLINK-13034
URL: https://issues.apache.org/jira/browse/FLINK-13034
Proje
[
https://issues.apache.org/jira/browse/FLINK-11696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11696:
-
Summary: Avoid to send mkdir requests to DFS from task side (was:
[checkpoint] Avoid to send mkdir requ
walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-507046084
thanks for the reminder @danny0405. will try to take a look and create
another PR asap.
---
shaoxuan-wang commented on a change in pull request #8632: [FLINK-12744][ml]
add shared params in ml package
URL: https://github.com/apache/flink/pull/8632#discussion_r298831640
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/params/shared/colname/HasKe
shaoxuan-wang commented on a change in pull request #8632: [FLINK-12744][ml]
add shared params in ml package
URL: https://github.com/apache/flink/pull/8632#discussion_r298831625
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/params/shared/colname/HasKe
shaoxuan-wang commented on a change in pull request #8632: [FLINK-12744][ml]
add shared params in ml package
URL: https://github.com/apache/flink/pull/8632#discussion_r298831489
##
File path: flink-ml-parent/flink-ml-lib/pom.xml
##
@@ -0,0 +1,65 @@
+
+
+http://maven.apache
shaoxuan-wang commented on a change in pull request #8632: [FLINK-12744][ml]
add shared params in ml package
URL: https://github.com/apache/flink/pull/8632#discussion_r298831635
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/params/shared/colname/HasKe
shaoxuan-wang commented on a change in pull request #8632: [FLINK-12744][ml]
add shared params in ml package
URL: https://github.com/apache/flink/pull/8632#discussion_r298831709
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/params/shared/colname/HasPr
shaoxuan-wang commented on a change in pull request #8632: [FLINK-12744][ml]
add shared params in ml package
URL: https://github.com/apache/flink/pull/8632#discussion_r298831509
##
File path: flink-ml-parent/flink-ml-lib/pom.xml
##
@@ -0,0 +1,65 @@
+
+
+http://maven.apache
shaoxuan-wang commented on a change in pull request #8632: [FLINK-12744][ml]
add shared params in ml package
URL: https://github.com/apache/flink/pull/8632#discussion_r298831785
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/params/shared/colname/HasPr
shaoxuan-wang commented on issue #8632: [FLINK-12744][ml] add shared params in
ml package
URL: https://github.com/apache/flink/pull/8632#issuecomment-507031331
Thanks for the contribution, @xuyang1706
The PR looks good to me in general. But I have a few concerns about the
naming of int
[
https://issues.apache.org/jira/browse/FLINK-12939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875762#comment-16875762
]
Jark Wu commented on FLINK-12939:
-
Sure [~xujiang]
> Translate "Apache Kafka Connector"
[
https://issues.apache.org/jira/browse/FLINK-12947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-12947.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in 1.9.0: 8315f38e89f897e32cfa0f23990cb3fb44db0d72
> Tr
asfgit closed pull request #8842: [FLINK-12947][docs] Translate Twitter
Connector page into Chinese
URL: https://github.com/apache/flink/pull/8842
This is an automated message from the Apache Git Service.
To respond to the m
[
https://issues.apache.org/jira/browse/FLINK-12881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-12881.
-
Resolution: Fixed
Fix Version/s: 1.9.0
> Add more functionalities for ML Params and Param
[
https://issues.apache.org/jira/browse/FLINK-12881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875719#comment-16875719
]
Shaoxuan Wang commented on FLINK-12881:
---
Fixed in master:1660c6b47af789fa5c9bf
[
https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang updated FLINK-12470:
--
Comment: was deleted
(was: Fixed in master:1660c6b47af789fa5c9bf6a3ff77e868ca90)
> FLIP39
[
https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875717#comment-16875717
]
Shaoxuan Wang commented on FLINK-12470:
---
Fixed in master:1660c6b47af789fa5c9bf
asfgit closed pull request #8776: [FLINK-12881][ml] Add more functionalities
for ML Params and ParamInfo class
URL: https://github.com/apache/flink/pull/8776
This is an automated message from the Apache Git Service.
To respo
wuchong commented on a change in pull request #8918:
[FLINK-12944][docs]Translate Streaming File Sink page into Chinese
URL: https://github.com/apache/flink/pull/8918#discussion_r298822550
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -23,30 +23,23 @@ speci
wuchong commented on a change in pull request #8918:
[FLINK-12944][docs]Translate Streaming File Sink page into Chinese
URL: https://github.com/apache/flink/pull/8918#discussion_r298822984
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -84,55 +77,41 @@ input
wuchong commented on a change in pull request #8918:
[FLINK-12944][docs]Translate Streaming File Sink page into Chinese
URL: https://github.com/apache/flink/pull/8918#discussion_r298822925
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -84,55 +77,41 @@ input
wuchong commented on a change in pull request #8918:
[FLINK-12944][docs]Translate Streaming File Sink page into Chinese
URL: https://github.com/apache/flink/pull/8918#discussion_r298822449
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -23,30 +23,23 @@ speci
wuchong commented on a change in pull request #8918:
[FLINK-12944][docs]Translate Streaming File Sink page into Chinese
URL: https://github.com/apache/flink/pull/8918#discussion_r298822673
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -84,55 +77,41 @@ input
wuchong commented on a change in pull request #8918:
[FLINK-12944][docs]Translate Streaming File Sink page into Chinese
URL: https://github.com/apache/flink/pull/8918#discussion_r298822620
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -84,55 +77,41 @@ input
wuchong commented on a change in pull request #8918:
[FLINK-12944][docs]Translate Streaming File Sink page into Chinese
URL: https://github.com/apache/flink/pull/8918#discussion_r298822464
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -23,30 +23,23 @@ speci
wuchong commented on a change in pull request #8837:
[FLINK-12938][docs]Translate "Streaming Connectors" page into Chinese
URL: https://github.com/apache/flink/pull/8837#discussion_r298821987
##
File path: docs/dev/connectors/index.zh.md
##
@@ -28,16 +28,15 @@ under the Li
wuchong commented on a change in pull request #8837:
[FLINK-12938][docs]Translate "Streaming Connectors" page into Chinese
URL: https://github.com/apache/flink/pull/8837#discussion_r298822366
##
File path: docs/dev/connectors/index.zh.md
##
@@ -48,39 +47,31 @@ Connectors p
wuchong commented on a change in pull request #8837:
[FLINK-12938][docs]Translate "Streaming Connectors" page into Chinese
URL: https://github.com/apache/flink/pull/8837#discussion_r298822152
##
File path: docs/dev/connectors/index.zh.md
##
@@ -48,39 +47,31 @@ Connectors p
wuchong commented on a change in pull request #8842: [FLINK-12947][docs]
Translate Twitter Connector page into Chinese
URL: https://github.com/apache/flink/pull/8842#discussion_r298821892
##
File path: docs/dev/connectors/twitter.zh.md
##
@@ -35,24 +35,21 @@ To use this co
wuchong commented on a change in pull request #8838:
[FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese
URL: https://github.com/apache/flink/pull/8838#discussion_r298821775
##
File path: docs/dev/connectors/nifi.zh.md
##
@@ -23,9 +23,8 @@ specific languag
wuchong commented on a change in pull request #8838:
[FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese
URL: https://github.com/apache/flink/pull/8838#discussion_r298821782
##
File path: docs/dev/connectors/nifi.zh.md
##
@@ -35,30 +34,23 @@ following depe
wuchong commented on a change in pull request #8838:
[FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese
URL: https://github.com/apache/flink/pull/8838#discussion_r298821853
##
File path: docs/dev/connectors/nifi.zh.md
##
@@ -89,18 +81,17 @@ val nifiSource
wuchong commented on a change in pull request #8838:
[FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese
URL: https://github.com/apache/flink/pull/8838#discussion_r298821868
##
File path: docs/dev/connectors/nifi.zh.md
##
@@ -135,6 +126,6 @@ streamExecEnv.
wuchong commented on a change in pull request #8838:
[FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese
URL: https://github.com/apache/flink/pull/8838#discussion_r298821829
##
File path: docs/dev/connectors/nifi.zh.md
##
@@ -35,30 +34,23 @@ following depe
wuchong commented on a change in pull request #8838:
[FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese
URL: https://github.com/apache/flink/pull/8838#discussion_r298821790
##
File path: docs/dev/connectors/nifi.zh.md
##
@@ -35,30 +34,23 @@ following depe
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821621
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -47,44 +43,30 @@ This connect
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821680
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -47,44 +43,30 @@ This connect
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821743
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -170,6 +151,6 @@ stream.addSi
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821645
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -47,44 +43,30 @@ This connect
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821204
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -23,21 +23,17 @@ specific lan
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821487
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -47,44 +43,30 @@ This connect
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821423
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -47,44 +43,30 @@ This connect
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821736
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -132,8 +114,7 @@ val stream =
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821407
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -47,44 +43,30 @@ This connect
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821048
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -23,21 +23,17 @@ specific lan
wuchong commented on a change in pull request #8843: [FLINK-12945][docs]
Translate RabbitMQ Connector page into Chinese
URL: https://github.com/apache/flink/pull/8843#discussion_r298821325
##
File path: docs/dev/connectors/rabbitmq.zh.md
##
@@ -23,21 +23,17 @@ specific lan
[
https://issues.apache.org/jira/browse/FLINK-13014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-13014.
Resolution: Duplicate
> ChainBreakTest failed on Travis
> ---
[
https://issues.apache.org/jira/browse/FLINK-13020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-13020.
Resolution: Duplicate
Fix Version/s: (was: 1.9.0)
> UT Failure: ChainLengthDecr
[
https://issues.apache.org/jira/browse/FLINK-13033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-13033.
Resolution: Duplicate
Fix Version/s: (was: 1.9.0)
> Unstable test ChainOrderTes
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298525853
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/AbstractJDBCO
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298554434
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertTab
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298569122
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertOut
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298554776
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertTab
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298524951
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/AbstractJDBCO
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298557117
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/AbstractJDBCO
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298556877
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/AbstractJDBCO
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298570308
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertOut
wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc]
Introduce upsert table sink for JDBC
URL: https://github.com/apache/flink/pull/8867#discussion_r298520541
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/upsert/QueryE
86 matches
Mail list logo
