[
https://issues.apache.org/jira/browse/FLINK-10683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10683.
-
Resolution: Won't Do
The stack trace line numbers indicate that the reporter uses an old Flink
flinkbot commented on issue #7875: [FLINK-11533] [container] Scan class path
for entry class (backport)
URL: https://github.com/apache/flink/pull/7875#issuecomment-468608532
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
zentol commented on a change in pull request #7820: [FLINK-11742][Metrics]Push
metrics to Pushgateway without "instance"
URL: https://github.com/apache/flink/pull/7820#discussion_r261541662
##
File path:
tillrohrmann commented on issue #7290: [FLINK-11137] [runtime] Fix unexpected
RegistrationTimeoutException of TaskExecutor
URL: https://github.com/apache/flink/pull/7290#issuecomment-468614535
Closing because this PR is superseded by #7808.
tillrohrmann closed pull request #7290: [FLINK-11137] [runtime] Fix unexpected
RegistrationTimeoutException of TaskExecutor
URL: https://github.com/apache/flink/pull/7290
This is an automated message from the Apache Git
zentol closed pull request #3554: Detached (Remote)StreamEnvironment execution
URL: https://github.com/apache/flink/pull/3554
This is an automated message from the Apache Git Service.
To respond to the message, please log on
zentol commented on issue #4717: [FLINK-3831][build][WIP] POM Cleanup
flink-streaming-java
URL: https://github.com/apache/flink/pull/4717#issuecomment-468615643
We will have to redo this from scratch since too much time has passed.
zentol commented on issue #4715: [FLINK-3830][build][WIP] POM Cleanup
flink-scala
URL: https://github.com/apache/flink/pull/4715#issuecomment-468615620
We will have to redo this from scratch since too much time has passed.
zentol closed pull request #4713: [FLINK-3828][build][WIP] POM Cleanup
flink-runtime
URL: https://github.com/apache/flink/pull/4713
This is an automated message from the Apache Git Service.
To respond to the message, please
zentol closed pull request #4718: [FLINK-3832][build][WIP] POM Cleanup
flink-streaming-scala
URL: https://github.com/apache/flink/pull/4718
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-3830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3830:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from flink-scala
>
[
https://issues.apache.org/jira/browse/FLINK-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3832:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from
zentol closed pull request #4719: [FLINK-3829][build][WIP] POM Cleanup
flink-java
URL: https://github.com/apache/flink/pull/4719
This is an automated message from the Apache Git Service.
To respond to the message, please
zentol commented on issue #4714: [FLINK-7577][build][WIP] POM Cleanup flink-core
URL: https://github.com/apache/flink/pull/4714#issuecomment-468615611
We will have to redo this from scratch since too much time has passed.
zentol closed pull request #4717: [FLINK-3831][build][WIP] POM Cleanup
flink-streaming-java
URL: https://github.com/apache/flink/pull/4717
This is an automated message from the Apache Git Service.
To respond to the
zentol closed pull request #4715: [FLINK-3830][build][WIP] POM Cleanup
flink-scala
URL: https://github.com/apache/flink/pull/4715
This is an automated message from the Apache Git Service.
To respond to the message, please
zentol commented on issue #4719: [FLINK-3829][build][WIP] POM Cleanup flink-java
URL: https://github.com/apache/flink/pull/4719#issuecomment-468615664
We will have to redo this from scratch since too much time has passed.
zentol closed pull request #4714: [FLINK-7577][build][WIP] POM Cleanup
flink-core
URL: https://github.com/apache/flink/pull/4714
This is an automated message from the Apache Git Service.
To respond to the message, please
zentol commented on issue #4718: [FLINK-3832][build][WIP] POM Cleanup
flink-streaming-scala
URL: https://github.com/apache/flink/pull/4718#issuecomment-468615653
We will have to redo this from scratch since too much time has passed.
zentol closed pull request #4716: [FLINK-3833][build][WIP] POM Cleanup
flink-test-utils
URL: https://github.com/apache/flink/pull/4716
This is an automated message from the Apache Git Service.
To respond to the message,
zentol commented on issue #4716: [FLINK-3833][build][WIP] POM Cleanup
flink-test-utils
URL: https://github.com/apache/flink/pull/4716#issuecomment-468615626
We will have to redo this from scratch since too much time has passed.
zentol commented on issue #4713: [FLINK-3828][build][WIP] POM Cleanup
flink-runtime
URL: https://github.com/apache/flink/pull/4713#issuecomment-468615595
We will have to redo this from scratch since too much time has passed.
zentol commented on issue #7305: [FLINK-11161]Unable to import java packages in
scala-shell
URL: https://github.com/apache/flink/pull/7305#issuecomment-468619871
JIRA has been closed.
This is an automated message from the
aljoscha opened a new pull request #7876: [FLINK-11751] Extend release notes
for Flink 1.8
URL: https://github.com/apache/flink/pull/7876
This is an automated message from the Apache Git Service.
To respond to the message,
tarmazakov commented on issue #7858: [FLINK-11787] Update Kubernetes resources:
workaround to make TM reachable from JM in Kubernetes
URL: https://github.com/apache/flink/pull/7858#issuecomment-468629356
Hi, thank you for this WA.
I downloaded the flink.tgz from
[
https://issues.apache.org/jira/browse/FLINK-10988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781516#comment-16781516
]
Till Rohrmann commented on FLINK-10988:
---
Thanks for opening this issue [~scottsue]. Wouldn't it be
[
https://issues.apache.org/jira/browse/FLINK-10988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10988:
--
Component/s: (was: Runtime / Coordination)
Runtime / Operators
> Improve
azagrebin commented on issue #7186: [FLINK-10941] Keep slots which contain
unconsumed result partitions
URL: https://github.com/apache/flink/pull/7186#issuecomment-468605747
@zhijiangW
Thanks for your answer. The consumer will close the connection on its side.
If consumer fails
uce opened a new pull request #7874: [FLINK-11752] [dist] Move flink-python to
opt (backport)
URL: https://github.com/apache/flink/pull/7874
Backport of #7843 to `release-1.8`. Cherry picked d637d8613d without any
conflicts.
I talked to @aljoscha (1.8 release manager) before
zentol commented on issue #7874: [FLINK-11752] [dist] Move flink-python to opt
(backport)
URL: https://github.com/apache/flink/pull/7874#issuecomment-468610182
Please to remember to set the `fixVersion` to `1.8.0`.
This is
[
https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781527#comment-16781527
]
Till Rohrmann commented on FLINK-10658:
---
Could you share the logs with us to see what's going on
zentol closed pull request #2412: FLINK-4462 Add RUN_TIME retention policy for
all the flink annotations
URL: https://github.com/apache/flink/pull/2412
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-11137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11137.
-
Resolution: Duplicate
> Unexpected RegistrationTimeoutException of TaskExecutor
>
[
https://issues.apache.org/jira/browse/FLINK-4462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-4462:
--
Labels: pull-request-available (was: )
> Add RUN_TIME retention policy for all the flink
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3829:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from flink-java
>
[
https://issues.apache.org/jira/browse/FLINK-3833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3833:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from flink-test-utils
>
[
https://issues.apache.org/jira/browse/FLINK-3831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3831:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from flink-streaming-java
[
https://issues.apache.org/jira/browse/FLINK-3828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3828:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from flink-runtime
>
[
https://issues.apache.org/jira/browse/FLINK-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7577:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from flink-core
>
zentol commented on issue #4724: [FLINK-7690] [Cluster Management] Do not call
actorSystem.awaitTermination from akka's main message han…
URL: https://github.com/apache/flink/pull/4724#issuecomment-468616139
JIRA has been closed.
zentol commented on issue #6493: [FLINK-10058] Add
getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6493#issuecomment-468617533
flink-streaming-python is in a limbo state and I can't get a clear answer
whether we want to
zentol commented on issue #6475: [FLINK-10012] Add
setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API
URL: https://github.com/apache/flink/pull/6475#issuecomment-468617559
flink-streaming-python is in a limbo state and I can't get a clear answer
whether we want to
zentol commented on issue #6476: [FLINK-10025] Add getCheckpointConfig API for
PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6476#issuecomment-468617542
flink-streaming-python is in a limbo state and I can't get a clear answer
whether we want to continue
zentol closed pull request #7325: [FLINK-11162][rest] Provide a rest API to
list all logical operators
URL: https://github.com/apache/flink/pull/7325
This is an automated message from the Apache Git Service.
To respond to
zentol closed pull request #6962: change accumulator value to be formatted with
digit group separator
URL: https://github.com/apache/flink/pull/6962
This is an automated message from the Apache Git Service.
To respond to
zentol commented on issue #7325: [FLINK-11162][rest] Provide a rest API to list
all logical operators
URL: https://github.com/apache/flink/pull/7325#issuecomment-468618728
As out-lined in the JIRA I would like to have this but the required changes
for a proper implementation (that covers
[
https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11336:
--
Issue Type: Bug (was: Improvement)
> Flink HA didn't remove ZK metadata
>
zentol closed pull request #7305: [FLINK-11161]Unable to import java packages
in scala-shell
URL: https://github.com/apache/flink/pull/7305
This is an automated message from the Apache Git Service.
To respond to the
aljoscha commented on issue #7156: [FLINK-10967] Update kafka dependency to
2.1.1
URL: https://github.com/apache/flink/pull/7156#issuecomment-468626863
Could you try and rebase to latest master?
This is an automated message
shengjk commented on issue #7751: [FLINK-11608] [docs] Translate the "Local
Setup Tutorial" page into Chinese
URL: https://github.com/apache/flink/pull/7751#issuecomment-468642467
ok @wuchong ,thank you
This is an automated
flinkbot commented on issue #7874: [FLINK-11752] [dist] Move flink-python to
opt (backport)
URL: https://github.com/apache/flink/pull/7874#issuecomment-468607399
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
uce opened a new pull request #7875: [FLINK-11533] [container] Scan class path
for entry class (backport)
URL: https://github.com/apache/flink/pull/7875
Backport of #7717 to `release-1.8`. Cherry picked bd60104dc1, b54fb2e626,
34aa3f5ac9, 1f1cc86a82, 753e0c618a without any conflicts.
[
https://issues.apache.org/jira/browse/FLINK-9029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9029.
Resolution: Won't Do
Flink 1.4.x is no longer supported. Please try out whether this problem also
[
https://issues.apache.org/jira/browse/FLINK-4462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4462.
---
Resolution: Won't Do
No clear use-case has been provided.
> Add RUN_TIME retention policy
[
https://issues.apache.org/jira/browse/FLINK-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7690:
--
Labels: flip-6 pull-request-available (was: flip-6)
> Do not call
[
https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-10737:
-
Priority: Critical (was: Blocker)
>
zentol commented on issue #5076: [FLINK-7574][build] POM Cleanup flink-clients
URL: https://github.com/apache/flink/pull/5076#issuecomment-468616292
We will have to redo this from scratch since too much time has passed.
This
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7574:
--
Labels: pull-request-available (was: )
> Remove unused dependencies from flink-clients
>
zentol closed pull request #5076: [FLINK-7574][build] POM Cleanup flink-clients
URL: https://github.com/apache/flink/pull/5076
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781538#comment-16781538
]
Till Rohrmann commented on FLINK-10756:
---
The second issue should not be a problem if we allow
zentol closed pull request #4724: [FLINK-7690] [Cluster Management] Do not call
actorSystem.awaitTermination from akka's main message han…
URL: https://github.com/apache/flink/pull/4724
This is an automated message from the
zentol closed pull request #6475: [FLINK-10012] Add
setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API
URL: https://github.com/apache/flink/pull/6475
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781544#comment-16781544
]
Till Rohrmann commented on FLINK-10756:
---
I checked and the {{JobGraph}} is submitted with
zentol closed pull request #6493: [FLINK-10058] Add
getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6493
This is an automated message from the Apache Git
zentol closed pull request #6476: [FLINK-10025] Add getCheckpointConfig API for
PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6476
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-11336:
-
Assignee: Till Rohrmann
> Flink HA didn't remove ZK metadata
>
flinkbot commented on issue #7876: [FLINK-11751] Extend release notes for Flink
1.8
URL: https://github.com/apache/flink/pull/7876#issuecomment-468623662
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request.
zhijiangW commented on issue #7186: [FLINK-10941] Keep slots which contain
unconsumed result partitions
URL: https://github.com/apache/flink/pull/7186#issuecomment-468624034
@azagrebin , `sendFailIntermediateResultPartitionsRpcCall` is mainly used
for the scenario that the producer task
[
https://issues.apache.org/jira/browse/FLINK-11751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11751:
---
Labels: pull-request-available (was: )
> Extend release notes for Flink 1.8
>
zhijiangW edited a comment on issue #7186: [FLINK-10941] Keep slots which
contain unconsumed result partitions
URL: https://github.com/apache/flink/pull/7186#issuecomment-468624034
@azagrebin , `sendFailIntermediateResultPartitionsRpcCall` is mainly used
for the scenario that the producer
tillrohrmann commented on issue #7858: [FLINK-11787] Update Kubernetes
resources: workaround to make TM reachable from JM in Kubernetes
URL: https://github.com/apache/flink/pull/7858#issuecomment-468638351
The script needs to be updated to call `exec $(drop_privs_cmd)
[
https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-11397.
--
Resolution: Cannot Reproduce
I'm closing this issue, since there is no known performance
rmetzger commented on issue #7801: [FLINK-11722][javadocs] Fix the outdated
java doc in AkkaRpcServiceUtils
URL: https://github.com/apache/flink/pull/7801#issuecomment-468734372
@flinkbot please re-evaluate the labels for this pull request
flinkbot edited a comment on issue #7801: [FLINK-11722][javadocs] Fix the
outdated java doc in AkkaRpcServiceUtils
URL: https://github.com/apache/flink/pull/7801#issuecomment-466295037
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261712788
##
File path:
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261709583
##
File path:
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261715744
##
File path:
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261708410
##
File path:
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261715920
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-11617.
--
Resolution: Fixed
Fix Version/s: 1.8.0
> Kinesis Connector getRecords() failure
Xeli edited a comment 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-468731002
Hello @rmetzger
Let me address them point by point:
1.
I really
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261769464
##
File path:
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261769488
##
File path:
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261769531
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782230#comment-16782230
]
Thomas Weise commented on FLINK-11617:
--
1.8: 704bc60bdb02681170a74ffcac72bfdab6658548
> Kinesis
[
https://issues.apache.org/jira/browse/FLINK-7344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782248#comment-16782248
]
vinoyang commented on FLINK-7344:
-
Hi all, if no one is working on this, I will try to take over.
>
Xeli edited a comment 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-468731002
Hello @rmetzger
Let me address them point by point:
1.
I really
flinkbot edited a comment on issue #7706: [FLINK-11617] [kinesis connector]
Kinesis Connector getRecords() failure logging is misleading
URL: https://github.com/apache/flink/pull/7706#issuecomment-463632400
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot.
flinkbot edited a comment on issue #7850: [FLINK-11183][metrics] Properly
measure current memory usage
URL: https://github.com/apache/flink/pull/7850#issuecomment-467904893
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #7862: [FLINK-11779] CLI ignores -m
parameter if high-availability is ZOOKEEPER
URL: https://github.com/apache/flink/pull/7862#issuecomment-468252495
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
flinkbot edited a comment on issue #7843: [FLINK-11752] [dist] Move
flink-python to opt
URL: https://github.com/apache/flink/pull/7843#issuecomment-467624899
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
flinkbot edited a comment on issue #7874: [FLINK-11752] [dist] Move
flink-python to opt (backport)
URL: https://github.com/apache/flink/pull/7874#issuecomment-468607399
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #7826: [hotfix] fix typos in description
URL: https://github.com/apache/flink/pull/7826#issuecomment-467018196
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
flinkbot edited a comment on issue #7822: [FLINK-11726][network] Refactor the
creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#issuecomment-466952983
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add
ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#issuecomment-462574731
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
pnowojski edited a comment on issue #7713: [FLINK-10995][network] Copy
intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#issuecomment-468709668
@zhijiangW in what scenarios is the `RecordWriter` being used for
broadcasting
flinkbot edited a comment on issue #7713: [FLINK-10995][network] Copy
intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#issuecomment-463979858
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
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-468731002
Hello @rmetzger
Let me address them point by point:
1.
I really like the
flinkbot edited a comment on issue #7879: [FLINK-11791] Describe how to build
Flink with Hadoop in build guide
URL: https://github.com/apache/flink/pull/7879#issuecomment-468697094
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
Konstantin Knauf created FLINK-11792:
Summary: Make KafkaConsumer more resilient to Kafka Broker
Failures
Key: FLINK-11792
URL: https://issues.apache.org/jira/browse/FLINK-11792
Project: Flink
1 - 100 of 274 matches
Mail list logo
