[
https://issues.apache.org/jira/browse/FLINK-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652895#comment-16652895
]
chenlf commented on FLINK-10564:
wo found some tasks failed after runing serveral hours.here is the
Jiayi Liao created FLINK-10578:
--
Summary: Support writable state in QueryableStateClient
Key: FLINK-10578
URL: https://issues.apache.org/jira/browse/FLINK-10578
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10569:
-
Description:
Legacy class {{Scheduler}} and {{Instance}} are still used in some valid tests
like
[
https://issues.apache.org/jira/browse/FLINK-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun reassigned FLINK-10569:
Assignee: TisonKun
> Clean up uses of Scheduler and Instance in valid tests
>
[
https://issues.apache.org/jira/browse/FLINK-10577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanghao updated FLINK-10577:
-
Description:
I think greedy operator has some problem.
Given the below java code:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-10577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanghao updated FLINK-10577:
-
Description:
I think greedy operator has some problem.
Given the below java code:
{code:java}
zhanghao created FLINK-10577:
Summary: CEP's greedy() doesn't work
Key: FLINK-10577
URL: https://issues.apache.org/jira/browse/FLINK-10577
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652877#comment-16652877
]
ASF GitHub Bot commented on FLINK-10134:
XuQianJin-Stars commented on issue #6823: [FLINK-10134]
XuQianJin-Stars commented on issue #6823: [FLINK-10134] UTF-16 support for
TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#issuecomment-430469738
@fhueske Thank you very much again for your review, I will modify the code
according to your comments,Then submit
[
https://issues.apache.org/jira/browse/FLINK-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652769#comment-16652769
]
chenlf edited comment on FLINK-10564 at 10/17/18 2:31 AM:
--
the version of flink
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652868#comment-16652868
]
ASF GitHub Bot commented on FLINK-10205:
wenlong88 commented on issue #6684: [FLINK-10205]
wenlong88 commented on issue #6684: [FLINK-10205] Batch Job: InputSplit
Fault tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-430467136
hi, @tillrohrmann @isunjin , we have encountered the same issue in region
failover, and fix with a similar
[
https://issues.apache.org/jira/browse/FLINK-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652863#comment-16652863
]
TisonKun commented on FLINK-10575:
--
[~isunjin] did you analyze the code path relevant?
For my
[
https://issues.apache.org/jira/browse/FLINK-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10562:
Assignee: vinoyang
> Relax (or document) table name constraints
>
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652814#comment-16652814
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9697] Provide
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-430458901
@zentol I did increase the timeout for some tests, because in the new kafka
client, the default timeout for some APIs (the API for
[
https://issues.apache.org/jira/browse/FLINK-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenlf updated FLINK-10564:
---
Description:
it works fine until the number of tasks is above about 400.
There are 600+ tasks(each task
[
https://issues.apache.org/jira/browse/FLINK-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652769#comment-16652769
]
chenlf edited comment on FLINK-10564 at 10/17/18 1:12 AM:
--
the version of flink
[
https://issues.apache.org/jira/browse/FLINK-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652779#comment-16652779
]
chenlf commented on FLINK-10564:
i will appritiate it if you could give me some clues.i am in a big
[
https://issues.apache.org/jira/browse/FLINK-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652769#comment-16652769
]
chenlf commented on FLINK-10564:
the version of flink we use is 1.2.1.[~Tison]
> tm costs too much
[
https://issues.apache.org/jira/browse/FLINK-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652769#comment-16652769
]
chenlf edited comment on FLINK-10564 at 10/17/18 1:01 AM:
--
the version of flink
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652761#comment-16652761
]
ASF GitHub Bot commented on FLINK-10205:
isunjin commented on issue #6684: [FLINK-10205]
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault
tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-430451645
@tillrohrmann i think the splits need be strictly consumed by failed job.
otherwise the logic to make data
[
https://issues.apache.org/jira/browse/FLINK-10567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652633#comment-16652633
]
ASF GitHub Bot commented on FLINK-10567:
Aitozi commented on issue #6860: [FLINK-10567]Fix
Aitozi commented on issue #6860: [FLINK-10567]Fix TtlStateSerializer lost field
during duplicate()
URL: https://github.com/apache/flink/pull/6860#issuecomment-430434802
cc @StefanRRichter @azagrebin
This is an automated
JIN SUN created FLINK-10576:
---
Summary: Introduce Machine/Node/TM health management
Key: FLINK-10576
URL: https://issues.apache.org/jira/browse/FLINK-10576
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10247.
---
Resolution: Fixed
Fix Version/s: (was: 1.5.5)
(was: 1.6.2)
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646054#comment-16646054
]
Till Rohrmann edited comment on FLINK-10247 at 10/16/18 10:34 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652566#comment-16652566
]
ASF GitHub Bot commented on FLINK-10213:
joey opened a new pull request #6862: [FLINK-10213]
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10247:
---
> Run MetricQueryService in separate thread pool
>
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652565#comment-16652565
]
ASF GitHub Bot commented on FLINK-10253:
tillrohrmann commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10213:
---
Labels: pull-request-available (was: )
> Task managers cache a negative DNS lookup of the
joey opened a new pull request #6862: [FLINK-10213] Task managers cache a
negative DNS lookup of the blob server indefinitely
URL: https://github.com/apache/flink/pull/6862
## What is the purpose of the change
This pull request fixes a bug where a negative DNS resolution for the
tillrohrmann commented on a change in pull request #6839: [FLINK-10253] Run
MetricQueryService with lower priority
URL: https://github.com/apache/flink/pull/6839#discussion_r225729531
##
File path:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
[
https://issues.apache.org/jira/browse/FLINK-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10405.
---
Resolution: Fixed
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652551#comment-16652551
]
ASF GitHub Bot commented on FLINK-10405:
tillrohrmann closed pull request #6841: [FLINK-10405]
tillrohrmann closed pull request #6841: [FLINK-10405] [tests] Port
JobManagerFailsITCase to new code base
URL: https://github.com/apache/flink/pull/6841
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
[
https://issues.apache.org/jira/browse/FLINK-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652542#comment-16652542
]
JIN SUN commented on FLINK-10575:
-
[~till.rohrmann] does this sound reasonable?
> Remove deprecated
JIN SUN created FLINK-10575:
---
Summary: Remove deprecated ExecutionGraphBuilder.buildGraph method
Key: FLINK-10575
URL: https://issues.apache.org/jira/browse/FLINK-10575
Project: Flink
Issue Type:
JIN SUN created FLINK-10574:
---
Summary: Update documents of new batch job failover strategy
Key: FLINK-10574
URL: https://issues.apache.org/jira/browse/FLINK-10574
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN reassigned FLINK-10574:
---
Assignee: JIN SUN
> Update documents of new batch job failover strategy
>
JIN SUN created FLINK-10573:
---
Summary: Support task revocation
Key: FLINK-10573
URL: https://issues.apache.org/jira/browse/FLINK-10573
Project: Flink
Issue Type: Sub-task
Components:
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652462#comment-16652462
]
ASF GitHub Bot commented on FLINK-10354:
asfgit closed pull request #6859: Revert FLINK-10354
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652463#comment-16652463
]
ASF GitHub Bot commented on FLINK-10354:
asfgit closed pull request #6858: Revert FLINK-10354
asfgit closed pull request #6858: Revert FLINK-10354 and FLINK-10247 for
release-1.5
URL: https://github.com/apache/flink/pull/6858
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
asfgit closed pull request #6859: Revert FLINK-10354 and FLINK-10247 for
release-1.6
URL: https://github.com/apache/flink/pull/6859
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
JIN SUN created FLINK-10572:
---
Summary: Enable Per-job level failover strategy.
Key: FLINK-10572
URL: https://issues.apache.org/jira/browse/FLINK-10572
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-9443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9443.
---
Resolution: Fixed
Fix Version/s: 1.7.0
master:
[
https://issues.apache.org/jira/browse/FLINK-9443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652365#comment-16652365
]
ASF GitHub Bot commented on FLINK-9443:
---
zentol closed pull request #6080: [FLINK-9443]Remove
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652362#comment-16652362
]
ASF GitHub Bot commented on FLINK-8887:
---
zentol commented on issue #5648: [FLINK-8887][flip-6]
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652363#comment-16652363
]
ASF GitHub Bot commented on FLINK-8887:
---
zentol closed pull request #5648: [FLINK-8887][flip-6]
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8887:
--
Labels: flip-6 pull-request-available (was: flip-6)
> ClusterClient.getJobStatus can throw
zentol closed pull request #6080: [FLINK-9443]Remove unused parameter in
generateNodeLocalHash
URL: https://github.com/apache/flink/pull/6080
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As
zentol commented on issue #5648: [FLINK-8887][flip-6]
ClusterClient.getJobStatus can throw FencingTokenException
URL: https://github.com/apache/flink/pull/5648#issuecomment-430378301
Already fixed.
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652355#comment-16652355
]
ASF GitHub Bot commented on FLINK-8917:
---
zentol commented on issue #5686: [FLINK-8917]
zentol closed pull request #5648: [FLINK-8887][flip-6]
ClusterClient.getJobStatus can throw FencingTokenException
URL: https://github.com/apache/flink/pull/5648
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
[
https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652359#comment-16652359
]
ASF GitHub Bot commented on FLINK-8917:
---
zentol commented on issue #5678: [FLINK-8917]
[
https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652356#comment-16652356
]
ASF GitHub Bot commented on FLINK-8917:
---
zentol closed pull request #5686: [FLINK-8917]
[
https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652360#comment-16652360
]
ASF GitHub Bot commented on FLINK-8917:
---
zentol closed pull request #5678: [FLINK-8917]
[
https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8917.
---
Resolution: Won't Fix
Fix Version/s: (was: 1.4.3)
The affected classes will be
zentol closed pull request #5678: [FLINK-8917] [Job-Submission]
FlinkMiniCluster haService not same as ClusterClient
URL: https://github.com/apache/flink/pull/5678
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
zentol commented on issue #5678: [FLINK-8917] [Job-Submission] FlinkMiniCluster
haService not same as ClusterClient
URL: https://github.com/apache/flink/pull/5678#issuecomment-430378120
Duplicates #5686.
This is an automated
zentol commented on issue #5686: [FLINK-8917] [Job-Submission] FlinkMiniCluster
default createHighAvailabilityServices is not same as ClusterClient
URL: https://github.com/apache/flink/pull/5686#issuecomment-430377948
The affected classes will be removed soon in FLINK-10540.
zentol closed pull request #5686: [FLINK-8917] [Job-Submission]
FlinkMiniCluster default createHighAvailabilityServices is not same as
ClusterClient
URL: https://github.com/apache/flink/pull/5686
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge,
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652352#comment-16652352
]
ASF GitHub Bot commented on FLINK-8623:
---
zentol closed pull request #5449: [FLINK-8623]
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652351#comment-16652351
]
ASF GitHub Bot commented on FLINK-8623:
---
zentol commented on issue #5449: [FLINK-8623]
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8623.
---
Resolution: Duplicate
Fix Version/s: (was: 1.5.5)
(was:
zentol closed pull request #5449: [FLINK-8623]
ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuri…
URL: https://github.com/apache/flink/pull/5449
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
zentol commented on issue #5449: [FLINK-8623]
ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuri…
URL: https://github.com/apache/flink/pull/5449#issuecomment-430376913
Subsumed in FLINK-4052.
This is an automated
zentol closed pull request #4374: repalce map.put with putIfAbsent
URL: https://github.com/apache/flink/pull/4374
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request
zentol commented on issue #4374: repalce map.put with putIfAbsent
URL: https://github.com/apache/flink/pull/4374#issuecomment-430375319
The TaskManager class is about to be removed.
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652343#comment-16652343
]
ASF GitHub Bot commented on FLINK-6387:
---
zentol commented on issue #3777: [FLINK-6387]
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652344#comment-16652344
]
ASF GitHub Bot commented on FLINK-6387:
---
zentol closed pull request #3777: [FLINK-6387]
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6387.
---
Resolution: Fixed
All incoming requests are logged as TRACE messages by the
zentol commented on issue #3777: [FLINK-6387] [webfrontend]Flink UI support
access log
URL: https://github.com/apache/flink/pull/3777#issuecomment-430374982
Subsumed in FLINK-7040.
This is an automated message from the
zentol closed pull request #3777: [FLINK-6387] [webfrontend]Flink UI support
access log
URL: https://github.com/apache/flink/pull/3777
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
[
https://issues.apache.org/jira/browse/FLINK-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652325#comment-16652325
]
ASF GitHub Bot commented on FLINK-5103:
---
zentol closed pull request #2833: [FLINK-5103] [Metrics]
[
https://issues.apache.org/jira/browse/FLINK-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5103.
---
Resolution: Duplicate
> TaskManager process virtual memory and physical memory used size
[
https://issues.apache.org/jira/browse/FLINK-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652324#comment-16652324
]
ASF GitHub Bot commented on FLINK-5103:
---
zentol commented on issue #2833: [FLINK-5103] [Metrics]
[
https://issues.apache.org/jira/browse/FLINK-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5103:
--
Labels: pull-request-available (was: )
> TaskManager process virtual memory and physical
zentol commented on issue #2833: [FLINK-5103] [Metrics] TaskManager process
virtual memory and physical memory used size gauge
URL: https://github.com/apache/flink/pull/2833#issuecomment-430372098
Subsumed in FLINK-7812.
zentol closed pull request #2833: [FLINK-5103] [Metrics] TaskManager process
virtual memory and physical memory used size gauge
URL: https://github.com/apache/flink/pull/2833
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4840.
---
Resolution: Won't Fix
The required time-measurement per record would make this too
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-4840:
--
Labels: pull-request-available (was: )
> Measure latency of record processing and expose it
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652317#comment-16652317
]
ASF GitHub Bot commented on FLINK-4840:
---
zentol closed pull request #2753: [FLINK-4840] [metrics]
zentol closed pull request #2753: [FLINK-4840] [metrics] Measure latency of
record processing and expose it as a metric
URL: https://github.com/apache/flink/pull/2753
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
zentol commented on issue #2288: Feature/s3 a fix
URL: https://github.com/apache/flink/pull/2288#issuecomment-430369667
Subsumed in #4939.
This is an automated message from the Apache Git Service.
To respond to the message,
zentol closed pull request #2288: Feature/s3 a fix
URL: https://github.com/apache/flink/pull/2288
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork),
[
https://issues.apache.org/jira/browse/FLINK-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-10509:
Assignee: Chesnay Schepler
> Drop flink-storm
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-10571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-10571:
Assignee: Chesnay Schepler
> Remove support for topologies
>
Chesnay Schepler created FLINK-10571:
Summary: Remove support for topologies
Key: FLINK-10571
URL: https://issues.apache.org/jira/browse/FLINK-10571
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652298#comment-16652298
]
ASF GitHub Bot commented on FLINK-2720:
---
zentol closed pull request #1157:
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-2720:
--
Labels: pull-request-available (was: )
> Add Storm-CountMetric in flink-stormcompatibility
>
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652297#comment-16652297
]
ASF GitHub Bot commented on FLINK-2720:
---
zentol commented on issue #1157:
zentol commented on issue #1157: [FLINK-2720][storm-compatibility]Add
Storm-CountMetric for storm metrics
URL: https://github.com/apache/flink/pull/1157#issuecomment-430367074
subsumed by #3615.
This is an automated message
zentol closed pull request #1157: [FLINK-2720][storm-compatibility]Add
Storm-CountMetric for storm metrics
URL: https://github.com/apache/flink/pull/1157
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
Thomas Wozniakowski created FLINK-10570:
---
Summary: State grows unbounded when "within" constraint not applied
Key: FLINK-10570
URL: https://issues.apache.org/jira/browse/FLINK-10570
Project:
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652132#comment-16652132
]
ASF GitHub Bot commented on FLINK-9697:
---
zentol commented on issue #6703: [FLINK-9697] Provide
zentol commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-430329421
@aljoscha @yanghua Did we just merge another kafka connector that takes more
than 10 minutes to test?
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652045#comment-16652045
]
ASF GitHub Bot commented on FLINK-7964:
---
yanghua commented on issue #6577: [FLINK-7964] Add Apache
1 - 100 of 452 matches
Mail list logo
