[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196946#comment-16196946
]
ASF GitHub Bot commented on FLINK-5005:
---
Github user DieBauer commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196947#comment-16196947
]
ASF GitHub Bot commented on FLINK-5005:
---
Github user DieBauer closed the pull request at:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4763#discussion_r143489310
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java
---
@@ -33,8 +33,7 @@
objectMapper.enable(
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197099#comment-16197099
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user zentol commented on a diff in the pull request:
Chesnay Schepler created FLINK-7781:
---
Summary: Support sime on-demand metrics aggregation
Key: FLINK-7781
URL: https://issues.apache.org/jira/browse/FLINK-7781
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197027#comment-16197027
]
Ajay commented on FLINK-7782:
-
1. Using an env parallelism of 1 performed similar with the additional problem
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197091#comment-16197091
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r143487841
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -0,0 +1,410 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4763#discussion_r143499239
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -0,0 +1,534 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197144#comment-16197144
]
Aljoscha Krettek commented on FLINK-7167:
-
Thanks for pointing this out, [~phoenixjiangnan]. There
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197156#comment-16197156
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user zentol commented on a diff in the pull request:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4786#discussion_r143502884
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java
---
@@ -79,7 +79,6 @@ public void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4763#discussion_r143502870
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -0,0 +1,534 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7575.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: c7968e9c2ad6601f9f38b673ead5bc71611a6fbd
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4749
Users shouldn't be able to call `shutdown()` and if they are, they
shouldn't be using it (it would be incorrect). `shutdown()` was a protected
method and shouldn't be used the users. Unfortunately
[
https://issues.apache.org/jira/browse/FLINK-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197022#comment-16197022
]
ASF GitHub Bot commented on FLINK-7761:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5510.
---
Resolution: Duplicate
With the QS client reworking of FLINK-7770 this issue becomes obsolete
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197137#comment-16197137
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4763#discussion_r143500886
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -0,0 +1,534 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4763#discussion_r143505801
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -0,0 +1,534 @@
+/*
+
Ajay created FLINK-7782:
---
Summary: Flink CEP not recognizing pattern
Key: FLINK-7782
URL: https://issues.apache.org/jira/browse/FLINK-7782
Project: Flink
Issue Type: Bug
Reporter: Ajay
I
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4773
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7783:
Summary: Don't always remove checkpoints in
ZooKeeperCompletedCheckpointStore#recover()
[
https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7495:
Component/s: (was: State Backends, Checkpointing)
DataStream API
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4763#discussion_r143504804
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -0,0 +1,534 @@
+/*
+
Github user DieBauer closed the pull request at:
https://github.com/apache/flink/pull/3703
---
Github user DieBauer commented on the issue:
https://github.com/apache/flink/pull/3703
Hi, I'm sorry for the late reaction. I haven't found the time to work on
this anymore (also priorities shifted... )
Therefore this pull request is stale. (it still could be used as a
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4787
Is there any problem with the current implementation?
The current implementation was carefully done to gracefully handle
concurrent removals and allow to pick whether to clean directories
[
https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197009#comment-16197009
]
ASF GitHub Bot commented on FLINK-6615:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197108#comment-16197108
]
Kostas Kloudas commented on FLINK-7782:
---
Hi [~ajkrishna], as seen in the JIRA that you posted
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197131#comment-16197131
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197158#comment-16197158
]
ASF GitHub Bot commented on FLINK-7388:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197163#comment-16197163
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197028#comment-16197028
]
Ajay commented on FLINK-7782:
-
Here is an example of a simple event I am trying to detect. The first and last
Github user 1m2c3t4 commented on the issue:
https://github.com/apache/flink/pull/4784
All review comments addressed
---
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197132#comment-16197132
]
ASF GitHub Bot commented on FLINK-7736:
---
Github user 1m2c3t4 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197023#comment-16197023
]
Ajay commented on FLINK-7782:
-
Related to FLINK-7606
> Flink CEP not recognizing pattern
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4647
---
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197025#comment-16197025
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197024#comment-16197024
]
ASF GitHub Bot commented on FLINK-7739:
---
Github user pnowojski commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197094#comment-16197094
]
Kostas Kloudas commented on FLINK-7606:
---
I do not think that this would solve the problem.
In event
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197170#comment-16197170
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user tillrohrmann commented on a diff in the pull
Aljoscha Krettek created FLINK-7783:
---
Summary: Don't always remove checkpoints
ZooKeeperCompletedCheckpointStore#recover()
Key: FLINK-7783
URL: https://issues.apache.org/jira/browse/FLINK-7783
Aljoscha Krettek created FLINK-7784:
---
Summary: Don't fail TwoPhaseCommitSinkFunction when failing to
commit
Key: FLINK-7784
URL: https://issues.apache.org/jira/browse/FLINK-7784
Project: Flink
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4777#discussion_r143480344
--- Diff: flink-core/pom.xml ---
@@ -77,6 +88,12 @@ under the License.
org.apache.commons
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197181#comment-16197181
]
ASF GitHub Bot commented on FLINK-7739:
---
Github user pnowojski commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4763#discussion_r143508371
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java
---
@@ -33,8 +33,7 @@
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197180#comment-16197180
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reopened FLINK-6219:
-
> Add a sorted state primitive
>
>
> Key: FLINK-6219
>
[
https://issues.apache.org/jira/browse/FLINK-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7761.
---
Resolution: Fixed
1.4: 08bfdae684548c2e9edf189f29d892335fd27dd3
> Twitter example is not
[
https://issues.apache.org/jira/browse/FLINK-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197215#comment-16197215
]
ASF GitHub Bot commented on FLINK-7761:
---
Github user zentol closed the pull request at:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4239
Merged! ð
Could you please close this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197379#comment-16197379
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user PangZhi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197188#comment-16197188
]
Bowen Li edited comment on FLINK-6219 at 10/9/17 4:18 PM:
--
[~fhueske] The new
[
https://issues.apache.org/jira/browse/FLINK-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197372#comment-16197372
]
Aljoscha Krettek commented on FLINK-7731:
-
No, FLINK-7700 is not related because we're not dealing
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4786#discussion_r143517965
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java
---
@@ -79,7 +79,6 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197245#comment-16197245
]
ASF GitHub Bot commented on FLINK-7388:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197278#comment-16197278
]
Fabian Hueske commented on FLINK-6219:
--
Thanks [~phoenixjiangnan], I updated the linked issue.
[
https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7750.
---
Resolution: Not A Problem
> Strange behaviour in savepoints
> ---
[
https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197240#comment-16197240
]
ASF GitHub Bot commented on FLINK-6615:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-6988.
---
Resolution: Fixed
Implemented in 2f651e9a69a9929ef154e7bf6fcba624b0e8b9a1 and surrounding
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4787
I was looking into
[FLINK-6615](https://issues.apache.org/jira/browse/FLINK-6615), and I think
6615 is not a problem due to files may be created concurrently. But I found the
current impl of
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197306#comment-16197306
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197323#comment-16197323
]
ASF GitHub Bot commented on FLINK-7072:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4742
---
Github user PangZhi commented on the issue:
https://github.com/apache/flink/pull/3748
@fhueske Hi zentol hasn't replied can you help to take a look. thx
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3748
When importing guava you have to explicitly add an exclusion to
https://github.com/apache/flink/blob/master/tools/maven/suppressions.xml.
---
Haohui Mai created FLINK-7787:
-
Summary: Remove guava dependency in the cassandra connector
Key: FLINK-7787
URL: https://issues.apache.org/jira/browse/FLINK-7787
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197497#comment-16197497
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197500#comment-16197500
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3748
Given we have dropped the support for Java 7, it might make sense to just
rewrite the class to use the completablefuture in java 8.
---
[
https://issues.apache.org/jira/browse/FLINK-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197582#comment-16197582
]
Chesnay Schepler commented on FLINK-7787:
-
we can't get rid of the cassandra guava dependency
Github user pnowojski closed the pull request at:
https://github.com/apache/flink/pull/4239
---
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4239
Thanks :)
---
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197420#comment-16197420
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197419#comment-16197419
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski closed the pull request at:
Kostas Kloudas created FLINK-7788:
-
Summary: Allow port range for queryable state client proxy.
Key: FLINK-7788
URL: https://issues.apache.org/jira/browse/FLINK-7788
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197673#comment-16197673
]
Fabian Hueske commented on FLINK-7548:
--
I've created a proposal for a reworked TableSource API that
[
https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7049:
--
Description:
After integration tests finish, TestingApplicationMaster is still running.
Toward the end of
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/4316
I think InterruptedException should be handled uniformly in
HadoopInputFormatBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197978#comment-16197978
]
ASF GitHub Bot commented on FLINK-6105:
---
Github user tedyu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197188#comment-16197188
]
Bowen Li commented on FLINK-6219:
-
[~fhueske] I think the dependency in 'Issues Link' is set wrong. This
Brice Bingman created FLINK-7786:
Summary: JarActionHandler.tokenizeArguments removes all quotes
from program arguments
Key: FLINK-7786
URL: https://issues.apache.org/jira/browse/FLINK-7786
Project:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/4773
---
[
https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197175#comment-16197175
]
Aljoscha Krettek commented on FLINK-7750:
-
If the data was not split when using Flink 1.2.x this
Chesnay Schepler created FLINK-7785:
---
Summary: DispatcherTest failure
Key: FLINK-7785
URL: https://issues.apache.org/jira/browse/FLINK-7785
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196560#comment-16196560
]
Yun Tang commented on FLINK-5510:
-
According to [FLINK-725 (Remove Flink Futures or back them by
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r143394582
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,93 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196572#comment-16196572
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user fhueske commented on a diff in the pull
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4742
Thanks for fixing the failing test cases @zentol. Travis passed. Merging
this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196577#comment-16196577
]
ASF GitHub Bot commented on FLINK-7072:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196579#comment-16196579
]
Fabian Hueske commented on FLINK-6219:
--
Hi [~phoenixjiangnan],
I think this feature would be very
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6219:
-
Description:
When we implement the OVER window of
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6219:
-
Summary: Add a sorted state primitive (was: Add a state backend which
supports sorting)
> Add a
[
https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6505:
---
Assignee: Bowen Li
> Proactively cleanup local FS for RocksDBKeyedStateBackend on startup
>
[
https://issues.apache.org/jira/browse/FLINK-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6684:
---
Assignee: Bowen Li
> Remove AsyncCheckpointRunnable from StreamTask
>
[
https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198175#comment-16198175
]
Ajay commented on FLINK-7782:
-
Hi Kostas,
My stream is pretty much unbounded in an endless loop and the
[
https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198175#comment-16198175
]
Ajay edited comment on FLINK-7782 at 10/10/17 5:15 AM:
---
Hi Kostas,
My stream is
[
https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198175#comment-16198175
]
Ajay edited comment on FLINK-7782 at 10/10/17 5:18 AM:
---
Hi Kostas,
My stream is
[
https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-7764:
--
Assignee: Xingcan Cui
> FlinkKafkaProducer010 does not accept name, uid, or parallelism
>
1 - 100 of 183 matches
Mail list logo
