lihaosky commented on code in PR #26610:
URL: https://github.com/apache/flink/pull/26610#discussion_r2138839903
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1017,6 +1018,139 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{< t
lihaosky commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2138834735
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{< t
flinkbot commented on PR #26667:
URL: https://github.com/apache/flink/pull/26667#issuecomment-2960666813
## CI report:
* b0cc11331bc6fa92542458416e10d7a66ef2a4f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lihaosky opened a new pull request, #26667:
URL: https://github.com/apache/flink/pull/26667
## What is the purpose of the change
Rewrite `ml_evaluate` table function scan to `ml_predict` table function
scan and `LogicalAggreate`
## Brief change log
Rewrite `ml_evalua
nateab opened a new pull request, #2:
URL: https://github.com/apache/flink/pull/2
Seems to be a copy paste typo, this PR correctly specifies the appropriate
config flag `isUnalignedCheckpointsSplittableTimersEnabled`
## What is the purpose of the change
*(For ex
flinkbot commented on PR #2:
URL: https://github.com/apache/flink/pull/2#issuecomment-2960567173
## CI report:
* fed87f6f1bf4b59025a802fba7bed96c65195f3d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
AHeise commented on PR #26656:
URL: https://github.com/apache/flink/pull/26656#issuecomment-2960565318
@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
nateab commented on PR #26609:
URL: https://github.com/apache/flink/pull/26609#issuecomment-2960558345
closing in favor of #2
--
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
nateab closed pull request #26609: [hotfix] Fix typo in
StreamingJobGraphGenerator config
URL: https://github.com/apache/flink/pull/26609
--
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
snuyanzin merged PR #26661:
URL: https://github.com/apache/flink/pull/26661
--
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
dependabot[bot] commented on PR #135:
URL:
https://github.com/apache/flink-connector-kafka/pull/135#issuecomment-2960544541
Superseded by #179.
--
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 th
dependabot[bot] opened a new pull request, #179:
URL: https://github.com/apache/flink-connector-kafka/pull/179
Bumps org.apache.kafka:kafka-clients from 3.9.0 to 3.9.1.
[
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
flinkbot commented on PR #26660:
URL: https://github.com/apache/flink/pull/26660#issuecomment-2959442219
## CI report:
* aeafcc10f0f2dfd484642ac69ac80150edee6840 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
echauchot merged PR #24:
URL: https://github.com/apache/flink-connector-cassandra/pull/24
--
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-unsubsc
1996fanrui opened a new pull request, #26660:
URL: https://github.com/apache/flink/pull/26660
## What is the purpose of the change
[FLINK-35051][checkpoint] Treat handling of unaligned checkpoint barrier as
the high priority mail
## Brief change log
[FLINK-35051][checkpo
iundarigun opened a new pull request, #4042:
URL: https://github.com/apache/flink-cdc/pull/4042
## Description
In the
[documentation](https://nightlies.apache.org/flink/flink-cdc-docs-release-3.1/docs/connectors/flink-sources/postgres-cdc/#data-type-mapping)
doesn't mention a way to map
gyfora merged PR #985:
URL: https://github.com/apache/flink-kubernetes-operator/pull/985
--
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
codenohup commented on code in PR #6:
URL: https://github.com/apache/flink-agents/pull/6#discussion_r2137805325
##
python/flink_agents/api/event.py:
##
@@ -0,0 +1,59 @@
+
+# Licensed to the Apache S
fsk119 merged PR #26653:
URL: https://github.com/apache/flink/pull/26653
--
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.apache
fsk119 commented on PR #26653:
URL: https://github.com/apache/flink/pull/26653#issuecomment-2959001561
All tests pass in my private CI:
https://dev.azure.com/1059623455/Flink/_build/results?buildId=695&view=results
--
This is an automated message from the Apache Git Service.
To respond
codenohup commented on code in PR #6:
URL: https://github.com/apache/flink-agents/pull/6#discussion_r2137739928
##
python/flink_agents/plan/workflow_plan.py:
##
@@ -0,0 +1,51 @@
+
+# Licensed to the
codenohup commented on code in PR #6:
URL: https://github.com/apache/flink-agents/pull/6#discussion_r2137740268
##
python/flink_agents/plan/workflow_plan.py:
##
@@ -0,0 +1,51 @@
+
+# Licensed to the
gustavodemorais commented on code in PR #26647:
URL: https://github.com/apache/flink/pull/26647#discussion_r2137720465
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMultiJoin.java:
##
@@ -39,7 +39,7 @@
import or
gustavodemorais commented on PR #26647:
URL: https://github.com/apache/flink/pull/26647#issuecomment-2958951446
> Thanks for the update. I added some last feedback from my side. Should be
good in the next iteration.
Thanks for the review, @twalthr. Comments have been addressed 🙂
--
Mrart commented on PR #3968:
URL: https://github.com/apache/flink-cdc/pull/3968#issuecomment-2958932494
This version does not support the following：
`
@Experimental
public static final ConfigOption METADATA_LIST =
ConfigOptions.key("metadata.list")
flinkbot commented on PR #26659:
URL: https://github.com/apache/flink/pull/26659#issuecomment-2958890818
## CI report:
* 81bb5bd0645785ae0665782ce433edda1351ce13 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fsk119 opened a new pull request, #26659:
URL: https://github.com/apache/flink/pull/26659
## What is the purpose of the change
*Forbid cdc-stream for ML_PREDICT*
## Brief change log
- *Change the modify kind trait inference logic and throw exception if
inpu
liuyongvs commented on PR #25932:
URL: https://github.com/apache/flink/pull/25932#issuecomment-2958843978
@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 #26658:
URL: https://github.com/apache/flink/pull/26658#issuecomment-2958845554
## CI report:
* a2e2a01176fa526739ceae74d968a4107883e495 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #26658:
URL: https://github.com/apache/flink/pull/26658#discussion_r2137654051
##
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-correlate_1/correlate-with-literal-agg/plan/correlate-with-literal-agg.json:
##
@@ -1,
snuyanzin commented on code in PR #26658:
URL: https://github.com/apache/flink/pull/26658#discussion_r2137654051
##
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-correlate_1/correlate-with-literal-agg/plan/correlate-with-literal-agg.json:
##
@@ -1,
snuyanzin opened a new pull request, #26658:
URL: https://github.com/apache/flink/pull/26658
…stPrograms#CORRELATE_WITH_LITERAL_AGG`
## What is the purpose of the change
The PR is to use `producedBeforeRestore` in
`CorrelateTestPrograms#CORRELATE_WITH_LITERAL_AGG`
si
davidradl commented on code in PR #26651:
URL: https://github.com/apache/flink/pull/26651#discussion_r2137621298
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java:
##
@@ -299,6 +292,56 @@ private StateTable tryRegisterStateTable(
davidradl commented on code in PR #26651:
URL: https://github.com/apache/flink/pull/26651#discussion_r2137619890
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java:
##
@@ -259,17 +261,8 @@ private StateTable tryRegisterStateTable(
davidradl commented on code in PR #26651:
URL: https://github.com/apache/flink/pull/26651#discussion_r2137625070
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java:
##
@@ -142,6 +145,34 @@ public byte[] getSerializedValue(
return baos.
lincoln-lil commented on code in PR #26648:
URL: https://github.com/apache/flink/pull/26648#discussion_r2137376644
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala:
##
@@ -69,6 +69,9 @@ class
HuangXingBo commented on code in PR #6:
URL: https://github.com/apache/flink-agents/pull/6#discussion_r2137370961
##
python/requirements/build_requirements.txt:
##
@@ -13,3 +13,4 @@
# See the License for the specific language governing permissions and
# limitations under the L
davidradl commented on code in PR #26651:
URL: https://github.com/apache/flink/pull/26651#discussion_r2137617241
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java:
##
@@ -212,7 +214,7 @@ private StateTable tryRegisterStateTable(
davidradl commented on code in PR #26651:
URL: https://github.com/apache/flink/pull/26651#discussion_r2137615225
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapState.java:
##
@@ -112,6 +115,29 @@ public byte[] getSerializedValue(
return K
echauchot commented on code in PR #33:
URL:
https://github.com/apache/flink-connector-cassandra/pull/33#discussion_r2137609420
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/source/reader/CassandraQueryTest.java:
##
@@ -39,7 +39,8 @@ public void
linjianchang opened a new pull request, #4041:
URL: https://github.com/apache/flink-cdc/pull/4041
[FLINK-37934][cdc-source-connectors] Get the case-sensitive variable names
and method names of table id are not standardized, and need to be adjusted
--
This is an automated message from the
twalthr commented on code in PR #26647:
URL: https://github.com/apache/flink/pull/26647#discussion_r2137507998
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMultiJoin.java:
##
@@ -0,0 +1,444 @@
+/*
+ * Licensed t
echauchot commented on PR #33:
URL:
https://github.com/apache/flink-connector-cassandra/pull/33#issuecomment-2958610829
Thanks @maciejbak85 for this fix. Reviewing
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
chenyuzhi459 commented on PR #956:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2958555002
I have changed the default value of new param `flink.client.io.threads` to
10.
--
This is an automated message from the Apache Git Service.
To respond to the messa
snuyanzin commented on code in PR #26657:
URL: https://github.com/apache/flink/pull/26657#discussion_r2137517172
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalWindowTableFunction.scala:
##
@@ -67,4 +67,8 @@ abstr
davidradl commented on code in PR #26657:
URL: https://github.com/apache/flink/pull/26657#discussion_r2137507579
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalWindowTableFunction.scala:
##
@@ -67,4 +67,8 @@ abstr
twalthr commented on code in PR #26655:
URL: https://github.com/apache/flink/pull/26655#discussion_r2137336904
##
flink-core/src/main/java/org/apache/flink/types/variant/BinaryVariant.java:
##
@@ -0,0 +1,490 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+
flinkbot commented on PR #26657:
URL: https://github.com/apache/flink/pull/26657#issuecomment-2958546232
## CI report:
* 0d5e5dff4070ad16757dea232000a9df3d10e6d3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin opened a new pull request, #26657:
URL: https://github.com/apache/flink/pull/26657
## What is the purpose of the change
it allows to read `WindowingStrategy` by downstream projects from
`CommonPhysicalWindowTableFunction`
## Verifying this change
T
flinkbot commented on PR #26656:
URL: https://github.com/apache/flink/pull/26656#issuecomment-2958424064
## CI report:
* 974a1d4133d9331cadc7cc47052b87b3371a38d5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
AHeise opened a new pull request, #26656:
URL: https://github.com/apache/flink/pull/26656
## What is the purpose of the change
Although TransformationScan/SinkProvider is an expert API, it's buried
inside planner and not easily usable. Move up to table-common to make i
fsk119 commented on PR #26653:
URL: https://github.com/apache/flink/pull/26653#issuecomment-2958357039
The current implementation has some room for improvement, and further
cleanup will be addressed in subsequent PRs.
--
This is an automated message from the Apache Git Service.
To respond
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137334440
##
flink-table/flink-table-common/src/test/java/org/apache/flink/table/catalog/CatalogPropertiesUtilTest.java:
##
@@ -111,7 +111,8 @@ public void testCatalogTableSerde
fsk119 commented on PR #26641:
URL: https://github.com/apache/flink/pull/26641#issuecomment-2958261132
All tests passes in my private CI pipeline:
https://dev.azure.com/1059623455/Flink/_build/results?buildId=694&view=logs&j=0e31ee24-31a6-528c-a4bf-45cde9b2a14e
Merging...
--
This i
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137331214
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ResolvedCatalogTableSerdeTest.java:
##
@@ -93,7 +93,8 @@ class Re
xuyangzhong commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2136986005
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1881,7 +1881,8 @@ public ResolvedCatalogView resolveCat
fsk119 merged PR #26641:
URL: https://github.com/apache/flink/pull/26641
--
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.apache
mxm commented on code in PR #26640:
URL: https://github.com/apache/flink/pull/26640#discussion_r2137165179
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBStateUploader.java:
##
@@ -180,6 +188,14 @@ private HandleAndLocalPat
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137082099
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Index.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Mrart commented on code in PR #3968:
URL: https://github.com/apache/flink-cdc/pull/3968#discussion_r2137213628
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDataSourceOptions
gustavodemorais commented on code in PR #26647:
URL: https://github.com/apache/flink/pull/26647#discussion_r2135285367
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ExecNodeMultiJoinJsonSerdeTest.java:
##
@@ -0,0 +1,181 @@
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137103530
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java:
##
@@ -126,7 +127,8 @@ public static ResolvedSchema
removeTimeAttr
xishuaidelin commented on code in PR #26617:
URL: https://github.com/apache/flink/pull/26617#discussion_r2135584738
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/keyordered/Epoch.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed
twalthr merged PR #26638:
URL: https://github.com/apache/flink/pull/26638
--
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.apach
wenjin272 opened a new pull request, #6:
URL: https://github.com/apache/flink-agents/pull/6
This pr import the core concepts Event and Action to Flink-Agents, and
import Function which is the dependency of Action. Based on these concepts, we
import WorkflowPlan, and add a simplest test case
yanand0909 commented on PR #26385:
URL: https://github.com/apache/flink/pull/26385#issuecomment-2958116097
@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 PR #26647:
URL: https://github.com/apache/flink/pull/26647#issuecomment-2958050761
I've addressed your feedback, @snuyanzin. Please take a look :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
Mrart commented on code in PR #3968:
URL: https://github.com/apache/flink-cdc/pull/3968#discussion_r2137213628
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDataSourceOptions
liuyongvs commented on code in PR #25932:
URL: https://github.com/apache/flink/pull/25932#discussion_r2137156123
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/WindowJoinTest.xml:
##
@@ -199,35 +199,19 @@
LogicalSink(ta
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137089118
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/Schema.java:
##
@@ -1043,4 +1126,53 @@ public int hashCode() {
return Objects.h
HuangXingBo merged PR #5:
URL: https://github.com/apache/flink-agents/pull/5
--
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
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137108152
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ResolvedCatalogTableSerdeTest.java:
##
@@ -93,7 +93,8 @@ class Re
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137101717
##
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TableSchemaUtilsTest.java:
##
@@ -101,7 +101,8 @@ void testRemoveTimeAttribute() {
lvyanquan commented on code in PR #3968:
URL: https://github.com/apache/flink-cdc/pull/3968#discussion_r2136976198
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDataSourceOpt
GOODBOY008 merged PR #4037:
URL: https://github.com/apache/flink-cdc/pull/4037
--
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.
Au-Miner commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2137076110
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1881,7 +1881,8 @@ public ResolvedCatalogView resolveCatalo
Mrart commented on PR #3968:
URL: https://github.com/apache/flink-cdc/pull/3968#issuecomment-2957903623
@lvyanquan Can we support map type in another pr？It is too many code in
this pr.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
1 - 100 of 10909 matches
Mail list logo
