Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2369
Just found some minor issues that can be fixed when merging.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525284#comment-15525284
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525278#comment-15525278
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80629075
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525277#comment-15525277
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80629176
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80628475
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525262#comment-15525262
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2517
zentol, thanks!
I am pushed edited implementation again.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525242#comment-15525242
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525190#comment-15525190
]
ASF GitHub Bot commented on FLINK-4339:
---
Github user KurtYoung commented on the issu
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2497
rebased to the latest flip-6 and use flink's own Future instead of scala's
Future
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525181#comment-15525181
]
ASF GitHub Bot commented on FLINK-4606:
---
Github user beyond1920 commented on the iss
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2540
@mxm , thanks for your review, I modified the pr based on your advices:
1. fIx checkstyle error, `AkkaRpcActorTest` testcase and
`RpcCompletenessTest` testcase. Sorry for those mistakes, I woul
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525179#comment-15525179
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
Ok. Then it should be clearly documented now. that the sink supports only
Puts/Deletes. So in future can the sink be updated with new APIs? I don't know
the procedure here in case new APIs have t
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525163#comment-15525163
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
I agree it might be an overkill. But in case of having an sink that only
supports Put/Delete, it would be better to have ordered execution than not,
after all HBase has this API so there could be som
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525128#comment-15525128
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
With in a single row you need guarantee of order of execution? I agree
Append/Increment or non-idempotent in certain failure cases but there is a
Nonce generator for that. I should say I have not
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525108#comment-15525108
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
Hi @ramkrish86 , I'm thinking replace batch() with mutateRow() because it
provides atomic ordered mutations for a single row, but it only supports Put
and Delete which should be fine since only Put a
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525031#comment-15525031
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
@delding
Do you have uses cases with Append/Increment?
I think with the batch() API we are not sure of the order of execution of
the batch() in the hbase server but still it would help us
[
https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525008#comment-15525008
]
ASF GitHub Bot commented on FLINK-4690:
---
GitHub user KurtYoung opened a pull request
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2552
[FLINK-4690] Replace SlotAllocationFuture with flink's own future
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/KurtYoung/flink flink-4690
Kurt Young created FLINK-4690:
-
Summary: Replace SlotAllocationFuture with flink's own future
Key: FLINK-4690
URL: https://issues.apache.org/jira/browse/FLINK-4690
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15524939#comment-15524939
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2369
@rmetzger Thanks for addressing the comments! Did a final pass, and the
changes look good to me.
I agree with merging the connector as is. Adding the timestamp to the
regular sink interface seem
[
https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15524850#comment-15524850
]
ASF GitHub Bot commented on FLINK-4606:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2540#discussion_r80612002
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -66,15 +67,16 @@
* {@link #requestSlo
[
https://issues.apache.org/jira/browse/FLINK-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15524806#comment-15524806
]
ASF GitHub Bot commented on FLINK-4653:
---
Github user beyond1920 commented on the iss
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2524
@mxm , thanks for your review. I modified the content based on your advice:
1. The changes could compile successfully now, sorry for the level mistake.
2. AwaitJobResult method in JobClientU
Kurt Young created FLINK-4689:
-
Summary: Implement a simple slot provider for the new job manager
Key: FLINK-4689
URL: https://issues.apache.org/jira/browse/FLINK-4689
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young resolved FLINK-4408.
---
Resolution: Fixed
> Submit Job and setup ExecutionGraph
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15524664#comment-15524664
]
ASF GitHub Bot commented on FLINK-4408:
---
Github user KurtYoung closed the pull reque
Github user KurtYoung closed the pull request at:
https://github.com/apache/flink/pull/2480
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is e
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15524101#comment-15524101
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user gyfora commented on the issue:
Github user gyfora commented on the issue:
https://github.com/apache/flink/pull/2509
@tzulitai makes sense ! As for for the Map you are right, the
multiple topic case slipped my mind :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian closed FLINK-598.
-
Resolution: Fixed
Closing since the sub-tasks are Closed and Resolved.
> Add suppo
[
https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523891#comment-15523891
]
ASF GitHub Bot commented on FLINK-4439:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2397
I've rebased to current master and triggered a build.
https://travis-ci.org/rmetzger/flink/builds/162871029
---
If your project is set up for it, you can reply to this email and have your
reply ap
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523868#comment-15523868
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2332
@nielsbasjes I want to avoid to exclude a version that is still in use by
existing Flink users. I do not have in insight in which HBase versions
currently in use. If (basically) everybody is on 1.1.x
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523849#comment-15523849
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user nielsbasjes commented on the is
Github user nielsbasjes commented on the issue:
https://github.com/apache/flink/pull/2332
@fhueske: What is "older" ?
I would like a clear statement about the (minimal) supported versions of
HBase.
I would see 1.1.x as old enough, or do you see 0.98 still required?
---
If yo
[
https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4688:
-
Attachment: stacktrace_76minsAfterSubmission.java
Stacktrace 76 mins after submission
> Optimizer
[
https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4688:
-
Attachment: stacktrace_shortlyAfterSubmission.java
Stacktrace shortly after submission
> Optimize
[
https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4688:
-
Attachment: stacktrace_32minsAfterSubmission.java
Stacktrace 32 mins after submission
> Optimize
Fabian Hueske created FLINK-4688:
Summary: Optimizer hangs for hours when optimizing complex plans
Key: FLINK-4688
URL: https://issues.apache.org/jira/browse/FLINK-4688
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523705#comment-15523705
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2509
Thank you for working on this. I gave #2369 some love today to speed up
things ;)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523703#comment-15523703
]
ASF GitHub Bot commented on FLINK-4439:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2397
Thank you. The pull request is now good to be merged!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have th
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523695#comment-15523695
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2369
@tzulitai I addressed all your comments except the one relating
`FlinkKafkaProducer010Configuration`: I had a quick offline discussion with
@StephanEwen about the issue and he suggested to add the t
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2529
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523636#comment-15523636
]
ASF GitHub Bot commented on FLINK-4241:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4241.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in ef15984988e883ced5311b332e5e5d8521c9573f.
[
https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523629#comment-15523629
]
ASF GitHub Bot commented on FLINK-4687:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2551
[FLINK-4687] [rpc] Add getAddress to RpcService
Adds the `getAddress` method to the `RpcService` which allows to retrieve
the address under which the `RpcService` is reachable.
You can merge t
Till Rohrmann created FLINK-4687:
Summary: Add getAddress method to RpcService
Key: FLINK-4687
URL: https://issues.apache.org/jira/browse/FLINK-4687
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4252.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in f150f987772c8d96f41a5acd1d20cba6622cb5c9.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2507
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523617#comment-15523617
]
ASF GitHub Bot commented on FLINK-4252:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4590.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 7eb45c133c49933b14719f06bf68ccf162a3e0b2.
[
https://issues.apache.org/jira/browse/FLINK-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523591#comment-15523591
]
ASF GitHub Bot commented on FLINK-4590:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2504
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4686:
Labels: starter (was: )
> Add possibility to get column names
> ---
Timo Walther created FLINK-4686:
---
Summary: Add possibility to get column names
Key: FLINK-4686
URL: https://issues.apache.org/jira/browse/FLINK-4686
Project: Flink
Issue Type: New Feature
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2535
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop-
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4573:
--
Description:
{code}
try {
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523472#comment-15523472
]
ASF GitHub Bot commented on FLINK-4662:
---
Github user asfgit closed the pull request
Stephan Ewen created FLINK-4685:
---
Summary: Gather operator checkpoint durations data sizes from the
runtime
Key: FLINK-4685
URL: https://issues.apache.org/jira/browse/FLINK-4685
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Description:
Checkpoint statistics contain the duration of a checkpoint, measured as from
the Check
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Fix Version/s: 1.2.0
> Report more information about operator checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Affects Version/s: 1.1.2
> Report more information about operator checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Priority: Major (was: Minor)
> Report more information about operator checkpoints
> ---
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Component/s: State Backends, Checkpointing
> Report more information about operator checkpoints
> --
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Summary: Report more information about operator checkpoints (was: Split
checkpoint times into synch
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2550
[Flink-4657] Implement HighAvailabilityServices based on zookeeper
This actually contains 3 commits. More details can be found here:
https://github.com/StephanEwen/incubator-flink/pull/15
You can
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523361#comment-15523361
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r80500304
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/expressionDsl.scala
---
@@ -223,10 +223,28 @@ trait ImplicitExpressionO
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523352#comment-15523352
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on a diff in the
Github user ex00 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2517#discussion_r80499420
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
---
@@ -219,9 +249,16 @@ public ScopeFormats getScopeFormats() {
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80496915
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
I'll rebase this PR soon, probably will also wait for Kafka 0.10 connector
to be merged.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523340#comment-15523340
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2369
I'm currently working on rebasing the PR and addressing the comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523334#comment-15523334
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user rmetzger commented on the issue
Stephan Ewen created FLINK-4684:
---
Summary: Remove obsolete classloader from CheckpointCoordinator
Key: FLINK-4684
URL: https://issues.apache.org/jira/browse/FLINK-4684
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523328#comment-15523328
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15523327#comment-15523327
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user rmetzger commented on a diff in
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Hi @gyfora,
Yes, it is absolutely possible to add that. There's actually a JIRA for
that feature too
([FLINK-3123](https://issues.apache.org/jira/browse/FLINK-3123)), so I'd say we
can add that
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80491475
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
1 - 100 of 222 matches
Mail list logo
