lvyanquan commented on PR #75:
URL:
https://github.com/apache/flink-connector-jdbc/pull/75#issuecomment-2665651533
Hi, @KevDi.
Would you like to rebase and fix the conflict?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
lvyanquan commented on PR #75:
URL:
https://github.com/apache/flink-connector-jdbc/pull/75#issuecomment-2665652224
Hi, @KevDi.
Would you like to rebase and fix the conflict?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
morozov commented on PR #3873:
URL: https://github.com/apache/flink-cdc/pull/3873#issuecomment-2666875989
I read more about the semantics of `InputStatus`, and I think the current
logic is good. Please validate my understanding below.
There are three possible value of the status:
1
eskabetxe closed pull request #140: [FLINK-36009] Architecture tests fixes
URL: https://github.com/apache/flink-connector-jdbc/pull/140
--
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 co
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Attachment: (was: operator-log-batch-job.log)
> FINISHED jobs incorrectly being set to REC
snuyanzin merged PR #131:
URL: https://github.com/apache/flink-shaded/pull/131
--
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.
becketqin commented on PR #25569:
URL: https://github.com/apache/flink/pull/25569#issuecomment-2666553880
@PatrickRen @tomncooper Thanks for the review and sorry for the late reply.
I just returned to work from vacation. I updated the patch to fix the
checkstyle failure. Will merge the patc
twalthr commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1959540183
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/UnnestITCase.scala:
##
@@ -312,71 +306,509 @@ class UnnestITCase(mod
fapaul commented on PR #75:
URL:
https://github.com/apache/flink-connector-jdbc/pull/75#issuecomment-2665385773
@EchoLee5 c @KevDi sorry for the long wait. Is anyone still willing to
contribute this change? I can help with reviewing/merging this PR.
--
This is an automated message from t
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928063#comment-17928063
]
Zakelly Lan commented on FLINK-34979:
-
Yes, if a callback may produce exception that
flinkbot commented on PR #26171:
URL: https://github.com/apache/flink/pull/26171#issuecomment-2665550842
## CI report:
* 71f5dc87f231a1c83cb5d52c1bb2df05f72d47db UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xiaoyu19950911 opened a new pull request, #26173:
URL: https://github.com/apache/flink/pull/26173
## What is the purpose of the change
Enabling the ignore-parse-errors parameter does not skip exceptions caused
by the format of the emitted data.
## Brief change l
flinkbot commented on PR #26172:
URL: https://github.com/apache/flink/pull/26172#issuecomment-2665584874
## CI report:
* 0fa67d2efde59dacc301bd5688f7b570f0bfefea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xiaoyu19950911 commented on PR #26172:
URL: https://github.com/apache/flink/pull/26172#issuecomment-2665590960
@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 com
gaborgsomogyi commented on PR #26170:
URL: https://github.com/apache/flink/pull/26170#issuecomment-2665165160
cc @mxm
--
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 un
gaborgsomogyi opened a new pull request, #26170:
URL: https://github.com/apache/flink/pull/26170
## What is the purpose of the change
This is a tiny change. `setup_hugo.sh` now installs everything inside the
`tar.gz` file into `/usr/local/bin`, but hugo executable is enough. In this P
yuxiqian commented on PR #3742:
URL: https://github.com/apache/flink-cdc/pull/3742#issuecomment-2665158791
Thanks for Kunni's proposal, rebased with master and migrated a few newly
added test cases.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
beryllw commented on PR #3914:
URL: https://github.com/apache/flink-cdc/pull/3914#issuecomment-2665148168
https://github.com/beryllw/flink-cdc/actions/runs/13387956706
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
libenchao merged PR #25919:
URL: https://github.com/apache/flink/pull/25919
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928025#comment-17928025
]
Zakelly Lan commented on FLINK-34979:
-
Well, the exception is framework-related, nor
[
https://issues.apache.org/jira/browse/FLINK-37343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Aranovsky updated FLINK-37343:
---
Description:
Hey, we have a use-case where we need to sink records into multiple ddb tables
xiaoyu19950911 opened a new pull request, #26172:
URL: https://github.com/apache/flink/pull/26172
## What is the purpose of the change
Enabling the ignore-parse-errors parameter does not skip exceptions caused
by the format of the emitted data.
## Brief change l
flinkbot commented on PR #26170:
URL: https://github.com/apache/flink/pull/26170#issuecomment-2665290537
## CI report:
* 2a16190b0984f38b2e85ca99ae808428a1cac165 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-34961:
Fix Version/s: hive-3.0.0
> GitHub Actions runner statistcs can be monitored per workflow
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928051#comment-17928051
]
xiaogang zhou commented on FLINK-34979:
---
[~zakelly] As user might use thenCompose,
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928052#comment-17928052
]
xiaogang zhou commented on FLINK-34979:
---
e.g. an operator has several states, and
twalthr commented on code in PR #26167:
URL: https://github.com/apache/flink/pull/26167#discussion_r1959564617
##
flink-python/pyflink/table/catalog.py:
##
@@ -1391,3 +1391,87 @@ def of(catalog_name: str, configuration: Configuration,
comment: str = None):
j_catalog_de
flinkbot commented on PR #26173:
URL: https://github.com/apache/flink/pull/26173#issuecomment-2665622934
## CI report:
* c3eb74229712131a084bcfb224d32232cba92ba7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928073#comment-17928073
]
Zakelly Lan commented on FLINK-34979:
-
We could have the similar API like `Completab
[
https://issues.apache.org/jira/browse/FLINK-36354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928106#comment-17928106
]
Stepan Stepanishchev commented on FLINK-36354:
--
[~xuyangzhong], can I help
[
https://issues.apache.org/jira/browse/FLINK-34961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928035#comment-17928035
]
Sergey Nuyanzin commented on FLINK-34961:
-
Merged to flink-connector-hive@main a
mxm commented on PR #26100:
URL: https://github.com/apache/flink/pull/26100#issuecomment-2665315384
> For the 1st part, my question is since the nullability info provided by
users are not reliable, why not enforce the use of nullable type when use
`RowData#createFieldGetter`? Am I missing s
snuyanzin merged PR #30:
URL: https://github.com/apache/flink-connector-hive/pull/30
--
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...@
boring-cyborg[bot] commented on PR #30:
URL:
https://github.com/apache/flink-connector-hive/pull/30#issuecomment-2665179406
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
beryllw commented on PR #3856:
URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2665141242
https://github.com/beryllw/flink-cdc/actions/runs/13387743918
@leonardBang Please help me retrigger the CI.
--
This is an automated message from the Apache Git Service.
To respond t
[
https://issues.apache.org/jira/browse/FLINK-37344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37344:
---
Labels: pull-request-available (was: )
> setup_hugo.sh should install the hugo binary only
zexin gong created FLINK-37345:
--
Summary: [BUG] ClassCastException
Key: FLINK-37345
URL: https://issues.apache.org/jira/browse/FLINK-37345
Project: Flink
Issue Type: Bug
Components: Fl
[
https://issues.apache.org/jira/browse/FLINK-36549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-36549:
--
Assignee: xiaoyu
> Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927984#comment-17927984
]
Yue Ma commented on FLINK-31238:
yes, i think this job is done and the ticket can be clo
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927982#comment-17927982
]
Gabor Somogyi commented on FLINK-31238:
---
Ah ok, I'm just looking at that PR but no
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927903#comment-17927903
]
xiaogang zhou edited comment on FLINK-34979 at 2/18/25 8:54 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-37311.
-
Resolution: Won't Do
> Fix doc generation issues with new version of hugo
>
lvyanquan commented on PR #3856:
URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2664992082
And you might need to do some rebase to fix the ci failure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
Alex Aranovsky created FLINK-37343:
--
Summary: Support for Dynamic Table Selection in DynamoDB Sink
Connector
Key: FLINK-37343
URL: https://issues.apache.org/jira/browse/FLINK-37343
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927993#comment-17927993
]
Gabor Somogyi commented on FLINK-17971:
---
FLINK-31238 has added such functionality
beryllw commented on PR #3856:
URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2665080984
> And you might need to do some rebase to fix the ci failure.
Sure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
lvyanquan commented on code in PR #3868:
URL: https://github.com/apache/flink-cdc/pull/3868#discussion_r1959350867
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/pom.xml:
##
@@ -28,7 +28,8 @@ limitations under the License.
flink-cd
[
https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-19303.
---
Resolution: Fixed
> Disable WAL in RocksDB recovery
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927988#comment-17927988
]
Gabor Somogyi commented on FLINK-31238:
---
6bf97674b660dbe1cd96b5b0273c3954f2c16fba
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927988#comment-17927988
]
Gabor Somogyi edited comment on FLINK-31238 at 2/18/25 9:14 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-31238.
---
Fix Version/s: 1.20.0
Resolution: Fixed
> Use IngestDB to speed up Rocksdb rescaling
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-31238.
-
> Use IngestDB to speed up Rocksdb rescaling recovery
> ---
gaborgsomogyi commented on PR #12345:
URL: https://github.com/apache/flink/pull/12345#issuecomment-2665036017
[FLINK-31238](https://issues.apache.org/jira/browse/FLINK-31238) has added
such functionality + this is an ancient PR without movement so closing.
--
This is an automated message
gaborgsomogyi closed pull request #12345: draft: [FLINK-17971]
[Runtime/StateBackends] Add RocksDB SST ingestion for batch writes
URL: https://github.com/apache/flink/pull/12345
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927974#comment-17927974
]
Yue Ma edited comment on FLINK-31238 at 2/18/25 8:34 AM:
-
Hi [~g
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927974#comment-17927974
]
Yue Ma commented on FLINK-31238:
[~gaborgsomogyi] In fact, we have already implemented t
[
https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927961#comment-17927961
]
lincoln lee commented on FLINK-37068:
-
[~xu_shuai_] Thank you for volunteering! Assi
[
https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927955#comment-17927955
]
Shuai Xu commented on FLINK-37068:
--
Hi [~xtsong][~xuyangzhong], I would like to assist
[
https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-37068:
---
Assignee: Shuai Xu
> Cross-team verification for FLIP-473
> ---
[
https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927975#comment-17927975
]
Gabor Somogyi commented on FLINK-37311:
---
I've had a deeper look and seems like the
[
https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927997#comment-17927997
]
Gabor Somogyi commented on FLINK-17288:
---
FLINK-31238 has added such functionality
[
https://issues.apache.org/jira/browse/FLINK-17971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-17971.
---
Resolution: Duplicate
> Speed up RocksDB bulk loading with SST generation and ingestion
> --
[
https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-17288.
---
Resolution: Duplicate
> Speedup loading from savepoints into RocksDB by bulk load
>
[
https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-19303.
-
> Disable WAL in RocksDB recovery
> ---
>
> Key: FLINK-1
lvyanquan commented on PR #3868:
URL: https://github.com/apache/flink-cdc/pull/3868#issuecomment-2665090728
> The mongodb7 CI failure is interesting, cause it ran without problem
locally (on macOS). The test times out, I'm just downloading the logs, will
check it out.
Hi @ferenc-csaky, h
lvyanquan commented on PR #3742:
URL: https://github.com/apache/flink-cdc/pull/3742#issuecomment-2665126860
I think it's a good time to complete this(Before the release of a large
number of other PRs), could @yuxiqian help to resolve the confilct?
--
This is an automated message from the
nicusX commented on code in PR #188:
URL:
https://github.com/apache/flink-connector-aws/pull/188#discussion_r1959395783
##
flink-connector-aws/flink-connector-aws-kinesis-streams/pom.xml:
##
@@ -102,6 +115,15 @@ under the License.
test
+
+
101 - 167 of 167 matches
Mail list logo
