klion26 commented on issue #7921: [FLINK-11825][StateBackends] Resolve name
class of StateTTL TimeCharacteristic class
URL: https://github.com/apache/flink/pull/7921#issuecomment-470423558
@fhueske thank you for your quick reply.
If moving `org.apache.flink.streaming.api.TimeCharacterist
fhueske commented on issue #7921: [FLINK-11825][StateBackends] Resolve name
class of StateTTL TimeCharacteristic class
URL: https://github.com/apache/flink/pull/7921#issuecomment-470420458
Thanks for opening a PR @klion26.
Just to put out an alternative. We could also think about mov
klion26 commented on issue #7921: [FLINK-11825][StateBackends] Resolve name
class of StateTTL TimeCharacteristic class
URL: https://github.com/apache/flink/pull/7921#issuecomment-470417326
cc @azagrebin, I can not remove the class StateTtlConfig#TimeCharacteristic
and use `org.apache.flink
flinkbot commented on issue #7921: [FLINK-11825][StateBackends] Resolve name
class of StateTTL TimeCharacteristic class
URL: https://github.com/apache/flink/pull/7921#issuecomment-470416457
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the commun
[
https://issues.apache.org/jira/browse/FLINK-11825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11825:
---
Labels: pull-request-available (was: )
> Resolve name clash of StateTTL TimeCharacteristic
klion26 opened a new pull request #7921: [FLINK-11825][StateBackends] Resolve
name class of StateTTL TimeCharacteristic class
URL: https://github.com/apache/flink/pull/7921
## What is the purpose of the change
Resolve name class of StateTTL TimeCharacteristic class for at least
foll
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r262963873
##
File path:
flink-streaming-java/src/main/java/org/apache/
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r262970822
##
File path:
flink-streaming-java/src/main/java/org/apache/
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r263257091
##
File path: docs/dev/connectors/pubsub.md
##
@@ -
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r263249985
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r263249127
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r263251302
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r262982838
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r263251455
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r263250580
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r262962875
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
hequn8128 commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r263253836
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/r
Shengnan YU created FLINK-11848:
---
Summary: Delete outdated kafka topics caused
UNKNOWN_TOPIC_EXCEPTIION
Key: FLINK-11848
URL: https://issues.apache.org/jira/browse/FLINK-11848
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-11343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun closed FLINK-11343.
Resolution: Resolved
Release Note: master via 28cccde59abd08289c3ec55363773c175452ec05
> TaskExecuto
KurtYoung commented on a change in pull request #7913:
[FLINK-11837][table-runtime-blink] Improve internal data format
URL: https://github.com/apache/flink/pull/7913#discussion_r263228751
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataf
KurtYoung commented on a change in pull request #7913:
[FLINK-11837][table-runtime-blink] Improve internal data format
URL: https://github.com/apache/flink/pull/7913#discussion_r263229076
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataf
KurtYoung commented on a change in pull request #7913:
[FLINK-11837][table-runtime-blink] Improve internal data format
URL: https://github.com/apache/flink/pull/7913#discussion_r263227450
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataf
KurtYoung commented on a change in pull request #7913:
[FLINK-11837][table-runtime-blink] Improve internal data format
URL: https://github.com/apache/flink/pull/7913#discussion_r263227576
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataf
[
https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-11837:
-
Component/s: (was: SQL / Planner)
Runtime / Operators
> Improve internal da
[
https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-11837:
-
Description:
In FLINK-11701 , we introduce an abstract set of internal data formats to
table-ru
[
https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-11837:
-
Summary: Improve internal data format (was: Improve blink internal data
format)
> Improve inte
[
https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16786295#comment-16786295
]
Jingsong Lee commented on FLINK-11837:
--
[~rmetzger] no, I mean, this code was chang
connord-stripe commented on issue #7168: [FLINK-6756][DataStream API] Provide
Rich AsyncFunction to Scala API …
URL: https://github.com/apache/flink/pull/7168#issuecomment-470347430
(@dawidwys) +1 to this in a stable release, this would have helped me out
the past few days, I'm having to w
glaksh100 commented on issue #7900: [FLINK-11826] Fix flaky Kafka ratelimiter
test
URL: https://github.com/apache/flink/pull/7900#issuecomment-470347145
@tillrohrmann @tweise I updated the test to run a little faster by
increasing the desired rate to 10 bytes/second. The test now completes
[
https://issues.apache.org/jira/browse/FLINK-11834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11834.
--
Resolution: Implemented
Fix Version/s: 1.9.0
fixed in fd04309c8828637de895cbb8470bc210a3f33b66
KurtYoung merged pull request #7910: [FLINK-11834] [table-planner-blink]
Introduce flink logical relational nodes
URL: https://github.com/apache/flink/pull/7910
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun reassigned FLINK-11835:
Assignee: (was: TisonKun)
> ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeader
TisonKun commented on a change in pull request #7918: [FLINK-11846] Don't
delete HA job files in case of duplicate job submission
URL: https://github.com/apache/flink/pull/7918#discussion_r263179412
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispa
[
https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16786145#comment-16786145
]
Ufuk Celebi commented on FLINK-11798:
-
[~1u0] Could you take a look at this?
> Inc
[
https://issues.apache.org/jira/browse/FLINK-11847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16786143#comment-16786143
]
Ufuk Celebi commented on FLINK-11847:
-
{{README.md}} refers to
[https://github.com/
[
https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16786139#comment-16786139
]
Chunhui Shi commented on FLINK-11439:
-
Should there be a work item for Calcite depen
twalthr commented on issue #7920: [FLINK-11844][table-api] Simplify over window
API classes and improve documentation
URL: https://github.com/apache/flink/pull/7920#issuecomment-470274963
@sunjincheng121 Would be great if you can take a quick look.
-
flinkbot commented on issue #7920: [FLINK-11844][table-api] Simplify over
window API classes and improve documentation
URL: https://github.com/apache/flink/pull/7920#issuecomment-470274466
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communi
[
https://issues.apache.org/jira/browse/FLINK-11844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11844:
---
Labels: pull-request-available (was: )
> Simplify OVER window Table API classes
> -
twalthr opened a new pull request #7920: [FLINK-11844][table-api] Simplify over
window API classes and improve documentation
URL: https://github.com/apache/flink/pull/7920
## What is the purpose of the change
This PR removes duplicate code and thus simplifies the over window API
cla
[
https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16786078#comment-16786078
]
Alexander Lehmann commented on FLINK-4399:
--
Hi, as of late I'm also running into
Fokko commented on issue #7915: FLINK-11838 Add GCS RecoverableWriter
URL: https://github.com/apache/flink/pull/7915#issuecomment-470247166
This is something that we run into:
https://lists.apache.org/thread.html/d74081ac65c19db790f421f28a70db2a8e0f0c804f08fd0344274515@%3Cdev.flink.apache.o
Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-470210907
Sorry to hear you were ill :) But I am glad to hear you used the wrong
connector so the iss
flinkbot commented on issue #7919: [BP-1.8][FLINK-11846] Don't delete HA job
files in case of duplicate job submission
URL: https://github.com/apache/flink/pull/7919#issuecomment-470207032
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communi
[
https://issues.apache.org/jira/browse/FLINK-11846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11846:
---
Labels: pull-request-available (was: )
> Duplicate job submission delete HA files
> ---
flinkbot commented on issue #7918: [FLINK-11846] Don't delete HA job files in
case of duplicate job submission
URL: https://github.com/apache/flink/pull/7918#issuecomment-470206774
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
tillrohrmann opened a new pull request #7919: [BP-1.8][FLINK-11846] Don't
delete HA job files in case of duplicate job submission
URL: https://github.com/apache/flink/pull/7919
Backport of #7918 to `release-1.8`.
This is an a
tillrohrmann opened a new pull request #7918: [FLINK-11846] Don't delete HA job
files in case of duplicate job submission
URL: https://github.com/apache/flink/pull/7918
## What is the purpose of the change
This commit changes the cleanup logic of the Dispatcher to only clean up job
Frank Wilson created FLINK-11847:
Summary: Docker job-specific image creation instruction make
reference to --job-jar parameter that does not actually exist in the script
Key: FLINK-11847
URL: https://issues.apach
Till Rohrmann created FLINK-11846:
-
Summary: Duplicate job submission delete HA files
Key: FLINK-11846
URL: https://issues.apache.org/jira/browse/FLINK-11846
Project: Flink
Issue Type: Bug
TisonKun created FLINK-11845:
Summary: Drop unused InfoMessage
Key: FLINK-11845
URL: https://issues.apache.org/jira/browse/FLINK-11845
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-9481.
-
Resolution: Cannot Reproduce
I could not reproduce it. Feel free to re-open if it appears again.
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11665:
--
Affects Version/s: 1.8.0
1.6.4
1.7.2
> Flink fai
[
https://issues.apache.org/jira/browse/FLINK-11446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-11446.
--
Resolution: Cannot Reproduce
I could not reproduce it. Feel free to re-open if it appears agai
[
https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-9481:
--
Fix Version/s: (was: 1.6.5)
(was: 1.7.3)
(was:
[
https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-9481:
-
Assignee: Kostas Kloudas
> FlinkKafkaProducer011ITCase deadlock in initializeState
> --
[
https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11843:
--
Fix Version/s: 1.8.0
> Dispatcher fails to recover jobs if leader change happens during
> Job
[
https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-11843:
-
Assignee: Till Rohrmann
> Dispatcher fails to recover jobs if leader change happens dur
flinkbot commented on issue #7917: [BP-1.7][FLINK-11537] Make
ExecutionGraph#suspend terminate ExecutionGraph atomically
URL: https://github.com/apache/flink/pull/7917#issuecomment-470172733
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the commu
tillrohrmann opened a new pull request #7917: [BP-1.7][FLINK-11537] Make
ExecutionGraph#suspend terminate ExecutionGraph atomically
URL: https://github.com/apache/flink/pull/7917
Backport of #7756 for `release-1.7`.
cc @stevenzwu.
glaksh100 edited a comment on issue #7900: [FLINK-11826] Fix flaky Kafka
ratelimiter test
URL: https://github.com/apache/flink/pull/7900#issuecomment-470162038
@tillrohrmann The test asserts that the Kafka consumer reads <= X bytes/sec.
I can increase X, so that the test takes lesser time
glaksh100 edited a comment on issue #7900: [FLINK-11826] Fix flaky Kafka
ratelimiter test
URL: https://github.com/apache/flink/pull/7900#issuecomment-470162038
@tillrohrmann The test asserts that the Kafka consumer reads <= X bytes/sec.
I can increase X, so that the test takes lesser time
glaksh100 commented on issue #7900: [FLINK-11826] Fix flaky Kafka ratelimiter
test
URL: https://github.com/apache/flink/pull/7900#issuecomment-470162038
@tillrohrmann The test asserts that the Kafka consumer reads <= X bytes/sec.
I can increase X, so that the test takes lesser time to run.
Timo Walther created FLINK-11844:
Summary: Simplify OVER window Table API classes
Key: FLINK-11844
URL: https://issues.apache.org/jira/browse/FLINK-11844
Project: Flink
Issue Type: Improvemen
StefanRRichter merged pull request #7830: [hotfix] Reduce and simplify code for
column creation in RocksDB backend
URL: https://github.com/apache/flink/pull/7830
This is an automated message from the Apache Git Service.
To r
StefanRRichter commented on issue #7830: [hotfix] Reduce and simplify code for
column creation in RocksDB backend
URL: https://github.com/apache/flink/pull/7830#issuecomment-470157540
Merging.
This is an automated message fro
Till Rohrmann created FLINK-11843:
-
Summary: Dispatcher fails to recover jobs if leader change happens
during JobManagerRunner termination
Key: FLINK-11843
URL: https://issues.apache.org/jira/browse/FLINK-11843
[
https://issues.apache.org/jira/browse/FLINK-11829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-11829.
Resolution: Fixed
Merged in:
master: 753bc10
> [checkpoint] FsCheckpointStateOutputStream
[
https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785748#comment-16785748
]
Robert Metzger commented on FLINK-11837:
Is the "blink" in the title a typo?
>
StefanRRichter merged pull request #7907: [FLINK-11829][checkpoint] Avoid
FsCheckpointStateOutputStream to store state in files when size below
fileStateThreshold
URL: https://github.com/apache/flink/pull/7907
This is an au
[
https://issues.apache.org/jira/browse/FLINK-11829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-11829:
---
Fix Version/s: 1.9.0
> [checkpoint] FsCheckpointStateOutputStream might store state in files
[
https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-11837:
---
Component/s: SQL / Planner
> Improve blink internal data format
> --
lamber-ken commented on issue #7902: [FLINK-11821] fix the error package
location of KafkaDeserializationSchemaWrapper.java
URL: https://github.com/apache/flink/pull/7902#issuecomment-470152930
@aljoscha，you are welcome.
Thi
StefanRRichter commented on issue #7907: [FLINK-11829][checkpoint] Avoid
FsCheckpointStateOutputStream to store state in files when size below
fileStateThreshold
URL: https://github.com/apache/flink/pull/7907#issuecomment-470152936
Changes LGTM 👍 Merging.
-
StefanRRichter merged pull request #7916: [hotfix][flink-core] fix errors in
MemorySegment description
URL: https://github.com/apache/flink/pull/7916
This is an automated message from the Apache Git Service.
To respond to th
pnowojski commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r262975197
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
[
https://issues.apache.org/jira/browse/FLINK-11821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-11821.
Resolution: Fixed
Fixed on master in
19d20e5cf8d44d726b4a44575e6c8db677e4c3c8
Fixed on re
aljoscha closed pull request #7902: [FLINK-11821] fix the error package
location of KafkaDeserializationSchemaWrapper.java
URL: https://github.com/apache/flink/pull/7902
This is an automated message from the Apache Git Servi
aljoscha commented on issue #7902: [FLINK-11821] fix the error package location
of KafkaDeserializationSchemaWrapper.java
URL: https://github.com/apache/flink/pull/7902#issuecomment-470146735
Merged, thanks again, @lamber-ken!
---
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r262986676
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/r
mikeholler commented on issue #7897: [FLINK-11817] Uses aggregate function in
DataStream API Tutorial
URL: https://github.com/apache/flink/pull/7897#issuecomment-470139863
> Wikipedia provides an IRC channel where all edits to the wiki are logged.
We are going to
read this channel in Fl
pnowojski commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r262975197
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
pnowojski commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r262926493
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime
pnowojski commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r262960302
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime
pnowojski commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r262961955
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime
leesf commented on issue #7897: [FLINK-11817] Uses aggregate function in
DataStream API Tutorial
URL: https://github.com/apache/flink/pull/7897#issuecomment-470134562
@zentol , should we just return new Tuple(a.f0, a.f1 + b.f1) in merge
function in above example or design an new example to
[
https://issues.apache.org/jira/browse/FLINK-11821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11821:
-
Fix Version/s: 1.8.0
> Fix package declaration and location of internal Kafka schema wra
flinkbot commented on issue #7916: [hotfix][flink-core] fix errors in
MemorySegment description
URL: https://github.com/apache/flink/pull/7916#issuecomment-470126609
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pu
leesf opened a new pull request #7916: [hotfix][flink-core] fix errors in
MemorySegment description
URL: https://github.com/apache/flink/pull/7916
Fix errors in MemorySegment description.
This is an automated message from the
flinkbot commented on issue #7915: FLINK-11838 Add GCS RecoverableWriter
URL: https://github.com/apache/flink/pull/7915#issuecomment-470125550
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11838:
---
Labels: pull-request-available (was: )
> Create RecoverableWriter for GCS
> ---
Fokko opened a new pull request #7915: FLINK-11838 Add GCS RecoverableWriter
URL: https://github.com/apache/flink/pull/7915
WIP: https://issues.apache.org/jira/browse/FLINK-11838
## What is the purpose of the change
*(For example: This pull request makes task deployment
[
https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785673#comment-16785673
]
Chesnay Schepler commented on FLINK-10756:
--
I found a possible explanation for
[
https://issues.apache.org/jira/browse/FLINK-11834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11834:
---
Description:
* _Adds nodes extended from Calcite, including {{FlinkLogicalAggregate}},
{{FlinkLogic
flinkbot edited a comment on issue #7897: [FLINK-11817] Uses aggregate function
in DataStream API Tutorial
URL: https://github.com/apache/flink/pull/7897#issuecomment-469527787
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to rev
aljoscha commented on issue #7902: [FLINK-11821] fix the error package location
of KafkaDeserializationSchemaWrapper.java
URL: https://github.com/apache/flink/pull/7902#issuecomment-470113472
Thanks a lot for working on this so quickly, @lamber-ken! 😃 I'll merge once
Travis is green and th
zentol commented on issue #7897: [FLINK-11817] Uses aggregate function in
DataStream API Tutorial
URL: https://github.com/apache/flink/pull/7897#issuecomment-470113504
@flinkbot approve-until quality
This is an automated mess
zentol commented on a change in pull request #7897: [FLINK-11817] Uses
aggregate function in DataStream API Tutorial
URL: https://github.com/apache/flink/pull/7897#discussion_r262947145
##
File path: docs/tutorials/datastream_api.md
##
@@ -368,14 +398,14 @@ The output of t
zentol commented on a change in pull request #7897: [FLINK-11817] Uses
aggregate function in DataStream API Tutorial
URL: https://github.com/apache/flink/pull/7897#discussion_r262946696
##
File path: docs/tutorials/datastream_api.md
##
@@ -240,13 +255,28 @@ public class Wi
flinkbot edited a comment on issue #7820: [FLINK-11742][Metrics]Push metrics to
Pushgateway without "instance"
URL: https://github.com/apache/flink/pull/7820#issuecomment-466942158
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
1 - 100 of 195 matches
Mail list logo
