[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628143#comment-17628143
]
Zhu Zhu commented on FLINK-29801:
-
The requirement makes sense. I will take a look at th
LadyForest commented on PR #349:
URL:
https://github.com/apache/flink-table-store/pull/349#issuecomment-1301703726
> Hi @LadyForest I want to fix this bug, can you help to review this PR? THX
Thx for the contribution, will take a look soon
--
This is an automated message from the A
snuyanzin commented on code in PR #20922:
URL: https://github.com/apache/flink/pull/20922#discussion_r1012540636
##
flink-table/pom.xml:
##
@@ -76,10 +76,10 @@ under the License.
- 1.26.0
+ 1.32.0
3
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628136#comment-17628136
]
Caizhi Weng commented on FLINK-27246:
-
Hi [~KristoffSC].
You talked about "maybe if
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29859:
---
Affects Version/s: 1.17.0
> TPC-DS end-to-end test with adaptive batch scheduler failed due to oo
>
Leonard Xu created FLINK-29859:
--
Summary: TPC-DS end-to-end test with adaptive batch scheduler
failed due to oo non-empty .out files.
Key: FLINK-29859
URL: https://issues.apache.org/jira/browse/FLINK-29859
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628133#comment-17628133
]
Weijie Guo commented on FLINK-29818:
[~leonard] Sure, [~xtsong] will take a look lat
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628132#comment-17628132
]
Leonard Xu commented on FLINK-29818:
[~Weijie Guo] Could you find someone who are fa
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628131#comment-17628131
]
Leonard Xu commented on FLINK-29818:
https://dev.azure.com/apache-flink/apache-flink
1996fanrui commented on code in PR #21131:
URL: https://github.com/apache/flink/pull/21131#discussion_r1012524837
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java:
##
@@ -73,11 +79,27 @@ public void dispatch(C
mbalassi merged PR #424:
URL: https://github.com/apache/flink-kubernetes-operator/pull/424
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubs
[
https://issues.apache.org/jira/browse/FLINK-29858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-29858:
-
Attachment: image-2022-11-03-13-53-12-593.png
> Jdbc reading supports setting multiple queryTemplates
>
[
https://issues.apache.org/jira/browse/FLINK-29858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-29858:
-
Description:
Jdbc reading supports setting multiple queryTemplates. Currently, jdbc reading
only suppor
[
https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628126#comment-17628126
]
Yanfei Lei commented on FLINK-29095:
I'd like to continue this work, could you pleas
waywtdcc created FLINK-29858:
Summary: Jdbc reading supports setting multiple queryTemplates
Key: FLINK-29858
URL: https://issues.apache.org/jira/browse/FLINK-29858
Project: Flink
Issue Type: New
gaoyunhaii commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1301675992
> I assume you're talking about AsyncRetryStrategies and the reference to
AsyncRetryPredicate is just a typo? I still don't think I fully understand what
you're suggesting. This is wha
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1301664533
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li closed FLINK-19651.
--
Resolution: Duplicate
[~Tomm] Thanks for your PR, it's a good work. However, this is duplicated
w
libenchao closed pull request #20126: [FLINK-19651][Connectors/JDBC] Support
the filter push down for the JDBC connector
URL: https://github.com/apache/flink/pull/20126
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
tsreaper opened a new pull request, #350:
URL: https://github.com/apache/flink-table-store/pull/350
Table Store sink continuously fails with "Trying to add file which is
already added" when snapshot committing is slow.
This is due to a bug in `FileStoreCommitImpl#filterCommitted`. Whe
xintongsong commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1301630684
Thanks @reswqa for the fix, and thanks all for the discussion.
For this specific case, I think it indeed can be fixed either way,
introducing a thread or making sure `leaderElec
[
https://issues.apache.org/jira/browse/FLINK-27995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628101#comment-17628101
]
lincoln lee commented on FLINK-27995:
-
[~fsk119] I'm investigating the problem in th
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-29818:
--
Assignee: Weijie Guo
> HsResultPartitionTest.testAvailability fails
> -
flinkbot commented on PR #21226:
URL: https://github.com/apache/flink/pull/21226#issuecomment-1301609959
## CI report:
* b8bad940ca1c1e0a5e4913d609766085801530ed UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ruanhang1993 opened a new pull request, #21226:
URL: https://github.com/apache/flink/pull/21226
## What is the purpose of the change
This pull request makes task deployment go through the blob server, rather
than through RPC. That way we avoid re-transferring them on each deployment
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29857:
Description: Hive3 add a new 'TGetInfoType' value 'CLI_ODBC_KEYWORDS', but
'HiveServer2Endpoint' doesn't h
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29857:
Description:
Hive3 add a new 'TGetInfoType' value 'CLI_ODBC_KEYWORDS', but
HiveServer2Endpoint
> Fix Hi
yuzelin created FLINK-29857:
---
Summary: Fix HiveServer2Endpoint crush when using Hive3 Beeline
Key: FLINK-29857
URL: https://issues.apache.org/jira/browse/FLINK-29857
Project: Flink
Issue Type: Bug
zjureel commented on PR #349:
URL:
https://github.com/apache/flink-table-store/pull/349#issuecomment-1301593843
Hi @LadyForest I want to fix this bug, can you help to review this PR? THX
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-29856:
---
Description:
When I trigger a savepoint with the Flink K8s operator, I verified for two
sources (Ka
tsreaper merged PR #346:
URL: https://github.com/apache/flink-table-store/pull/346
--
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...@fl
[
https://issues.apache.org/jira/browse/FLINK-29791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29791:
---
Labels: pull-request-available (was: )
> Print sink result mess up with GC log in E2eTestBa
zjureel opened a new pull request, #349:
URL: https://github.com/apache/flink-table-store/pull/349
Redirct gc log from stdout to file
--
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-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-29856:
---
Description:
When I trigger a savepoint with the Flink K8s operator, I verified for two
sources (Ka
[
https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-29856:
---
Description:
When I trigger a savepoint with the Flink K8s operator, I verified for two
sources (Ka
Mason Chen created FLINK-29856:
--
Summary: Triggering savepoint does not trigger source operator
checkpoint
Key: FLINK-29856
URL: https://issues.apache.org/jira/browse/FLINK-29856
Project: Flink
zhipeng93 commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r1012438620
##
docs/content/docs/operators/feature/randomsplitter.md:
##
@@ -0,0 +1,148 @@
+---
+title: "RandomSplitter"
+weight: 1
+type: docs
+aliases:
+- /operators/feature/ran
1996fanrui commented on PR #19781:
URL: https://github.com/apache/flink/pull/19781#issuecomment-1301580063
@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
1996fanrui commented on PR #20137:
URL: https://github.com/apache/flink/pull/20137#issuecomment-1301579975
@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-29567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620663#comment-17620663
]
Qingsheng Ren edited comment on FLINK-29567 at 11/3/22 2:24 AM:
--
PatrickRen merged PR #21220:
URL: https://github.com/apache/flink/pull/21220
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.ap
[
https://issues.apache.org/jira/browse/FLINK-29647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628074#comment-17628074
]
Xintong Song commented on FLINK-29647:
--
[~jackin853],
As [~zhuzh] mentioned previo
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628061#comment-17628061
]
dalongliu edited comment on FLINK-29855 at 11/3/22 2:05 AM:
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628061#comment-17628061
]
dalongliu commented on FLINK-29855:
---
Do the results in the print table as expected?
>
yunfengzhou-hub commented on code in PR #166:
URL: https://github.com/apache/flink-ml/pull/166#discussion_r1012433599
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/ImputerTest.java:
##
@@ -0,0 +1,361 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
flinkbot commented on PR #21225:
URL: https://github.com/apache/flink/pull/21225#issuecomment-1301559678
## CI report:
* 6ab4e11b720543cdde73a912d6a39bdfa77750f9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lincoln-lil opened a new pull request, #21225:
URL: https://github.com/apache/flink/pull/21225
## What is the purpose of the change
Fix ChangelogNormalize uses wrong keys after transformation by
WatermarkAssignerChangelogNormalizeTransposeRule, the remap logic is necessary
here.
flink-sql closed pull request #21173: [FLINK-29781][table-planner] Fix
ChangelogNormalize uses wrong keys after transformation by
WatermarkAssignerChangelogNormalizeTransposeRule
URL: https://github.com/apache/flink/pull/21173
--
This is an automated message from the Apache Git Service.
To r
flink-sql commented on PR #21173:
URL: https://github.com/apache/flink/pull/21173#issuecomment-1301555055
incorrect github account here, close this pr.
--
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 g
lincoln-lil commented on PR #21219:
URL: https://github.com/apache/flink/pull/21219#issuecomment-1301554180
@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 commen
yunfengzhou-hub commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r1012423267
##
flink-ml-python/pyflink/ml/lib/feature/randomsplitter.py:
##
@@ -0,0 +1,80 @@
+###
luoyuxia commented on PR #21218:
URL: https://github.com/apache/flink/pull/21218#issuecomment-1301543777
@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.
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1012407031
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java:
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1012406782
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,306 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-29850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628030#comment-17628030
]
Shammon commented on FLINK-29850:
-
Hi [~knaufk] I try the steps above with flink 1.15.2
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1012406088
##
flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilderTest.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyi Yan updated FLINK-29855:
--
Description:
Local flink cluster env:
1 task manager and 1 task slot.
To reproduce the issue:
# cr
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyi Yan updated FLINK-29855:
--
Description:
To reproduce the issue:
# create a datagen table with a single column int type of id
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyi Yan updated FLINK-29855:
--
Description:
To reproduce the issue:
# create a datagen table with a single column int type of id
snuyanzin commented on PR #21150:
URL: https://github.com/apache/flink/pull/21150#issuecomment-1301432124
@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.
flinkbot commented on PR #21224:
URL: https://github.com/apache/flink/pull/21224#issuecomment-1301400580
## CI report:
* 39c4138587b44ba392e84b1b5f30065e34b71b59 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29827:
---
Labels: pull-request-available (was: )
> [Connector][AsyncSinkWriter] Checkpointed states b
vahmed-hamdy opened a new pull request, #21224:
URL: https://github.com/apache/flink/pull/21224
## What is the purpose of the change
This is a bug fix, where `AsyncSinkWriter` doesn't register callback on
state restoration causing records to reside in buffer more than
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyi Yan updated FLINK-29855:
--
Description:
To reproduce the issue:
# create a datagen table with a single column int type of id.
Xinyi Yan created FLINK-29855:
-
Summary: UDF randomly processed input data twice
Key: FLINK-29855
URL: https://issues.apache.org/jira/browse/FLINK-29855
Project: Flink
Issue Type: Bug
Affect
mbalassi commented on PR #424:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/424#issuecomment-1301291863
Thanks @morhidi, good catch. The beauty of refactoring.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
morhidi commented on PR #424:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/424#issuecomment-1301281774
LGTM, it seems we only needed the plugin interface from flink-core.
Nit: The STATUS generic type is not used. `public > ResourceLifecycleState getLifecycleState() {
[
https://issues.apache.org/jira/browse/FLINK-29854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29854:
--
Description:
h3. Background
Currently AsyncSinkWriter supports three mechanisms that trigger
[
https://issues.apache.org/jira/browse/FLINK-29854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-29854:
-
Assignee: Ahmed Hamdy
> Make Record Size Flush Strategy Optional for Async Sink
> -
[
https://issues.apache.org/jira/browse/FLINK-29854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627986#comment-17627986
]
Danny Cranmer commented on FLINK-29854:
---
Done, thanks [~chalixar]
> Make Record S
[
https://issues.apache.org/jira/browse/FLINK-29854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627981#comment-17627981
]
Ahmed Hamdy commented on FLINK-29854:
-
Hi [~dannycranmer], could you please assign m
[
https://issues.apache.org/jira/browse/FLINK-29853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627978#comment-17627978
]
James Busche commented on FLINK-29853:
--
OK - I tried changing the pom.xml from:
2.
[
https://issues.apache.org/jira/browse/FLINK-29854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29854:
--
Description:
h3. Background
Currently AsyncSinkWriter supports three mechanisms that trigger
[
https://issues.apache.org/jira/browse/FLINK-29854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29854:
--
Description:
h3. Background
Currently AsyncSinkWriter supports three mechanisms that trigger
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1012223894
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,306 @@
+/*
+ * Lic
Danny Cranmer created FLINK-29854:
-
Summary: Make Record Size Flush Strategy Optional for Async Sink
Key: FLINK-29854
URL: https://issues.apache.org/jira/browse/FLINK-29854
Project: Flink
Iss
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1012223894
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,306 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-29850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627911#comment-17627911
]
Konstantin Knauf commented on FLINK-29850:
--
I can reproduce this.
> Flink Tabl
mbalassi commented on PR #424:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/424#issuecomment-1301044792
cc @morhidi
--
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
mbalassi opened a new pull request, #424:
URL: https://github.com/apache/flink-kubernetes-operator/pull/424
I expect that this is finally the last commit for the API refactor change.
This is a potentially controversial one, because for this I needed to
introduce an intentionally slim
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1012083456
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java:
##
@@ -0,0 +1,65 @@
+/*
James Busche created FLINK-29853:
Summary: Older jackson-databind found in
flink-kubernetes-operator-1.2.0-shaded.jar
Key: FLINK-29853
URL: https://issues.apache.org/jira/browse/FLINK-29853
Project: F
[
https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627854#comment-17627854
]
João Boto commented on FLINK-15462:
---
created a PR to Trino dialect (previous PrestoSql
eskabetxe commented on PR #21223:
URL: https://github.com/apache/flink/pull/21223#issuecomment-1300995384
Im working on docs, but it would be cool some review as documentation
depends on implementation.
There are two test disabled on TrinoTableSinkITCase, as the Trino connector
used
flinkbot commented on PR #21223:
URL: https://github.com/apache/flink/pull/21223#issuecomment-1300993207
## CI report:
* 828280a9c4c672af0e67737da302fd095c96108f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15462:
---
Labels: auto-deprioritized-major pull-request-available (was:
auto-deprioritized-major)
>
eskabetxe opened a new pull request, #21223:
URL: https://github.com/apache/flink/pull/21223
## What is the purpose of the change
Add the implementation of the Trino dialect for JDBC connectors
## Brief change log
Added:
TrinoDialect
TrinoDialectFactory
TrinoRowC
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1012085964
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java:
##
@@ -0,0 +1,219 @@
+/*
+ * Licensed to the A
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1012083456
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java:
##
@@ -0,0 +1,65 @@
+/*
pnowojski commented on code in PR #21131:
URL: https://github.com/apache/flink/pull/21131#discussion_r1012016085
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java:
##
@@ -73,11 +79,27 @@ public void dispatch(Ch
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627824#comment-17627824
]
Weijie Guo commented on FLINK-29818:
I have found the reason and proposed pull reque
XComp commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1300806942
> To me the issue stems more from both the runner and election service
calling into each other under locks (== fundamental issue that should never
happen), and locks maybe being way too bro
JasonLee created FLINK-29852:
Summary: The operator is repeatedly displayed on the Flink Web UI
Key: FLINK-29852
URL: https://issues.apache.org/jira/browse/FLINK-29852
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627804#comment-17627804
]
Matthias Pohl commented on FLINK-29818:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627802#comment-17627802
]
Matthias Pohl commented on FLINK-24119:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627801#comment-17627801
]
Matthias Pohl commented on FLINK-26974:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627798#comment-17627798
]
Matthias Pohl commented on FLINK-29818:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29818:
--
Labels: pull-request-available test-stability (was: pull-request-available)
> HsResultPartiti
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627796#comment-17627796
]
Matthias Pohl commented on FLINK-24119:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627795#comment-17627795
]
Matthias Pohl commented on FLINK-29427:
---
https://dev.azure.com/apache-flink/apache
1 - 100 of 232 matches
Mail list logo
