[
https://issues.apache.org/jira/browse/FLINK-36627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894945#comment-17894945
]
Baiqing Lyu commented on FLINK-36627:
-
I took a brief look at this problem at it see
github-actions[bot] commented on PR #3509:
URL: https://github.com/apache/flink-cdc/pull/3509#issuecomment-2452737305
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] commented on PR #3450:
URL: https://github.com/apache/flink-cdc/pull/3450#issuecomment-2452737329
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
stankiewicz commented on PR #33:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/33#issuecomment-2452454402
Thanks 👍. Do you know when the next release is planned? Can I help with
anything?
--
This is an automated message from the Apache Git Service.
To respond to the mess
SamBarker commented on PR #906:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/906#issuecomment-2452399865
> What's the status of this? Could you guys @SamBarker @k-wall sort out the
issues that you have found?
@k-wall's fix is merged into this PR and OkHTTP is fully e
snuyanzin commented on PR #25601:
URL: https://github.com/apache/flink/pull/25601#issuecomment-2452295562
+1
LGTM
one minor thing: I noticed there is absent test for CURRENT_ROW_TIMESTAMP
does it make sense to add it as well?
--
This is an automated message from the Apache Gi
[
https://issues.apache.org/jira/browse/FLINK-36409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-36409:
--
Assignee: Sai Sharath Dandi (was: Matyas Orhidi)
> Publish some autoscaler metrics during st
[
https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36602:
---
Labels: pull-request-available (was: )
> Upgrade Calcite version to 1.38.0
> --
tomncooper opened a new pull request, #25602:
URL: https://github.com/apache/flink/pull/25602
## What is the purpose of the change
There is a high severity CVE
([CVE-2023-1370](https://nvd.nist.gov/vuln/detail/CVE-2023-1370)) in the
json-path version used by Calcite 1.32 used in the
flinkbot commented on PR #25602:
URL: https://github.com/apache/flink/pull/25602#issuecomment-2452155281
## CI report:
* fdde6c12c906f60845397764704e514c1c35b9d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hlteoh37 commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#discussion_r1825991540
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPosition.java:
##
@@ -52,6 +5
hlteoh37 commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#discussion_r1825985227
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/StreamConsumerRegistrar.java:
###
hlteoh37 commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#discussion_r1825983858
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
###
fhueske commented on code in PR #25601:
URL: https://github.com/apache/flink/pull/25601#discussion_r1825949609
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2157,6 +2172,7 @@ ANY, and(logical(LogicalTypeR
[
https://issues.apache.org/jira/browse/FLINK-36650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jerome Gagnon updated FLINK-36650:
--
Description:
When using the {{ConfluentRegistryAvroSerializationSchema}} as the
serialization
[
https://issues.apache.org/jira/browse/FLINK-36650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jerome Gagnon updated FLINK-36650:
--
Description:
When using the {{ConfluentRegistryAvroSerializationSchema}} as the
serialization
tomncooper commented on PR #25600:
URL: https://github.com/apache/flink/pull/25600#issuecomment-2451995434
@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
mxm commented on code in PR #908:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/908#discussion_r1825875810
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/metrics/KubernetesClientMetricsFabric8InterceptorTest.java:
##
@@ -345,6 +3
[
https://issues.apache.org/jira/browse/FLINK-36510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894851#comment-17894851
]
Ferenc Csaky commented on FLINK-36510:
--
I don't think so, we need to double check t
[
https://issues.apache.org/jira/browse/FLINK-36650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jerome Gagnon updated FLINK-36650:
--
Description:
When using the `ConfluentRegistryAvroSerializationSchema{*}`{*} as the
serializa
[
https://issues.apache.org/jira/browse/FLINK-36650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jerome Gagnon updated FLINK-36650:
--
Description:
When using the `ConfluentRegistryAvroSerializationSchema{*}`{*} as the
serializa
[
https://issues.apache.org/jira/browse/FLINK-36650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jerome Gagnon updated FLINK-36650:
--
Description:
When using the `ConfluentRegistryAvroSerializationSchema{*}`{*} as the
serializa
ztison commented on PR #25589:
URL: https://github.com/apache/flink/pull/25589#issuecomment-2451875075
@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
Jerome Gagnon created FLINK-36650:
-
Summary: ConfluentRegistryAvroSerializationSchema always tries to
register the schema on serialize even if it already exists
Key: FLINK-36650
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/FLINK-36460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-36460.
--
Fix Version/s: kubernetes-operator-1.11.0
Resolution: Fixed
merged to main 1a5ee081eef2c8435c94
[
https://issues.apache.org/jira/browse/FLINK-36510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894849#comment-17894849
]
Ufuk Celebi commented on FLINK-36510:
-
[~gracegrimwood] [~fcsaky] Would there be any
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36649:
--
Description:
Oracle When reading via OracleIncrementalSource, the connection is occasionally
closed.
>
morhidi commented on PR #908:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/908#issuecomment-2451817195
cc @mxm @gyfora
--
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 speci
gyfora commented on PR #906:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/906#issuecomment-2451845743
What's the status of this? Could you guys @SamBarker @k-wall sort out the
issues that you have found?
Does this mean that the changes we released in 1.10.0 don't really
[
https://issues.apache.org/jira/browse/FLINK-36460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-36460:
--
Assignee: Sam Barker
> Refactor Kubernetes Operator Edge to Edge test setup
> ---
snuyanzin commented on code in PR #25601:
URL: https://github.com/apache/flink/pull/25601#discussion_r1825795742
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2157,6 +2172,7 @@ ANY, and(logical(LogicalTyp
gyfora merged PR #893:
URL: https://github.com/apache/flink-kubernetes-operator/pull/893
--
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
yuxiqian commented on PR #3680:
URL: https://github.com/apache/flink-cdc/pull/3680#issuecomment-2451780758
Need more eyes on this PR since this PR tweaks schema evolution
communication process. cc @leonardBang @ruanhang1993
--
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36649:
--
Fix Version/s: 3.0.0
> Oracle When reading via OracleIncrementalSource, the connection is
> occasionally clos
beryllw commented on PR #3679:
URL: https://github.com/apache/flink-cdc/pull/3679#issuecomment-2451732788
@yuxiqian @lvyanquan Could you take a quick look and help me review the code?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
snuyanzin commented on PR #25597:
URL: https://github.com/apache/flink/pull/25597#issuecomment-2451715562
@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.
yuxiqian opened a new pull request, #3680:
URL: https://github.com/apache/flink-cdc/pull/3680
This fixes schema operator hanging glitch under extreme parallelized
pressure.
---
Previously, `SchemaOperator`s will ask for schema evolve permission first,
before sending `FlushEven
[
https://issues.apache.org/jira/browse/FLINK-36646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894829#comment-17894829
]
Thomas Cooper commented on FLINK-36646:
---
We could set the {{env.java.default-opts.
RanJinh commented on PR #25594:
URL: https://github.com/apache/flink/pull/25594#issuecomment-2451699694
@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.
hlteoh37 commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#discussion_r1825693268
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -178,6 +18
flinkbot commented on PR #25601:
URL: https://github.com/apache/flink/pull/25601#issuecomment-2451673231
## CI report:
* e49564a2e36a43ac5a3cb4bd64c0470f3ec9c9df UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36642:
---
Labels: pull-request-available (was: )
> Table API expressions with several built-in functi
fhueske opened a new pull request, #25601:
URL: https://github.com/apache/flink/pull/25601
## What is the purpose of the change
Fix the SQL names of several built-in functions.
The names are used to serialize Table API expressions to SQL. Using wrong
function names results in SQL
tomncooper commented on PR #25600:
URL: https://github.com/apache/flink/pull/25600#issuecomment-2451656298
@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-34825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34825:
---
Labels: github-import pull-request-available (was: github-import)
> [flink-cdc-pipeline-con
liboshuai01 commented on PR #146:
URL:
https://github.com/apache/flink-connector-jdbc/pull/146#issuecomment-2451622763
> LGTM, thanks.
Hi, could you please tell me why there are checks errors? Is it because of
the code changes I made this time?
--
This is an automated message from
liboshuai01 commented on PR #146:
URL:
https://github.com/apache/flink-connector-jdbc/pull/146#issuecomment-2451621875
Hi, @reswqa , could you please tell me why there are checks errors? Is it
because of the code changes I made this time?
--
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/FLINK-35862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35862:
--
Assignee: BoShuai Li
> Chinese and English documents are different
>
hlteoh37 commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#discussion_r1825626808
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -178,6 +18
[ https://issues.apache.org/jira/browse/FLINK-35862 ]
BoShuai Li deleted comment on FLINK-35862:
was (Author: JIRAUSER306047):
HI, [~nova], I am a Chinese Speaker and glad to take this work , cloud you
assign this ticket to me?:)
> Chinese and
JNSimba opened a new pull request, #3678:
URL: https://github.com/apache/flink-cdc/pull/3678
https://issues.apache.org/jira/browse/FLINK-36649
--
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
JNSimba commented on PR #3678:
URL: https://github.com/apache/flink-cdc/pull/3678#issuecomment-2451546676
@leonardBang @ruanhang1993 PTAL, Thanks
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-35862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35862:
---
Labels: pull-request-available (was: )
> Chinese and English documents are different
>
boring-cyborg[bot] commented on PR #146:
URL:
https://github.com/apache/flink-connector-jdbc/pull/146#issuecomment-2451531195
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
liboshuai01 opened a new pull request, #146:
URL: https://github.com/apache/flink-connector-jdbc/pull/146
(no comment)
--
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
[
https://issues.apache.org/jira/browse/FLINK-36631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36631:
--
Affects Version/s: cdc-3.1.1
cdc-3.2.0
cdc-3.1.0
Di Wu created FLINK-36649:
-
Summary: Oracle When reading via OracleIncrementalSource, the
connection is occasionally closed
Key: FLINK-36649
URL: https://issues.apache.org/jira/browse/FLINK-36649
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36649:
--
Affects Version/s: cdc-3.1.1
cdc-3.2.0
cdc-3.3.0
> Oracle When r
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36649:
--
Fix Version/s: (was: cdc-3.3.0)
> Oracle When reading via OracleIncrementalSource, the connection is
> oc
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36649:
---
Labels: CDC pull-request-available (was: CDC)
> Oracle When reading via OracleIncrementalSo
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36649:
--
Description:
Oracle When reading via OracleIncrementalSource, the connection is occasionally
closed.
{code
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36649:
--
Fix Version/s: cdc-3.3.0
(was: 3.0.0)
> Oracle When reading via OracleIncrementalSource
[
https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36649:
--
Labels: CDC (was: )
> Oracle When reading via OracleIncrementalSource, the connection is
> occasionally clos
[
https://issues.apache.org/jira/browse/FLINK-35862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894806#comment-17894806
]
liboshuai commented on FLINK-35862:
---
HI, [~nova], I am a Chinese Speaker and glad to t
[
https://issues.apache.org/jira/browse/FLINK-35862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894804#comment-17894804
]
liboshuai commented on FLINK-35862:
---
HI, [~Weijie Guo] ,I am a Chinese Speaker and gl
[
https://issues.apache.org/jira/browse/FLINK-36625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-36625:
---
Assignee: Zhenqiu Huang
> Add helper classes for Lineage integration in connectors
> --
66 matches
Mail list logo
