[
https://issues.apache.org/jira/browse/FLINK-31436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31436:
---
Labels: pull-request-available (was: )
> Remove schemaId from constructor of
[
https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699962#comment-17699962
]
Zhimin Geng commented on FLINK-31437:
-
ok
> 'lookup.cache.caching-missing-key' change should be
tsreaper opened a new pull request, #598:
URL: https://github.com/apache/flink-table-store/pull/598
As schema may change during a CTAS streaming job, the schema ID of snapshots
and manifest files may also change. We should remove `schemaId` from their
constructor and calculate the real
[
https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699960#comment-17699960
]
Junrui Li commented on FLINK-31437:
---
[~gaara] Thanks for creating this issue, and
[
https://issues.apache.org/jira/browse/FLINK-31436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-31436:
Summary: Remove schemaId from constructor of FileStoreCommitImpl and
ManifestFile in Table Store
Zhimin Geng created FLINK-31437:
---
Summary: 'lookup.cache.caching-missing-key' change should be
configured as 'lookup.partial-cache.caching-missing-key'
Key: FLINK-31437
URL:
liuyongvs commented on code in PR #22144:
URL: https://github.com/apache/flink/pull/22144#discussion_r1135000970
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -178,6 +181,137 @@ Stream
liuyongvs commented on code in PR #22144:
URL: https://github.com/apache/flink/pull/22144#discussion_r1135001220
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -178,6 +181,137 @@ Stream
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699956#comment-17699956
]
jinghaihang commented on FLINK-30863:
-
More to the point, I'm also confused about whether it's
Caizhi Weng created FLINK-31436:
---
Summary: Remove schemaId from constructor of Snapshot and
ManifestFile in Table Store
Key: FLINK-31436
URL: https://issues.apache.org/jira/browse/FLINK-31436
Project:
liuyongvs commented on code in PR #22144:
URL: https://github.com/apache/flink/pull/22144#discussion_r1134999542
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayRemoveFunction.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699955#comment-17699955
]
Zhu Zhu edited comment on FLINK-31144 at 3/14/23 5:41 AM:
--
IIRC, the
[
https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699955#comment-17699955
]
Zhu Zhu commented on FLINK-31144:
-
IIRC, the parallelism of that benchmark job is 4000, which is
swuferhong commented on code in PR #22049:
URL: https://github.com/apache/flink/pull/22049#discussion_r1134947973
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -386,6 +387,21 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-30748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-30748.
---
Fix Version/s: 1.18.0
Assignee: chenhaiyang
Resolution: Fixed
Fixed in master:
wuchong merged PR #21726:
URL: https://github.com/apache/flink/pull/21726
--
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:
[
https://issues.apache.org/jira/browse/FLINK-30694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-30694.
---
Fix Version/s: 1.18.0
(was: 1.16.2)
Resolution: Fixed
Fixed in master:
wuchong merged PR #21823:
URL: https://github.com/apache/flink/pull/21823
--
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:
WencongLiu commented on PR #21645:
URL: https://github.com/apache/flink/pull/21645#issuecomment-1467302863
@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
[
https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699929#comment-17699929
]
Jane Chan commented on FLINK-26051:
---
[~KristoffSC], Sorry for the late reply. Feel free to go ahead.
[
https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699930#comment-17699930
]
Yuxin Tan commented on FLINK-31418:
---
I have created a PR for master and 1.17, could you help take a
godfreyhe commented on code in PR #22049:
URL: https://github.com/apache/flink/pull/22049#discussion_r1134883506
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -386,6 +387,21 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699928#comment-17699928
]
Feifan Wang commented on FLINK-31414:
-
Thanks for reply [~pnowojski] , sorry for the lack of clarity
zhuangchong opened a new pull request, #597:
URL: https://github.com/apache/flink-table-store/pull/597
Change the variable name `sekableInputStream` to `seekableInputStream`
--
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-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-31418:
---
Assignee: Yuxin Tan
> SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout
[
https://issues.apache.org/jira/browse/FLINK-31425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699925#comment-17699925
]
Junrui Li commented on FLINK-31425:
---
[~tophei] Thanks for creating this issue. IIUC, according to the
JingsongLi merged PR #594:
URL: https://github.com/apache/flink-table-store/pull/594
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31397.
Resolution: Fixed
master: 0f5744a92bc52f52bc0f6644dc063dcb60fe326c
> Introduce write-once hash
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699920#comment-17699920
]
jinghaihang edited comment on FLINK-30863 at 3/14/23 3:16 AM:
--
[~Yanfei
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699920#comment-17699920
]
jinghaihang commented on FLINK-30863:
-
[~Yanfei Lei] Thanks for your reply.
I don't think the
JingsongLi merged PR #593:
URL: https://github.com/apache/flink-table-store/pull/593
--
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:
Caizhi Weng created FLINK-31435:
---
Summary: Introduce event parser for MySql Debezium JSON format in
Table Store
Key: FLINK-31435
URL: https://issues.apache.org/jira/browse/FLINK-31435
Project: Flink
Caizhi Weng created FLINK-31434:
---
Summary: Introduce CDC sink for Table Store
Key: FLINK-31434
URL: https://issues.apache.org/jira/browse/FLINK-31434
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #22173:
URL: https://github.com/apache/flink/pull/22173#issuecomment-1467279898
## CI report:
* 9cff66bb2cf991967633d0b3aa88377224085b9f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Caizhi Weng created FLINK-31433:
---
Summary: Make SchemaChange serializable
Key: FLINK-31433
URL: https://issues.apache.org/jira/browse/FLINK-31433
Project: Flink
Issue Type: Sub-task
syhily commented on PR #35:
URL:
https://github.com/apache/flink-connector-pulsar/pull/35#issuecomment-1467278411
@reswqa Can you help me review 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
Caizhi Weng created FLINK-31432:
---
Summary: Introduce a special StoreWriteOperator to deal with
schema changes
Key: FLINK-31432
URL: https://issues.apache.org/jira/browse/FLINK-31432
Project: Flink
TanYuxin-tyx opened a new pull request, #22173:
URL: https://github.com/apache/flink/pull/22173
## What is the purpose of the change
*Fix buffer request timeout for sort merge result partition read test*
## Brief change log
*(for example:)*
- *Fix buffer
[
https://issues.apache.org/jira/browse/FLINK-31427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31427:
--
Assignee: Yufan Sheng
> Pulsar Catalog support with Schema translation
>
Caizhi Weng created FLINK-31431:
---
Summary: Support copying a FileStoreTable with latest schema
Key: FLINK-31431
URL: https://issues.apache.org/jira/browse/FLINK-31431
Project: Flink
Issue
flinkbot commented on PR #22172:
URL: https://github.com/apache/flink/pull/22172#issuecomment-1467272865
## CI report:
* 4438179c6b2181fcaec452f16a52a2b9033dc706 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Caizhi Weng created FLINK-31430:
---
Summary: Support migrating states between different instances of
TableWriteImpl and AbstractFileStoreWrite
Key: FLINK-31430
URL: https://issues.apache.org/jira/browse/FLINK-31430
Caizhi Weng created FLINK-31429:
---
Summary: Support CTAS(create table as) streaming job with schema
changes in table store
Key: FLINK-31429
URL: https://issues.apache.org/jira/browse/FLINK-31429
[
https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31418:
---
Labels: pull-request-available (was: )
>
TanYuxin-tyx opened a new pull request, #22172:
URL: https://github.com/apache/flink/pull/22172
## What is the purpose of the change
*Fix buffer request timeout for sort merge result partition read test*
## Brief change log
*(for example:)*
- *Fix buffer
[
https://issues.apache.org/jira/browse/FLINK-31269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-31269.
---
Assignee: Shammon
Resolution: Fixed
master: dd2d600f6743ca074a023fdbb1a7a2cbcfbf8ff0
> Split
[
https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699913#comment-17699913
]
Yingjie Cao commented on FLINK-31418:
-
It is a test issue, we will fix it soon.
>
tsreaper merged PR #569:
URL: https://github.com/apache/flink-table-store/pull/569
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699911#comment-17699911
]
Qingsheng Ren commented on FLINK-31418:
---
Thanks for the feedback [~kevin.cyj]. I'll downgrade this
[
https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-31418:
--
Priority: Critical (was: Blocker)
>
wuchong commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1134831904
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java:
##
@@ -763,7 +783,7 @@ CatalogBaseTable
Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1134809157
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java:
##
@@ -157,12 +165,12 @@ public static Operation
[
https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699901#comment-17699901
]
Yufan Sheng commented on FLINK-31428:
-
I see, the ser/deser issue matters. You want to intercept
Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1134803012
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java:
##
@@ -69,67 +69,75 @@ private
[
https://issues.apache.org/jira/browse/FLINK-31413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-31413:
Assignee: luoyuxia
> Remove provided dependency of flink-table-planner from Hive connector
>
[
https://issues.apache.org/jira/browse/FLINK-30659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-30659:
Assignee: luoyuxia
> drop flink-sql-parser-hive
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-31409:
Assignee: luoyuxia
> Hive dialect should use public interfaces in Hive connector
>
[
https://issues.apache.org/jira/browse/FLINK-17398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-17398:
Assignee: Hang Ruan (was: luoyuxia)
> Filesystem support flexible path reading
>
swuferhong commented on code in PR #22049:
URL: https://github.com/apache/flink/pull/22049#discussion_r1134791918
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -386,6 +387,21 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31415.
Fix Version/s: table-store-0.4.0
Assignee: yuzelin
Resolution: Fixed
master:
JingsongLi merged PR #596:
URL: https://github.com/apache/flink-table-store/pull/596
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699896#comment-17699896
]
Yufan Sheng commented on FLINK-31371:
-
Can we change this JIRA into a feature request with a new
herunkang2018 commented on code in PR #22049:
URL: https://github.com/apache/flink/pull/22049#discussion_r1134786876
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -386,6 +387,21 @@ private void
JingsongLi commented on code in PR #594:
URL: https://github.com/apache/flink-table-store/pull/594#discussion_r1134786122
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/aggregate/AggregateMergeFunction.java:
##
@@ -172,10 +133,30 @@
JingsongLi commented on code in PR #594:
URL: https://github.com/apache/flink-table-store/pull/594#discussion_r1134784531
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/ForceUpLevel0Compaction.java:
##
@@ -0,0 +1,59 @@
+/*
+ *
JingsongLi commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134777880
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/hash/HashLookupStoreWriter.java:
##
@@ -0,0 +1,486 @@
+/*
+ * Licensed to the
JingsongLi commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134777430
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/hash/HashLookupStoreWriter.java:
##
@@ -0,0 +1,486 @@
+/*
+ * Licensed to the
JingsongLi commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134775901
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/hash/HashLookupStoreWriter.java:
##
@@ -0,0 +1,486 @@
+/*
+ * Licensed to the
liujiawinds commented on PR #19844:
URL: https://github.com/apache/flink/pull/19844#issuecomment-1467197335
@pgaref Feel free to take over this.
--
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
lindong28 commented on PR #224:
URL: https://github.com/apache/flink-ml/pull/224#issuecomment-1467184153
@alberta0714 Thanks for creating this PR. Could you explain how to reproduce
the error "failed to extract shortcode"? We can add a test to catch issues like
this in the future if we can
SteNicholas commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134714232
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/utils/SimpleReadBuffer.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Copyright 2015 LinkedIn
SteNicholas commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134713621
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/hash/HashLookupStoreWriter.java:
##
@@ -0,0 +1,486 @@
+/*
+ * Licensed to the
SteNicholas commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134711088
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/hash/HashLookupStoreWriter.java:
##
@@ -0,0 +1,486 @@
+/*
+ * Licensed to the
SteNicholas commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134708812
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/hash/HashLookupStoreWriter.java:
##
@@ -0,0 +1,486 @@
+/*
+ * Licensed to the
SteNicholas commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134702880
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/LookupStoreReader.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache
SteNicholas commented on code in PR #593:
URL: https://github.com/apache/flink-table-store/pull/593#discussion_r1134703041
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/lookup/LookupStoreWriter.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache
SteNicholas commented on code in PR #594:
URL: https://github.com/apache/flink-table-store/pull/594#discussion_r1134698287
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/aggregate/AggregateMergeFunction.java:
##
@@ -172,10 +133,30 @@
SteNicholas commented on code in PR #594:
URL: https://github.com/apache/flink-table-store/pull/594#discussion_r1134693522
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/LookupMergeFunction.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed
SteNicholas commented on code in PR #594:
URL: https://github.com/apache/flink-table-store/pull/594#discussion_r1134691216
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/LookupChangelogMergeFunctionWrapper.java:
##
@@ -0,0 +1,142 @@
SteNicholas commented on code in PR #594:
URL: https://github.com/apache/flink-table-store/pull/594#discussion_r1134689986
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/ForceUpLevel0Compaction.java:
##
@@ -0,0 +1,59 @@
+/*
+ *
SteNicholas commented on code in PR #594:
URL: https://github.com/apache/flink-table-store/pull/594#discussion_r1134689986
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/ForceUpLevel0Compaction.java:
##
@@ -0,0 +1,59 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-31369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699863#comment-17699863
]
Sergey Nuyanzin commented on FLINK-31369:
-
Merged at:
[
https://issues.apache.org/jira/browse/FLINK-31369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-31369.
-
Fix Version/s: 1.18.0
Resolution: Fixed
> Harden modifiers for sql-gateway
snuyanzin merged PR #22135:
URL: https://github.com/apache/flink/pull/22135
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-31369:
---
Assignee: Sergey Nuyanzin
> Harden modifiers for sql-gateway module
>
mbalassi commented on code in PR #548:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/548#discussion_r1134642722
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/Fabric8FlinkStandaloneKubeClient.java:
##
@@ -57,14
[
https://issues.apache.org/jira/browse/FLINK-31407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31407:
---
Labels: pull-request-available (was: )
> Upgrade Fabric8 version to 6.5.0
>
mbalassi opened a new pull request, #548:
URL: https://github.com/apache/flink-kubernetes-operator/pull/548
This new version brings critical stability fixes for the informers. I fixed
the newly introduced deprecation warnings.
--
This is an automated message from the Apache Git Service.
pgaref commented on PR #19844:
URL: https://github.com/apache/flink/pull/19844#issuecomment-1466980765
@liujiawinds are you still working on this one?
--
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
snuyanzin commented on code in PR #22144:
URL: https://github.com/apache/flink/pull/22144#discussion_r1134628496
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -178,6 +181,137 @@ Stream
[
https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alpha Diallo updated FLINK-31428:
-
Description:
We'd like to add support for user callbacks in {{PulsarSource}} and
Alpha Diallo created FLINK-31428:
Summary: Add user callbacks to PulsarSource and PulsarSink
Key: FLINK-31428
URL: https://issues.apache.org/jira/browse/FLINK-31428
Project: Flink
Issue
snuyanzin commented on code in PR #22144:
URL: https://github.com/apache/flink/pull/22144#discussion_r1134622026
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayRemoveFunction.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to
pgaref commented on code in PR #22153:
URL: https://github.com/apache/flink/pull/22153#discussion_r1134608280
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobResourceRequirements.java:
##
@@ -0,0 +1,222 @@
+/*
+ * Licensed to the Apache Software Foundation
pgaref commented on code in PR #22153:
URL: https://github.com/apache/flink/pull/22153#discussion_r1134606959
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobResourceRequirements.java:
##
@@ -0,0 +1,222 @@
+/*
+ * Licensed to the Apache Software Foundation
pgaref commented on code in PR #22153:
URL: https://github.com/apache/flink/pull/22153#discussion_r1134587834
##
flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java:
##
@@ -466,6 +468,7 @@ public static String checkForInstantiationError(Class
clazz) {
[
https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699824#comment-17699824
]
Enzo Dechaene commented on FLINK-31371:
---
Hi [~syhily], yes, it makes sense to do it that way
[
https://issues.apache.org/jira/browse/FLINK-31427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31427:
---
Labels: pull-request-available (was: )
> Pulsar Catalog support with Schema translation
>
syhily opened a new pull request, #35:
URL: https://github.com/apache/flink-connector-pulsar/pull/35
## Purpose of the change
This PR will make the Pulsar serve as the Flink catalog backend. It will
expose the Pulsar's namespace as the Flink's database, the Pulsar's topic as
the
[
https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699776#comment-17699776
]
Piotr Nowojski commented on FLINK-31414:
[~Feifan Wang], can you elaborate a bit more what's the
1 - 100 of 275 matches
Mail list logo