gustavodemorais commented on code in PR #26091:
URL: https://github.com/apache/flink/pull/26091#discussion_r1935623598
##
docs/data/sql_functions.yml:
##
@@ -241,9 +241,9 @@ arithmetic:
- sql: UNHEX(expr)
table: expr.unhex()
description: |
- Converts hexadecima
flinkbot commented on PR #26091:
URL: https://github.com/apache/flink/pull/26091#issuecomment-2624521308
## CI report:
* 3c08458ae0d1f748c97444e16e4fc34769823d64 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gustavodemorais commented on code in PR #26091:
URL: https://github.com/apache/flink/pull/26091#discussion_r1935601554
##
docs/data/sql_functions.yml:
##
@@ -241,9 +241,9 @@ arithmetic:
- sql: UNHEX(expr)
table: expr.unhex()
description: |
- Converts hexadecima
gustavodemorais commented on code in PR #26091:
URL: https://github.com/apache/flink/pull/26091#discussion_r1935601554
##
docs/data/sql_functions.yml:
##
@@ -241,9 +241,9 @@ arithmetic:
- sql: UNHEX(expr)
table: expr.unhex()
description: |
- Converts hexadecima
snuyanzin commented on code in PR #26091:
URL: https://github.com/apache/flink/pull/26091#discussion_r1935576588
##
docs/data/sql_functions.yml:
##
@@ -241,9 +241,9 @@ arithmetic:
- sql: UNHEX(expr)
table: expr.unhex()
description: |
- Converts hexadecimal stri
gustavodemorais opened a new pull request, #26091:
URL: https://github.com/apache/flink/pull/26091
## What is the purpose of the change
We currently have no examples for some functions in the documentation. 5
examples of these are unhex, btrim, percentile, translate and ETL. These
davidradl commented on PR #18267:
URL: https://github.com/apache/flink/pull/18267#issuecomment-2624407560
@ashulin are you able to make the requested changes ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
davidradl commented on PR #26080:
URL: https://github.com/apache/flink/pull/26080#issuecomment-2624247899
Reviewed by Chi on 30/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #26090:
URL: https://github.com/apache/flink/pull/26090#issuecomment-2624254358
Reviewed by Chi on 30/01/2025 Dependabot change requires notice - raise a
separate Jira and PR so the impact can be properly assessed
The Hive connector is now in an external rep
davidradl commented on PR #26089:
URL: https://github.com/apache/flink/pull/26089#issuecomment-2624250766
Reviewed by Chi on 30/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #26083:
URL: https://github.com/apache/flink/pull/26083#issuecomment-2624249127
Reviewed by Chi on 30/01/2025 Approve - looking for committer to merge
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
davidradl commented on PR #26082:
URL: https://github.com/apache/flink/pull/26082#issuecomment-2624248354
Reviewed by Chi on 30/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
ferenc-csaky merged PR #7:
URL: https://github.com/apache/flink-connector-kudu/pull/7
--
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...
gyfora opened a new pull request, #938:
URL: https://github.com/apache/flink-kubernetes-operator/pull/938
## What is the purpose of the change
This PR adds support for the 2.0 preview release of Flink. As a necessary
prerequisite it also includes a bumping of the operator Flink depend
yoheimuta commented on PR #3876:
URL: https://github.com/apache/flink-cdc/pull/3876#issuecomment-2623409206
@leonardBang Two tests failed:
- **[Unit Tests (MySQL) / compile_and_test (8,
generic)](https://github.com/apache/flink-cdc/actions/runs/12902800573/job/3636684?pr=3876#logs
yoheimuta commented on PR #3876:
URL: https://github.com/apache/flink-cdc/pull/3876#issuecomment-2623408027
Two tests failed:
- **[Unit Tests (MySQL) / compile_and_test (8,
generic)](https://github.com/apache/flink-cdc/actions/runs/12902800573/job/3636684?pr=3876#logs)**
-
flinkbot commented on PR #26090:
URL: https://github.com/apache/flink/pull/26090#issuecomment-2622674511
## CI report:
* 73d5c097987f5c48642c5fc53f1a977f9506028b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #26090:
URL: https://github.com/apache/flink/pull/26090
Bumps org.apache.hive:hive-exec from 2.3.10 to 4.0.1.
[
--
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 unsubscrib
afedulov opened a new pull request, #771:
URL: https://github.com/apache/flink-web/pull/771
(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 unsubscribe, e-m
afedulov commented on PR #26087:
URL: https://github.com/apache/flink/pull/26087#issuecomment-2619236653
@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.
afedulov commented on PR #26087:
URL: https://github.com/apache/flink/pull/26087#issuecomment-2618812801
@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.
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1932025118
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2819,6 +2819,15 @@ ANY, and(logical(Log
dianfu commented on PR #26058:
URL: https://github.com/apache/flink/pull/26058#issuecomment-2618774065
@davidradl Thanks for the comments. It's very difficult to add unit test for
this. Besides, it's an inner behavior of Beam and I don't think we should test
for it. It should happen very ra
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1931805263
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2819,6 +2819,15 @@ ANY, and(logical(Log
gyfora merged PR #937:
URL: https://github.com/apache/flink-kubernetes-operator/pull/937
--
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
Jam804 commented on PR #26039:
URL: https://github.com/apache/flink/pull/26039#issuecomment-2618589964
PTAL, Please @Zakelly
--
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.
Jam804 commented on PR #26039:
URL: https://github.com/apache/flink/pull/26039#issuecomment-2618481207
PTAL，Please @XComp
--
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
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1931805263
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2819,6 +2819,15 @@ ANY, and(logical(Log
twalthr commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1931694563
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2819,6 +2819,15 @@ ANY, and(logical(LogicalType
twalthr commented on PR #26022:
URL: https://github.com/apache/flink/pull/26022#issuecomment-2618168026
> why do we need a new function when we can already do this with
json_object? Or am I missing something?
@davidradl In many cases, JSON is generated by external systems and already
wangqinghuan commented on PR #3898:
URL: https://github.com/apache/flink-cdc/pull/3898#issuecomment-2618098157
There is another open pr(https://github.com/apache/flink-cdc/pull/3535) but
it's not updated. So I created a new PR to i mplement e2e test for
Elasticsearch Sink. Could you review
wangqinghuan opened a new pull request, #3898:
URL: https://github.com/apache/flink-cdc/pull/3898
(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 unsubscrib
dianfu commented on PR #26008:
URL: https://github.com/apache/flink/pull/26008#issuecomment-2618040496
Will wait to see if @davidradl has other comments before merging the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
dianfu commented on PR #26008:
URL: https://github.com/apache/flink/pull/26008#issuecomment-2618037911
@mina-asham Thanks for the update. LGTM.
--
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
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1931388443
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
showuon commented on code in PR #26003:
URL: https://github.com/apache/flink/pull/26003#discussion_r1931354609
##
flink-runtime/src/test/java/org/apache/flink/runtime/memory/MemoryManagerConcurrentModReleaseTest.java:
##
@@ -97,6 +101,12 @@ public void run() {
t
st3w4r commented on PR #47:
URL: https://github.com/apache/flink-playgrounds/pull/47#issuecomment-2616688861
Thanks for the fix! I’ve tried it, and it’s working.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ferenc-csaky merged PR #6:
URL: https://github.com/apache/flink-connector-kudu/pull/6
--
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...
github-actions[bot] commented on PR #19537:
URL: https://github.com/apache/flink/pull/19537#issuecomment-2616537324
This PR is being marked as stale since it has not had any activity in the
last 180 days.
If you would like to keep this PR alive, please leave a comment asking for a
revie
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1928817518
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2819,6 +2819,15 @@ ANY, and(logical(Log
XComp commented on PR #26084:
URL: https://github.com/apache/flink/pull/26084#issuecomment-2616475204
Closing this one because my initial approach with just adding the shutdown
logic doesn't work because we're running the code on the TaskManager.
--
This is an automated message from the A
XComp closed pull request #26084: [FLINK-37220][connector-api] Deprecates
RateLimiterStrategy#perSecond and introduces PerSecondRateLimiterStrategy to
fix thread leakage and intro
URL: https://github.com/apache/flink/pull/26084
--
This is an automated message from the Apache Git Service.
To
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1930922052
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/JsonFunction.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1930899164
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala:
##
@@ -476,6 +485,11 @@ class ExprCodeGenerato
ferenc-csaky opened a new pull request, #6:
URL: https://github.com/apache/flink-connector-kudu/pull/6
Relevant changes:
- removed `kudu` prefix from table option keys
- added `sink` prefix for relevant table options
- adapted tests
I will handle the documentation in a differe
afedulov merged PR #26085:
URL: https://github.com/apache/flink/pull/26085
--
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.apac
XComp commented on PR #26084:
URL: https://github.com/apache/flink/pull/26084#issuecomment-2616346713
> I suggest changing the [datagen
documentation](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/datagen/#rate-limiting)
so it refers to the preferred rate l
flinkbot commented on PR #26087:
URL: https://github.com/apache/flink/pull/26087#issuecomment-2616319817
## CI report:
* 3df83b77b6d1579ee3dbcf2b5fc59eadeb74fa32 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on code in PR #26084:
URL: https://github.com/apache/flink/pull/26084#discussion_r1930826627
##
flink-core/src/main/java/org/apache/flink/api/connector/source/util/ratelimit/RateLimiterStrategy.java:
##
@@ -42,9 +43,14 @@ public interface RateLimiterStrategy exte
autophagy commented on PR #26065:
URL: https://github.com/apache/flink/pull/26065#issuecomment-2616161221
@dawidwys I will take a look!
--
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 specifi
flinkbot commented on PR #26086:
URL: https://github.com/apache/flink/pull/26086#issuecomment-2616049425
## CI report:
* 3485b71667f78324fb820a5f19f9a00e3d0452f6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jam804 commented on PR #26039:
URL: https://github.com/apache/flink/pull/26039#issuecomment-2615973030
PTAL, Please. @alpinegizmo
--
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
alpinegizmo merged PR #26077:
URL: https://github.com/apache/flink/pull/26077
--
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.a
XComp opened a new pull request, #26086:
URL: https://github.com/apache/flink/pull/26086
## What is the purpose of the change
Refactors test to use proper Executor (rather than `directExecutor`). This
allows for callbacks to be scheduled on the main thread in production code.
#
sn-12-3 commented on PR #25528:
URL: https://github.com/apache/flink/pull/25528#issuecomment-2615906024
@xuyangzhong , @davidradl , Gentle reminder.
--
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 t
RocMarshal commented on PR #26083:
URL: https://github.com/apache/flink/pull/26083#issuecomment-2615838674
hi, @AHeise ,Could you help take a look if you had the free time ? Thank a
lot!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
flinkbot commented on PR #26085:
URL: https://github.com/apache/flink/pull/26085#issuecomment-2615719996
## CI report:
* baa83ba077e59a13a4c7b51cdc6786d72bba05c4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on PR #26080:
URL: https://github.com/apache/flink/pull/26080#issuecomment-2615673968
From the discussion in the Jira it seems like this change was for Python
datastream. I think introducing a Python raw format to Python would be more
consistent with the way Java impleme
dawidwys opened a new pull request, #26085:
URL: https://github.com/apache/flink/pull/26085
Since I can not reproduce the original problem. Do you mind checking if this
makes the trick @afedulov ?
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
mxm commented on PR #21008:
URL: https://github.com/apache/flink/pull/21008#issuecomment-2615632983
Closing because there doesn't seem to be an appetite for this feature.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
mxm closed pull request #21008: [FLINK-29571] Support Map
ConfigOptions
URL: https://github.com/apache/flink/pull/21008
--
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 unsu
davidradl commented on code in PR #26084:
URL: https://github.com/apache/flink/pull/26084#discussion_r1930448042
##
flink-core/src/main/java/org/apache/flink/api/connector/source/util/ratelimit/RateLimiterStrategy.java:
##
@@ -42,9 +43,14 @@ public interface RateLimiterStrategy
1 - 100 of 9251 matches
Mail list logo
