wanglijie95 closed pull request #546: Add blogs for FLIP-187 adaptive batch
scheduler
URL: https://github.com/apache/flink-web/pull/546
--
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 c
zhuzhurk commented on code in PR #545:
URL: https://github.com/apache/flink-web/pull/545#discussion_r908091944
##
_posts/2022-06-01-final-checkpoint-part2.md:
##
@@ -0,0 +1,244 @@
+---
+layout: post
+title: "FLIP-147: Support Checkpoints After Tasks Finished - Part Two"
+date:
Title: Message Title
ConradJam commented o
Title: Message Title
Robert Metzger commen
Title: Message Title
Yun Tang commented on
Title: Message Title
Martijn Visser assign
Title: Message Title
Robert Metzger create
Title: Message Title
Martijn Visser assign
Title: Message Title
Martijn Visser assign
Title: Message Title
Martijn Visser create
Title: Message Title
Martijn Visser assign
Title: Message Title
Martijn Visser assign
fsk119 commented on PR #20063:
URL: https://github.com/apache/flink/pull/20063#issuecomment-1168282826
@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
Martijn Visser commen
Myasuka commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1168271898
@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
Huang Xingbo closed a
Title: Message Title
Yun Tang commented on
Title: Message Title
Yun Tang updated an i
Title: Message Title
Yun Tang assigned an
HuangXingBo closed pull request #20085: [FLINK-28195][python] Fix the build
wheels
URL: https://github.com/apache/flink/pull/20085
--
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
Title: Message Title
Jingsong Lee closed a
JingsongLi merged PR #177:
URL: https://github.com/apache/flink-table-store/pull/177
--
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...@
morhidi commented on PR #281:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/281#issuecomment-1168242595
> > Nice job, @tweise! I was wondering if we could/should make the Reason
field part of the FlinkResourceListener API? If we do so a call control layer
could leverage it
Title: Message Title
ASF GitHub Bot update
gyfora commented on PR #283:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/283#issuecomment-1168240211
cc @Aitozi
--
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 co
Title: Message Title
Matyas Orhidi updated
Title: Message Title
Matyas Orhidi comment
Title: Message Title
Matyas Orhidi created
Title: Message Title
Matyas Orhidi updated
lirui-apache commented on PR #20071:
URL: https://github.com/apache/flink/pull/20071#issuecomment-1168214812
Thanks @luoyuxia for fixing the issue. Should we also add test cases for
grouping function with multiple parameters?
--
This is an automated message from the Apache Git Service.
To
PatrickRen commented on code in PR #19856:
URL: https://github.com/apache/flink/pull/19856#discussion_r908016836
##
flink-end-to-end-tests/flink-end-to-end-tests-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/table/test/KinesisStreamsTableApiIT.java:
##
@@
godfreyhe commented on code in PR #20084:
URL: https://github.com/apache/flink/pull/20084#discussion_r908013925
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveInputFormat.java:
##
@@ -132,10 +132,10 @@ private RowType tableRowTyp
Title: Message Title
Jing Zhang updated an
Title: Message Title
Jing Zhang updated an
luoyuxia commented on PR #20062:
URL: https://github.com/apache/flink/pull/20062#issuecomment-1168198450
@godfreyhe Yes. The `Infinity` and `NaN` is just a special type of `double`
. It can be hanlded as normal double value. I have checked it.
--
This is an automated message from the
Title: Message Title
Jing Zhang updated an
LadyForest commented on code in PR #177:
URL: https://github.com/apache/flink-table-store/pull/177#discussion_r908011725
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/FileStoreTableFactory.java:
##
@@ -56,13 +56,14 @@ public static FileStoreTable cre
Title: Message Title
Zhu Zhu closed an iss
zhuzhurk closed pull request #20080: [FLINK-28258] Introduce ExecutionHistory
to host historical executions for each execution vertex
URL: https://github.com/apache/flink/pull/20080
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Title: Message Title
Yuan Mei assigned an
zhuzhurk commented on PR #20080:
URL: https://github.com/apache/flink/pull/20080#issuecomment-1168193020
Thanks for the reviewing! @zhoulii @wanglijie95
Merging.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Title: Message Title
Yuan Mei commented on
flinkbot commented on PR #20087:
URL: https://github.com/apache/flink/pull/20087#issuecomment-1168192437
## CI report:
* c4c4fb962bcea34f1f94b149ded8123d3f76131c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Title: Message Title
ASF GitHub Bot update
zhuzhurk opened a new pull request, #20087:
URL: https://github.com/apache/flink/pull/20087
## What is the purpose of the change
This PR adds config options for speculative scheduler.
It is needed to unblock the development of blocklist and speculative
scheduler.
## Verifyi
curcur commented on code in PR #19679:
URL: https://github.com/apache/flink/pull/19679#discussion_r908006152
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java:
##
@@ -477,6 +478,50 @@ KeyGroupe
Title: Message Title
Zhu Zhu created an is
Title: Message Title
Zhu Zhu assigned an i
Title: Message Title
Feifan Wang commented
Title: Message Title
Feifan Wang commented
Title: Message Title
Feifan Wang updated a
Title: Message Title
Yun Tang commented on
Title: Message Title
Huang Xingbo commente
Title: Message Title
Huang Xingbo commente
Title: Message Title
Huang Xingbo commente
Title: Message Title
Huang Xingbo updated
Title: Message Title
Huang Xingbo commente
Title: Message Title
Huang Xingbo created
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r907992379
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SpeculativeExecutionVertex.java:
##
@@ -0,0 +1,284 @@
+/*
+ * Licensed to the Apache Software Fou
zoltar9264 commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1168172328
> LGTM, @zoltar9264 could you please squash all commits into one?
sure , done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Title: Message Title
Huang Xingbo created
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r907991457
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedSpeculativeExecutionVertex.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Softw
godfreyhe commented on PR #17956:
URL: https://github.com/apache/flink/pull/17956#issuecomment-1168171339
hi @zstraw please resolve the conflict
--
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
Title: Message Title
Feifan Wang commented
Title: Message Title
Feifan Wang commented
zhuzhurk commented on code in PR #20072:
URL: https://github.com/apache/flink/pull/20072#discussion_r907986543
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetectorTest.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to
zhoulii commented on code in PR #20072:
URL: https://github.com/apache/flink/pull/20072#discussion_r907987000
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the
Title: Message Title
zl commented on FLIN
Title: Message Title
Huang Xingbo commente
godfreyhe commented on PR #20062:
URL: https://github.com/apache/flink/pull/20062#issuecomment-1168163165
@luoyuxia do the down stream operators and sinks can process `Infinity` and
`NaN` ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
zoltar9264 commented on code in PR #19998:
URL: https://github.com/apache/flink/pull/19998#discussion_r907984996
##
docs/content.zh/docs/ops/state/checkpoints_vs_savepoints.md:
##
@@ -24,72 +24,65 @@ specific language governing permissions and limitations
under the License.
--
Title: Message Title
Jingsong Lee closed a
JingsongLi merged PR #176:
URL: https://github.com/apache/flink-table-store/pull/176
--
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...@
Title: Message Title
Jingsong Lee closed a
zhuzhurk commented on code in PR #20072:
URL: https://github.com/apache/flink/pull/20072#discussion_r907983899
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the
JingsongLi merged PR #175:
URL: https://github.com/apache/flink-table-store/pull/175
--
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...@
godfreyhe commented on PR #17873:
URL: https://github.com/apache/flink/pull/17873#issuecomment-1168159085
>
> > It is just a hint for the scheduling and might not be obeyed in the
future. However, I agree that this is indeed helpful information. @godfreyhe
WDYT about the com
Title: Message Title
Huang Xingbo commente
Title: Message Title
Huang Xingbo updated
Title: Message Title
Huang Xingbo created
Title: Message Title
Yun Tang assigned an
1996fanrui commented on code in PR #20075:
URL: https://github.com/apache/flink/pull/20075#discussion_r907979743
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java:
##
@@ -385,11 +385,16 @@ public Task(
shuffleEnvironment.createShuffle
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907979574
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
Title: Message Title
Huang Xingbo commente
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907978610
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907978530
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
zhuzhurk commented on PR #20080:
URL: https://github.com/apache/flink/pull/20080#issuecomment-1168154340
@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.
zhipeng93 merged PR #122:
URL: https://github.com/apache/flink-ml/pull/122
--
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
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907977869
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
Title: Message Title
Zhu Zhu commented on
Title: Message Title
Zhu Zhu created an is
LadyForest commented on code in PR #177:
URL: https://github.com/apache/flink-table-store/pull/177#discussion_r907977310
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreRead.java:
##
@@ -33,6 +31,5 @@
public interface FileStoreRead {
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907977299
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907976919
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907976427
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907976297
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907976211
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
pengmide commented on code in PR #19945:
URL: https://github.com/apache/flink/pull/19945#discussion_r907976097
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -0,0 +1,1648 @@
+
+#
godfreyhe commented on PR #17873:
URL: https://github.com/apache/flink/pull/17873#issuecomment-1168150447
> @godfreyhe Is the JSON plan a public interface to users? This PR seems to
break it.
@KarmaGYZ The execution json plan will be exposed to users as part of
`explain` result. So
HuangXingBo commented on PR #20085:
URL: https://github.com/apache/flink/pull/20085#issuecomment-1168149769
https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=1862&view=logs&j=79728727-bed4-5185-8f2e-b43a119f2877
build wheels
--
This is an automated message from the Apache
1 - 100 of 283 matches
Mail list logo
