[
https://issues.apache.org/jira/browse/FLINK-28257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28257:
---
Labels: pull-request-available (was: )
> Replace ValueKind to RowKind in table store
>
JingsongLi opened a new pull request, #176:
URL: https://github.com/apache/flink-table-store/pull/176
In [FLINK-28244](https://issues.apache.org/jira/browse/FLINK-28244)
We need store changelog of a table, the row kind should contains
UPDATE_BEFORE and UPDATE_AFTER, but if we use ValueKin
Jingsong Lee created FLINK-28257:
Summary: Replace ValueKind to RowKind in table store
Key: FLINK-28257
URL: https://issues.apache.org/jira/browse/FLINK-28257
Project: Flink
Issue Type: New F
[
https://issues.apache.org/jira/browse/FLINK-28257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28257:
-
Issue Type: Improvement (was: New Feature)
> Replace ValueKind to RowKind in table store
>
yunfengzhou-hub opened a new pull request, #119:
URL: https://github.com/apache/flink-ml/pull/119
This PR is a complement to #117 . It updates the version of
flink-ml-examples and docs to 2.2-SNAPSHOT.
--
This is an automated message from the Apache Git Service.
To respond to the message,
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1166944578
@leonardBang Hi, It has passed the CI tests. Could you have a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
weibozhao opened a new pull request, #118:
URL: https://github.com/apache/flink-ml/pull/118
Add benchmark of vectorAssembler and minmaxScaler
--
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 s
HuangXingBo opened a new pull request, #20078:
URL: https://github.com/apache/flink/pull/20078
## What is the purpose of the change
*This pull request will annotate Python3.6 as deprecated in PyFlink 1.16*
## Verifying this change
This change added tests and can be verifi
flinkbot commented on PR #20078:
URL: https://github.com/apache/flink/pull/20078#issuecomment-1166926611
## CI report:
* d716b4376f4e6328be9ba3875df796478280a6d1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28195:
---
Labels: pull-request-available (was: )
> Annotate Python3.6 as deprecated in PyFlink 1.16
>
[
https://issues.apache.org/jira/browse/FLINK-28241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-28241.
---
Resolution: Fixed
Fix merged as 5d2f5a96b4bcb6f2e96db0a16a7ccea6280c91e2
(disable th
rkhachatryan merged PR #56:
URL: https://github.com/apache/flink-benchmarks/pull/56
--
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...@f
[
https://issues.apache.org/jira/browse/FLINK-28068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28068.
Resolution: Fixed
master: 981b8e36984803eb269e32a5f3116da8ce4185dc
> Control the total memory of
JingsongLi merged PR #171:
URL: https://github.com/apache/flink-table-store/pull/171
--
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...@
Aitozi commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r906975589
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/FlinkReconciler.java:
##
@@ -0,0 +1,282 @@
+/*
+ *
masteryhx commented on code in PR #19679:
URL: https://github.com/apache/flink/pull/19679#discussion_r906965060
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java:
##
@@ -477,6 +478,50 @@ KeyGro
flinkbot commented on PR #20077:
URL: https://github.com/apache/flink/pull/20077#issuecomment-1166816132
## CI report:
* 3da741a481dcc6c23f85081e93bd2b1c83967496 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jingsong Lee created FLINK-28256:
Summary: Move the write and prepareCommit logic of
AbstractTableWrite to FileStoreWrite
Key: FLINK-28256
URL: https://issues.apache.org/jira/browse/FLINK-28256
Projec
JingsongLi commented on code in PR #171:
URL: https://github.com/apache/flink-table-store/pull/171#discussion_r906958100
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/MemoryTableWrite.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Soft
HuangXingBo commented on code in PR #19878:
URL: https://github.com/apache/flink/pull/19878#discussion_r906952038
##
flink-python/src/main/java/org/apache/flink/streaming/api/transformations/python/PythonBroadcastStateTransformation.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to
libenchao commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r906952793
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbCodegenAppender.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Fou
libenchao commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r906951970
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize/PbRowDataSerializationSchema.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to th
nyingping opened a new pull request, #20077:
URL: https://github.com/apache/flink/pull/20077
## What is the purpose of the change
Fix doc of chapter etl.
## Brief change log
Add InputSelectable link address ,add missing ')' at the end of
note.
U
[
https://issues.apache.org/jira/browse/FLINK-28255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28255:
-
Description:
See FLINK-28244
{code:java}
class DataFileMeta {
String fileName;
.
[
https://issues.apache.org/jira/browse/FLINK-28237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-28237.
Resolution: Fixed
Merged into master via 58dbc3813e37085ef67c05f31a44ef11482ecd65
> Improve the f
HuangXingBo closed pull request #116: [FLINK-28237][python][ml] Improve flink
ml python examples in doc
URL: https://github.com/apache/flink-ml/pull/116
--
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
[
https://issues.apache.org/jira/browse/FLINK-28244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28244:
-
Description:
When using TableStore to support stream consumption, there are two requirements.
*
JingsongLi commented on code in PR #175:
URL: https://github.com/apache/flink-table-store/pull/175#discussion_r906944640
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java:
##
@@ -131,27 +129,4 @@ public String getPartitionS
tsreaper commented on code in PR #171:
URL: https://github.com/apache/flink-table-store/pull/171#discussion_r906944139
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/MemoryTableWrite.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-28255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28255:
---
Labels: pull-request-available (was: )
> Add extraFiles to DataFileMeta
> -
JingsongLi opened a new pull request, #175:
URL: https://github.com/apache/flink-table-store/pull/175
See [FLINK-28244](https://issues.apache.org/jira/browse/FLINK-28244)
```
class DataFileMeta {
String fileName;
.
// store the name of extra files, extra files
[
https://issues.apache.org/jira/browse/FLINK-28255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28255:
-
Description:
See FLINK-28244
{code:java}
class DataFileMeta {
String fileName;
.
Jingsong Lee created FLINK-28255:
Summary: Add extraFiles to DataFileMeta
Key: FLINK-28255
URL: https://issues.apache.org/jira/browse/FLINK-28255
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558975#comment-17558975
]
Yanfei Lei commented on FLINK-28010:
I think this is an interesting idea. There is a
liuzhuang2017 commented on PR #20061:
URL: https://github.com/apache/flink/pull/20061#issuecomment-1166786336
@MartijnVisser , Sorry to bother you again, can you help me review this pr?
Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1166785797
@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.
weibo zhao created FLINK-28254:
--
Summary: Add benchmark of vectorAssembler and minMaxScaler
Key: FLINK-28254
URL: https://issues.apache.org/jira/browse/FLINK-28254
Project: Flink
Issue Type: New
zhoulii commented on code in PR #20072:
URL: https://github.com/apache/flink/pull/20072#discussion_r906918702
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-28100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558959#comment-17558959
]
Yanfei Lei commented on FLINK-28100:
hi [~SOD_DOB], you can set up SateBackend by
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28253:
Summary: It reports "LocalDateTime is not supported in PyFlink currently"
when converting between Table an
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1166769356
> The failure test is related to
[https://issues.apache.org/jira/browse/FLINK-28226，](https://issues.apache.org/jira/browse/FLINK-28226%EF%BC%8C)
let's rebase util the
[FLINK-28226](htt
Dian Fu created FLINK-28253:
---
Summary: LocalDateTime is not supported in PyFlink
Key: FLINK-28253
URL: https://issues.apache.org/jira/browse/FLINK-28253
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-28226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-28226.
--
Resolution: Fixed
Merged into master via e52484a6b55147d8d4aa32bb51dc46aadb3acdf0
Merged into
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1166767237
@leonardBang the ci report build failed on `e2e_n_ci`, it seems that the
connectors module is not related. If I am wrong, please help correct it. Is
this because of the python3 package v
leonardBang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1166764398
The failure test is related to
https://issues.apache.org/jira/browse/FLINK-28226， let's rebase util the
FLINK-28226 fix has been backported to release-1.15, just wait a minute
@dusuk
fsk119 commented on code in PR #18920:
URL: https://github.com/apache/flink/pull/18920#discussion_r906783415
##
flink-connectors/flink-connector-hive/src/test/resources/query-test/sub_query.q:
##
@@ -0,0 +1,9 @@
+-- SORT_QUERY_RESULTS
Review Comment:
After reading the doc[1]
fsk119 commented on code in PR #18920:
URL: https://github.com/apache/flink/pull/18920#discussion_r906783415
##
flink-connectors/flink-connector-hive/src/test/resources/query-test/sub_query.q:
##
@@ -0,0 +1,9 @@
+-- SORT_QUERY_RESULTS
Review Comment:
After reading the doc[1]
lsyldliu commented on PR #20057:
URL: https://github.com/apache/flink/pull/20057#issuecomment-1166732624
@wuchong Thanks for your review, the CI have passed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-26891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26891:
---
Labels: pull-request-available (was: )
> Emit events for important Deployment / Job changes
tweise opened a new pull request, #281:
URL: https://github.com/apache/flink-kubernetes-operator/pull/281
Record events that may be of interest to users when looking at the
deployment with describe. Generally, these will be conversions of existing log
messages. I added couple examples for i
[
https://issues.apache.org/jira/browse/FLINK-28252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alvin Tan Jian Jia updated FLINK-28252:
---
Description:
*Summary*
I have identified a few classes with refactoring potential,
Alvin Tan Jian Jia created FLINK-28252:
--
Summary: Potential Refactoring
Key: FLINK-28252
URL: https://issues.apache.org/jira/browse/FLINK-28252
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558898#comment-17558898
]
Feifan Wang commented on FLINK-27822:
-
Hi [~jingge] , I have committed your suggesti
zoltar9264 commented on code in PR #19998:
URL: https://github.com/apache/flink/pull/19998#discussion_r906837057
##
docs/content.zh/docs/ops/state/checkpoints_vs_savepoints.md:
##
@@ -24,72 +24,65 @@ specific language governing permissions and limitations
under the License.
--
zoltar9264 commented on code in PR #19998:
URL: https://github.com/apache/flink/pull/19998#discussion_r906836151
##
docs/content.zh/docs/ops/state/checkpoints_vs_savepoints.md:
##
@@ -24,72 +24,65 @@ specific language governing permissions and limitations
under the License.
--
zoltar9264 commented on code in PR #19998:
URL: https://github.com/apache/flink/pull/19998#discussion_r906835722
##
docs/content.zh/docs/ops/state/checkpoints_vs_savepoints.md:
##
@@ -24,72 +24,65 @@ specific language governing permissions and limitations
under the License.
--
afedulov commented on PR #20052:
URL: https://github.com/apache/flink/pull/20052#issuecomment-1166562387
@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 #20049:
URL: https://github.com/apache/flink/pull/20049#issuecomment-1166562360
@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 comme
[
https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28250:
---
Priority: Major (was: Critical)
> exactly-once sink kafka cause out of memory
> ---
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-27344:
--
Assignee: Paul Lin
> FLIP-222: Support full job lifecycle statements in SQL client
>
1996fanrui commented on code in PR #19998:
URL: https://github.com/apache/flink/pull/19998#discussion_r906800401
##
docs/content.zh/docs/ops/state/checkpoints_vs_savepoints.md:
##
@@ -24,72 +24,65 @@ specific language governing permissions and limitations
under the License.
--
gyfora commented on code in PR #280:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/280#discussion_r906791270
##
flink-kubernetes-operator/src/main/resources/log4j2.properties:
##
@@ -24,3 +24,6 @@ appender.console.name = ConsoleAppender
appender.console.type =
flinkbot commented on PR #20076:
URL: https://github.com/apache/flink/pull/20076#issuecomment-1166457461
## CI report:
* fd59daebe776c4ddf300850de397af2bed446b19 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui opened a new pull request, #20076:
URL: https://github.com/apache/flink/pull/20076
## What is the purpose of the change
Translate the doc of overdraft buffers
## Brief change log
Translate the doc of overdraft buffers
## Verifying this change
This
flinkbot commented on PR #20075:
URL: https://github.com/apache/flink/pull/20075#issuecomment-1166448719
## CI report:
* cf09ed60bd0b072ca87e659d37295762d5595582 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27789:
---
Labels: pull-request-available (was: )
> LegacySource compatible with overdraft buffer
> --
1996fanrui opened a new pull request, #20075:
URL: https://github.com/apache/flink/pull/20075
## What is the purpose of the change
Disable overdraft buffer for LegacySource.
## Brief change log
Disable overdraft buffer for LegacySource.
## Verifying this change
gyfora commented on PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#issuecomment-1166444887
@Aitozi added some further javadocs to clean up the base reconciler class
and renamed classes for consistency. Please take a look
--
This is an automated message from t
gyfora commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r906772317
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/FlinkReconciler.java:
##
@@ -0,0 +1,282 @@
+/*
+ *
gyfora commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r906772181
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/FlinkReconciler.java:
##
@@ -0,0 +1,282 @@
+/*
+ *
gyfora commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r906772118
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/FlinkReconciler.java:
##
@@ -0,0 +1,282 @@
+/*
+ *
SteNicholas commented on PR #20029:
URL: https://github.com/apache/flink/pull/20029#issuecomment-1166436229
@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 commen
72 matches
Mail list logo
