KarmaGYZ commented on PR #20042:
URL: https://github.com/apache/flink/pull/20042#issuecomment-1169561842
Thanks for the comments. PR updated. @xintongsong @wangyang0918
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Title: Message Title
Jingsong Lee updated
Title: Message Title
ASF GitHub Bot
JingsongLi opened a new pull request, #180:
URL: https://github.com/apache/flink-table-store/pull/180
These APIs were changed significantly in 1.14 and 1.15 and are not
compatible.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Title: Message Title
Jingsong Lee created
Title: Message Title
Jingsong Lee updated
6591812 commented on PR #20072:
URL: https://github.com/apache/flink/pull/20072#issuecomment-1169530980
@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.
1996fanrui commented on code in PR #20075:
URL: https://github.com/apache/flink/pull/20075#discussion_r909185339
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java:
##
@@ -385,11 +385,16 @@ public Task(
JingsongLi closed pull request #178: [FLINK-28244] Introduce changelog file for
DataFile
URL: https://github.com/apache/flink-table-store/pull/178
--
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
wangyang0918 commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r909164865
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecorator.java:
##
@@ -149,7 +153,16 @@ private Container
Title: Message Title
Yanfei Lei updated
Myasuka commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1169492816
> Hi @Myasuka , It seems that test can't be triggered, have you ever come
across this ?
No, @zentol do you know what happened here?
--
This is an automated message from the
zoltar9264 commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1169491021
Hi @Myasuka , It seems that test can't be triggered, have you ever come
across this ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
zhuzhurk commented on code in PR #20057:
URL: https://github.com/apache/flink/pull/20057#discussion_r909160467
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -1023,6 +1025,19 @@ public void
Title: Message Title
Yun Tang commented
Title: Message Title
Yun Tang commented
JingsongLi closed pull request #178: [FLINK-28244] Introduce changelog file for
DataFile
URL: https://github.com/apache/flink-table-store/pull/178
--
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
Title: Message Title
jiulong.zhu updated
Title: Message Title
jiulong.zhu created
Title: Message Title
Huang Xingbo
Title: Message Title
Huang Xingbo updated
Title: Message Title
Huang Xingbo
Title: Message Title
Huang Xingbo
Title: Message Title
Huang Xingbo
Title: Message Title
Huang Xingbo
Title: Message Title
Huang Xingbo
masteryhx commented on code in PR #19679:
URL: https://github.com/apache/flink/pull/19679#discussion_r909148359
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java:
##
@@ -477,6 +478,50 @@
Title: Message Title
Huang Xingbo
Title: Message Title
Huang Xingbo
Title: Message Title
Huang Xingbo created
Title: Message Title
Huang Xingbo
fsk119 commented on code in PR #16108:
URL: https://github.com/apache/flink/pull/16108#discussion_r909145606
##
flink-core/src/main/java/org/apache/flink/util/FileLock.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more
fsk119 commented on code in PR #16108:
URL: https://github.com/apache/flink/pull/16108#discussion_r909145606
##
flink-core/src/main/java/org/apache/flink/util/FileLock.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more
lindong28 closed pull request #74: [FLINK-26828][example] add new examples sub
module and create KMeans example
URL: https://github.com/apache/flink-ml/pull/74
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
lindong28 commented on PR #74:
URL: https://github.com/apache/flink-ml/pull/74#issuecomment-1169469111
Thanks for the PR. We have added examples and the corresponding doc in
https://github.com/apache/flink-ml/pull/119.
I will close this PR as discussed offline.
--
This is an
Title: Message Title
Huang Xingbo
lindong28 merged PR #121:
URL: https://github.com/apache/flink-ml/pull/121
--
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:
lindong28 commented on PR #121:
URL: https://github.com/apache/flink-ml/pull/121#issuecomment-1169468374
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 specific
flinkbot commented on PR #20098:
URL: https://github.com/apache/flink/pull/20098#issuecomment-1169465743
## CI report:
* aaf82b9952009cc3fc131cd86d0f0201a5986855 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Title: Message Title
ASF GitHub Bot
deadwind4 opened a new pull request, #20098:
URL: https://github.com/apache/flink/pull/20098
## What is the purpose of the change
Support decode and encode built-in functions in Table API.
## Brief change log
- *Support decode and encode built-in functions in Table
Title: Message Title
Jingsong Lee created
Title: Message Title
Weijie Guo updated
Title: Message Title
Weijie Guo updated
Title: Message Title
Weijie Guo updated
Title: Message Title
Feifan Wang
Title: Message Title
LuNing Wang updated
Title: Message Title
LuNing Wang updated
Title: Message Title
LuNing Wang created
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
yunfengzhou-hub commented on code in PR #121:
URL: https://github.com/apache/flink-ml/pull/121#discussion_r909134520
##
flink-ml-python/pyflink/examples/ml/__init__.py:
##
@@ -15,3 +15,80 @@
# See the License for the specific language governing permissions and
# limitations
lsyldliu commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1169449211
@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.
lsyldliu commented on PR #20057:
URL: https://github.com/apache/flink/pull/20057#issuecomment-1169448529
@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.
Title: Message Title
Feifan Wang
zoltar9264 commented on PR #20093:
URL: https://github.com/apache/flink/pull/20093#issuecomment-1169447489
@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
Title: Message Title
Dian Fu closed an
Title: Message Title
Dian Fu updated an
xintongsong commented on PR #20031:
URL: https://github.com/apache/flink/pull/20031#issuecomment-1169445372
@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
Title: Message Title
Dian Fu closed an
dianfu closed pull request #19988: [FLINK-28092][table] Support ASCII and CHR
built-in function in the Table API
URL: https://github.com/apache/flink/pull/19988
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dianfu commented on PR #19988:
URL: https://github.com/apache/flink/pull/19988#issuecomment-1169444531
LGTM. Merging...
> If we migrate all built-in functions to the new stack, we could create a
new Jira ticket to target this.
Agree. Let's do that in a separate ticket if we
zoltar9264 commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1169443111
@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
Aitozi commented on code in PR #283:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r909107158
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java:
##
@@ -279,21
tweise commented on PR #281:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/281#issuecomment-1169419765
> The PR looks pretty good!
>
> My only question whether we should trigger events before or after
executing the actions using the Flink service.
>
> For
nyingping commented on PR #20028:
URL: https://github.com/apache/flink/pull/20028#issuecomment-1169414641
@Myasuka @MartijnVisser Thanks a lot!
--
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
Aitozi commented on code in PR #283:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r909093534
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java:
##
@@ -279,21
Aitozi commented on code in PR #283:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r908605561
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java:
##
@@ -352,22 +382,33 @@
Aitozi commented on code in PR #283:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r908605561
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java:
##
@@ -352,22 +382,33 @@
Title: Message Title
JieFang.He updated
Title: Message Title
JieFang.He created
syhily commented on PR #19473:
URL: https://github.com/apache/flink/pull/19473#issuecomment-1169400631
> Thanks for the patch @syhily. I notice that this PR touches a lot of
components including Pulsar client version, docs even default value of sink
options. What about breaking these
Title: Message Title
Roman Khachatryan
rkhachatryan commented on code in PR #19679:
URL: https://github.com/apache/flink/pull/19679#discussion_r909048188
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java:
##
@@ -477,6 +478,50 @@
Title: Message Title
Yordan Pavlov
flinkbot commented on PR #20097:
URL: https://github.com/apache/flink/pull/20097#issuecomment-1169146748
## CI report:
* 8bcbd05a6b7eeb2000685b729f860eae3c1b50aa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Title: Message Title
Robin Neufeld
eskabetxe commented on PR #20097:
URL: https://github.com/apache/flink/pull/20097#issuecomment-1169141734
@leonardBang @MartijnVisser could you check 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
Title: Message Title
ASF GitHub Bot
eskabetxe opened a new pull request, #20097:
URL: https://github.com/apache/flink/pull/20097
## What is the purpose of the change
Add a JdbcSink with new format (sink2)
## Brief change log
- *JdbcSink* the new sink
- *JdbcSinkWriter* the writer used by the new
Title: Message Title
Martijn Visser
Title: Message Title
Martijn Visser
MartijnVisser merged PR #20096:
URL: https://github.com/apache/flink/pull/20096
--
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:
MartijnVisser merged PR #20095:
URL: https://github.com/apache/flink/pull/20095
--
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:
MartijnVisser opened a new pull request, #20096:
URL: https://github.com/apache/flink/pull/20096
Unchanged backport of https://github.com/apache/flink/pull/20083
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
MartijnVisser opened a new pull request, #20095:
URL: https://github.com/apache/flink/pull/20095
Unchanged backport of https://github.com/apache/flink/pull/20083
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
MartijnVisser merged PR #20083:
URL: https://github.com/apache/flink/pull/20083
--
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:
Title: Message Title
uharaqo edited a
MartijnVisser commented on PR #20083:
URL: https://github.com/apache/flink/pull/20083#issuecomment-1169074724
@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
Title: Message Title
Martijn Visser
zentol commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r908766389
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -685,13 +687,27 @@ public CompletableFuture submitTask(
Title: Message Title
ASF GitHub Bot
MartijnVisser commented on PR #20083:
URL: https://github.com/apache/flink/pull/20083#issuecomment-1169016409
@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
Title: Message Title
Martijn Visser
Title: Message Title
Márton Balassi
Title: Message Title
uharaqo commented on
Title: Message Title
Márton Balassi
Title: Message Title
Sebastian Mattheis
Title: Message Title
Sebastian Mattheis
Title: Message Title
Márton Balassi
mbalassi merged PR #284:
URL: https://github.com/apache/flink-kubernetes-operator/pull/284
--
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:
1 - 100 of 293 matches
Mail list logo