[
https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470398#comment-17470398
]
Echo Lee edited comment on FLINK-25561 at 1/7/22, 7:56 AM:
---
Ye
[
https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470398#comment-17470398
]
Echo Lee commented on FLINK-25561:
--
Yes, Maybe ExecutionConfigInfo#executionMode should
fapaul closed pull request #13918:
URL: https://github.com/apache/flink/pull/13918
--
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
[
https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25561:
---
Component/s: Runtime / Coordination
(was: Runtime / Web Frontend)
> Ex
[
https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470393#comment-17470393
]
Martijn Visser commented on FLINK-25560:
[~jingge] Will you take a look at this
[
https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25561:
---
Priority: Minor (was: Major)
> Execution mode of batch mode job web ui shows pipeline
> --
[
https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470392#comment-17470392
]
Martijn Visser commented on FLINK-25561:
I don't think this is a bug in the fron
[
https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470391#comment-17470391
]
Martijn Visser commented on FLINK-25562:
[~wzq246810] Please translate your tick
[
https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-19937.
--
Resolution: Fixed
Closing this since all subtasks are completed
> Support sink parallelism op
[
https://issues.apache.org/jira/browse/FLINK-19943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-19943.
--
Resolution: Duplicate
I'm closing this ticket as a duplicate of
https://issues.apache.org/jir
MartijnVisser commented on pull request #13918:
URL: https://github.com/apache/flink/pull/13918#issuecomment-1007197535
This PR is superseded by https://github.com/apache/flink/pull/18033
@fapaul Can you close this one?
--
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-25563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-25563.
--
Resolution: Duplicate
> Support sink parallelism configuration to Elasticsearch connector
> --
[
https://issues.apache.org/jira/browse/FLINK-25563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-25563:
-
Issue Type: Improvement (was: Bug)
> Support sink parallelism configuration to Elasticsearch connector
MartijnVisser commented on pull request #18288:
URL: https://github.com/apache/flink/pull/18288#issuecomment-1007195956
@infoverload Can you also have a look at this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
slinkydeveloper commented on a change in pull request #17598:
URL: https://github.com/apache/flink/pull/17598#discussion_r780071456
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/TableCsvFormatITCase.java
##
@@ -0,0 +1,204 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-24962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-24962.
---
Fix Version/s: (was: 1.14.3)
Resolution: Cannot Reproduce
Just close it for now as I cannot repro
Yubin Li created FLINK-25563:
Summary: Support sink parallelism configuration to Elasticsearch
connector
Key: FLINK-25563
URL: https://issues.apache.org/jira/browse/FLINK-25563
Project: Flink
Is
flinkbot edited a comment on pull request #18291:
URL: https://github.com/apache/flink/pull/18291#issuecomment-1007087098
## CI report:
* 83604f544f5ff5e5d8b1857313fee595c32ce37a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
ziqiang.wang created FLINK-25562:
Summary: hive sql connector 依赖冲突
Key: FLINK-25562
URL: https://issues.apache.org/jira/browse/FLINK-25562
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470369#comment-17470369
]
刘方奇 commented on FLINK-25360:
-
[~yunta] OK, THX, I will put the design doc link in this issu
Echo Lee created FLINK-25561:
Summary: Execution mode of batch mode job web ui shows pipeline
Key: FLINK-25561
URL: https://issues.apache.org/jira/browse/FLINK-25561
Project: Flink
Issue Type: B
flinkbot edited a comment on pull request #18293:
URL: https://github.com/apache/flink/pull/18293#issuecomment-1007116888
## CI report:
* Unknown: [CANCELED](TBD)
* d7004a1d41618e403920420e06b2218ccadf8b56 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462
flinkbot edited a comment on pull request #18293:
URL: https://github.com/apache/flink/pull/18293#issuecomment-1007116888
## CI report:
* Unknown: [CANCELED](TBD)
* d7004a1d41618e403920420e06b2218ccadf8b56 UNKNOWN
Bot commands
The @flinkbot bot supports the fo
dengziming commented on pull request #18145:
URL: https://github.com/apache/flink/pull/18145#issuecomment-1007175286
I rewrote this PR and tried to keep the
`OffsetsInitializer#PartitionOffsetsRetriever` unchanged according to your
suggestion, PTAL, @fapaul 🤝
--
This is an automated mes
BruceWong96 commented on pull request #18293:
URL: https://github.com/apache/flink/pull/18293#issuecomment-1007174456
@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 spec
[
https://issues.apache.org/jira/browse/FLINK-25556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470361#comment-17470361
]
Yun Gao edited comment on FLINK-25556 at 1/7/22, 6:30 AM:
--
Very
[
https://issues.apache.org/jira/browse/FLINK-25556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470361#comment-17470361
]
Yun Gao commented on FLINK-25556:
-
Very thanks [~akalashnikov] for the fix. Fix on maste
[
https://issues.apache.org/jira/browse/FLINK-25556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-25556.
---
Fix Version/s: 1.15.0
Resolution: Fixed
> Extra waiting of final checkpoint in benchmarks
> -
flinkbot edited a comment on pull request #18253:
URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117
## CI report:
* bf6b56b1cd6591e7b3fad6fddd3f701a06c64868 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii closed pull request #42:
URL: https://github.com/apache/flink-benchmarks/pull/42
--
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
flinkbot edited a comment on pull request #17936:
URL: https://github.com/apache/flink/pull/17936#issuecomment-980533423
## CI report:
* 819fe60c18d405d58487948d56df1fbf8662e476 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470355#comment-17470355
]
Yun Tang commented on FLINK-25360:
--
[~liufangqi] I suggest to create a design doc via g
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
//sink table,omits some physical fields
CREATE TABLE kd_product_info (
pr
[
https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-24880.
---
Fix Version/s: 1.15.0
1.14.3
Assignee: Dian Fu
Resolution: Fixed
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470352#comment-17470352
]
Zongwen Li commented on FLINK-25559:
[~lincoln.86xy] Yes, the primary key of the Sin
dianfu closed pull request #18292:
URL: https://github.com/apache/flink/pull/18292
--
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
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
//sink table,omits some physical fields
CREATE TABLE kd_product_info (
pr
TanYuxin-tyx commented on pull request #17936:
URL: https://github.com/apache/flink/pull/17936#issuecomment-1007156363
@wsry Thanks a lot for helping review it. I have updated the PR according to
your comments.
--
This is an automated message from the Apache Git Service.
To respond to th
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780039241
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java
##
@@ -75,6 +75,10 @@
@GuardedBy("bu
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780039080
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
##
@@ -192,6
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780038916
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
##
@@ -192,6
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780038225
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
##
@@ -192,6
flinkbot edited a comment on pull request #17936:
URL: https://github.com/apache/flink/pull/17936#issuecomment-980533423
## CI report:
* ec7627125864b807502b26946f61a59ec027c625 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780036507
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
##
@@ -192,6
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780036377
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
##
@@ -192,6
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780035986
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
##
@@ -192,6
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780035800
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
##
@@ -192,6
flinkbot edited a comment on pull request #17936:
URL: https://github.com/apache/flink/pull/17936#issuecomment-980533423
## CI report:
* ec7627125864b807502b26946f61a59ec027c625 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
TanYuxin-tyx commented on a change in pull request #17936:
URL: https://github.com/apache/flink/pull/17936#discussion_r780035144
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java
##
@@ -121,12 +12
flinkbot edited a comment on pull request #17937:
URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170
## CI report:
* 48c44601bb0c15a3975d8ad41249231f06cbced2 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
lindong28 commented on a change in pull request #493:
URL: https://github.com/apache/flink-web/pull/493#discussion_r779998154
##
File path: _config.yml
##
@@ -562,6 +579,11 @@ release_archive:
version: 1.0
release_date: 2017-07-27
+flink_ml:
+ - ver
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470323#comment-17470323
]
lincoln lee edited comment on FLINK-25559 at 1/7/22, 4:05 AM:
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470323#comment-17470323
]
lincoln lee commented on FLINK-25559:
-
[~Ashulin] Does the sink table's primary key
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-24758:
---
Fix Version/s: 1.15.0
> filesystem sink: partition.time-extractor.kind support "MMdd"
>
flinkbot edited a comment on pull request #18293:
URL: https://github.com/apache/flink/pull/18293#issuecomment-1007116888
## CI report:
* ead78b4fb9331e7b89163879492f804dbb1df185 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-24758.
Resolution: Resolved
master(1.15): c66720ae9fda223b9236aad0fa3b0eaf7a57831b
> filesystem sink: pa
leonardBang merged pull request #17749:
URL: https://github.com/apache/flink/pull/17749
--
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-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470316#comment-17470316
]
Zongwen Li edited comment on FLINK-25559 at 1/7/22, 3:52 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
[
https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruce Wong updated FLINK-25560:
---
Component/s: Connectors / HBase
> Add "sink.delete.mode" in HBase sql connector for retracting the l
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruce Wong updated FLINK-25560:
---
Affects Version/s: 1.15.0
> Add "sink.delete.mode" in HBase sql connector for retracting the latest
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
flinkbot edited a comment on pull request #18293:
URL: https://github.com/apache/flink/pull/18293#issuecomment-1007116888
## CI report:
* ead78b4fb9331e7b89163879492f804dbb1df185 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18293:
URL: https://github.com/apache/flink/pull/18293#issuecomment-1007117133
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
flinkbot commented on pull request #18293:
URL: https://github.com/apache/flink/pull/18293#issuecomment-1007116888
## CI report:
* ead78b4fb9331e7b89163879492f804dbb1df185 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
flinkbot edited a comment on pull request #17937:
URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170
## CI report:
* c1728e5765b33b6ba1140a2f313687eb3bbbaf5f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17937:
URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170
## CI report:
* c1728e5765b33b6ba1140a2f313687eb3bbbaf5f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25560:
---
Labels: pull-request-available (was: )
> Add "sink.delete.mode" in HBase sql connector for
BruceWong96 opened a new pull request #18293:
URL: https://github.com/apache/flink/pull/18293
Add "sink.delete.mode" in HBase sql connector for retracting the latest
version or all versions in changelog mode.
## What is the purpose of the change
When we synchronize dat
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470318#comment-17470318
]
Zongwen Li commented on FLINK-25559:
[~lzljs3620320] Hi，Please take a look.
> SQL J
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
imaffe commented on a change in pull request #17937:
URL: https://github.com/apache/flink/pull/17937#discussion_r780005813
##
File path:
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/source/PulsarSourceReaderTestBase.java
###
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Attachment: image-2022-01-07-11-27-01-010.png
> SQL JOIN causes data loss
>
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
ps.pr
HuangXingBo commented on a change in pull request #18292:
URL: https://github.com/apache/flink/pull/18292#discussion_r77483
##
File path: flink-python/pyflink/fn_execution/utils/operation_utils.py
##
@@ -271,3 +273,37 @@ def load_aggregate_function(payload):
return
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470316#comment-17470316
]
Zongwen Li commented on FLINK-25559:
[~lincoln.86xy]
{code:java}
WITH (
'connector'
flinkbot edited a comment on pull request #18253:
URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117
## CI report:
* 233bdf5e282ecb6f4b9f50a507fd52753fdfc298 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18253:
URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117
## CI report:
* 233bdf5e282ecb6f4b9f50a507fd52753fdfc298 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
lindong28 commented on a change in pull request #493:
URL: https://github.com/apache/flink-web/pull/493#discussion_r779998154
##
File path: _config.yml
##
@@ -562,6 +579,11 @@ release_archive:
version: 1.0
release_date: 2017-07-27
+flink_ml:
+ - ver
flinkbot edited a comment on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102305
## CI report:
* 91138d1cbb2d6f6c36b693f9682c8d0e570137c4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470313#comment-17470313
]
lincoln lee commented on FLINK-25559:
-
[~Ashulin] Thanks for reporting this!
Could y
flinkbot commented on pull request #18292:
URL: https://github.com/apache/flink/pull/18292#issuecomment-1007102039
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
[
https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruce Wong updated FLINK-25560:
---
Description:
h1. Motivation
When we synchronize data from mysql to HBase, we find that when deletin
[
https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruce Wong updated FLINK-25560:
---
Description:
h1. Motivation
When we synchronize data from mysql to HBase, we find that when deletin
1 - 100 of 462 matches
Mail list logo
