Chengxiang Li created FLINK-3474:
Summary: Partial aggregate interface design and sort-based
implementation
Key: FLINK-3474
URL: https://issues.apache.org/jira/browse/FLINK-3474
Project: Flink
Chengxiang Li created FLINK-3473:
Summary: Add partial aggregate support in Flink
Key: FLINK-3473
URL: https://issues.apache.org/jira/browse/FLINK-3473
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158264#comment-15158264
]
godfrey he edited comment on FLINK-3253 at 2/23/16 6:18 AM:
is
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158311#comment-15158311
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user subhankarb commented on the pul
Github user subhankarb commented on the pull request:
https://github.com/apache/flink/pull/1580#issuecomment-187546037
hi matthias,
i was on vacation for 1 week. I'll update the pr once i get some input
from robert about my design.
On 22-Feb-2016 7:21 PM, "Robert Metzger"
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023
]
Dongwon Kim edited comment on FLINK-1502 at 2/23/16 4:44 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158264#comment-15158264
]
godfrey he commented on FLINK-3253:
---
0.10.1 ?
> deserializeObject exception on WindowOp
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158238#comment-15158238
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user sbcd90 commented on the pull re
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1617#issuecomment-187515384
Hello @mjsax , it is possible to use Travis for testing the redis. Travis
can start Redis during build. Please check out an example
[here](https://github.com/sbcd90/redis
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158138#comment-15158138
]
sahitya pavurala commented on FLINK-2118:
-
Isn't this because && has a higher prec
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158090#comment-15158090
]
Jamie Grier edited comment on FLINK-1502 at 2/23/16 1:30 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158090#comment-15158090
]
Jamie Grier commented on FLINK-1502:
[~eastcirclek] Let's define our terms to make su
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023
]
Dongwon Kim edited comment on FLINK-1502 at 2/23/16 12:43 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023
]
Dongwon Kim edited comment on FLINK-1502 at 2/23/16 12:41 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023
]
Dongwon Kim commented on FLINK-1502:
Let's consider the following scenario:
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158005#comment-15158005
]
ASF GitHub Bot commented on FLINK-3385:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1680#issuecomment-187448014
Thanks for the fix! Will merge this.
---
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
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-187439412
Thanks @aalexandrov. I added a few comments to the document.
Looking forward to the results :-)
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157950#comment-15157950
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on the pull r
Ken Geis created FLINK-3472:
---
Summary: JDBCInputFormat.nextRecord(..) has misleading message on
NPE
Key: FLINK-3472
URL: https://issues.apache.org/jira/browse/FLINK-3472
Project: Flink
Issue Type:
Ken Geis created FLINK-3471:
---
Summary: JDBCInputFormat cannot handle null fields of certain types
Key: FLINK-3471
URL: https://issues.apache.org/jira/browse/FLINK-3471
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-3340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157671#comment-15157671
]
ASF GitHub Bot commented on FLINK-3340:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1692#issuecomment-187376965
Is this FLINK-3440?
---
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
[
https://issues.apache.org/jira/browse/FLINK-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157629#comment-15157629
]
ASF GitHub Bot commented on FLINK-3455:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1684
---
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-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3455.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Resolved in http://git-wip-us.apache.org/repos/a
[
https://issues.apache.org/jira/browse/FLINK-3340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157622#comment-15157622
]
ASF GitHub Bot commented on FLINK-3340:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157623#comment-15157623
]
ASF GitHub Bot commented on FLINK-3455:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1684#issuecomment-187366906
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 have this feature
e
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1692
[FLINK-3340][Kafka 0.8] Commit also offsets retrieved from Kafka into the
OffsetStore (ZK)
Before this change, offsets were only committed to Zookeeper if something
was read from the TopicPartitio
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157611#comment-15157611
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-187364918
Hi, the error is not related to your changes. Its an issue of our build
system (an inconsistent file has been cached).
From a CI point of view, the changes look good
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1669#discussion_r53678441
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1487,7 +1487,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157542#comment-15157542
]
ASF GitHub Bot commented on FLINK-3443:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157536#comment-15157536
]
ASF GitHub Bot commented on FLINK-3443:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1669#discussion_r53677748
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1487,7 +1487,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157523#comment-15157523
]
ASF GitHub Bot commented on FLINK-3418:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1687#issuecomment-187328780
Ahh, stupid beginners mistake. Fixed it.
---
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-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157502#comment-15157502
]
ASF GitHub Bot commented on FLINK-3418:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1687#issuecomment-187323846
Fails on checkstyle, otherwise looks good...
---
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
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1669#discussion_r53673891
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1487,7 +1487,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157487#comment-15157487
]
ASF GitHub Bot commented on FLINK-3443:
---
Github user StephanEwen commented on a diff
Stephan Ewen created FLINK-3470:
---
Summary: EventTime WindowAssigners should error on negative
timestamps
Key: FLINK-3470
URL: https://issues.apache.org/jira/browse/FLINK-3470
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-3467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157417#comment-15157417
]
ASF GitHub Bot commented on FLINK-3467:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1691
[FLINK-3467] Remove superfluous objects from DataSourceTask.invoke
This reverts the object reuse logic to that of commit e8734b24.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157404#comment-15157404
]
ASF GitHub Bot commented on FLINK-3398:
---
GitHub user shikhar opened a pull request:
GitHub user shikhar opened a pull request:
https://github.com/apache/flink/pull/1690
FLINK-3398: Allow for opting-out from Kafka offset auto-commit
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shikhar/flink kafka-autocommit-op
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1689
Make DataStream property methods properly Scalaesk
This is a suggestion on how to make the `DataStream` Scala code (particular
the property methods) more scalaesk.
For example:
-
Greg Hogan created FLINK-3469:
-
Summary: Fix documentation for grouping keys
Key: FLINK-3469
URL: https://issues.apache.org/jira/browse/FLINK-3469
Project: Flink
Issue Type: Bug
Compone
[
https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157377#comment-15157377
]
Shikhar Bhushan commented on FLINK-3375:
We are also on Kafka 0.8 for now
> Allow
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157338#comment-15157338
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1553#discussion_r53659684
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java
---
@@ -434,6 +431,95 @@ public void
testCorrectnessOfG
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157339#comment-15157339
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1553#discussion_r53659650
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java
---
@@ -87,19 +92,39 @@ public DriverSt
[
https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157295#comment-15157295
]
Zach Cox commented on FLINK-3375:
-
Our specific app is currently using Kafka 0.8 (we plan
Stephan Ewen created FLINK-3468:
---
Summary: Change Timestamp Extractors to not support negative
timestamps
Key: FLINK-3468
URL: https://issues.apache.org/jira/browse/FLINK-3468
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-3458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157271#comment-15157271
]
ASF GitHub Bot commented on FLINK-3458:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1681#issuecomment-187265742
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157270#comment-15157270
]
Stephan Ewen commented on FLINK-3375:
-
I think we could use some contributor help to g
[
https://issues.apache.org/jira/browse/FLINK-3331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157267#comment-15157267
]
ASF GitHub Bot commented on FLINK-3331:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1654#issuecomment-187262614
Looks good, +1 to merge this
---
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-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157255#comment-15157255
]
ASF GitHub Bot commented on FLINK-3425:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1652#issuecomment-187261145
Sorry, I confused the diff.
This looks actually good, +1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157252#comment-15157252
]
ASF GitHub Bot commented on FLINK-3385:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1680#issuecomment-187258482
Unprobed, spilled partitions are now retained when performing a build-side
outer join (and still discarded in all other cases).
When these unprobed, spilled pa
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1680#issuecomment-187253798
Could add description on how is the fix being done and proposed result.
Thanks
---
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-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157232#comment-15157232
]
ASF GitHub Bot commented on FLINK-3385:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157221#comment-15157221
]
ASF GitHub Bot commented on FLINK-3438:
---
Github user StephanEwen commented on the pu
Greg Hogan created FLINK-3467:
-
Summary: Remove superfluous objects from DataSourceTask.invoke
Key: FLINK-3467
URL: https://issues.apache.org/jira/browse/FLINK-3467
Project: Flink
Issue Type: Imp
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1665#issuecomment-187250281
The test failure looks unrelated to this fix.
+1 to merge this
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1665#issuecomment-187248829
Running the test locally with the same `PROFILE` as the failing tests do
not yield the same results (i.e. all tests pass). Is there a way to determine
if this was
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/1616
---
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
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1616#issuecomment-187240850
Considering this and other recent discussions I agree that introducing a
high-level copy would be detrimental and that there are better solutions. I
would still like t
[
https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157212#comment-15157212
]
ASF GitHub Bot commented on FLINK-3438:
---
Github user stefanobaghino commented on the
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-187243415
I've added a [Google
Doc](https://docs.google.com/document/d/12yx7olVrkooceaQPoR1nkk468lIq0xOObY5ukWuNEcM/edit?usp=sharing)
where we can collaborate on the design of
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1684#issuecomment-187246143
Looks good, +1 to merge this
---
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-3467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3467:
--
Description: In the object reuse case we cycle between three objects. This
is a vestige of an earlier bu
[
https://issues.apache.org/jira/browse/FLINK-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157198#comment-15157198
]
ASF GitHub Bot commented on FLINK-3455:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157179#comment-15157179
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user aalexandrov commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157174#comment-15157174
]
ASF GitHub Bot commented on FLINK-3335:
---
Github user greghogan closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157173#comment-15157173
]
ASF GitHub Bot commented on FLINK-3335:
---
Github user greghogan commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3335.
-
Resolution: Won't Fix
> Fix DataSourceTask object reuse when disabled
> --
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1641#issuecomment-187190568
Updated on top of master again. This should have the behavior that we want
for 1.0.
---
If your project is set up for it, you can reply to this email and have your
rep
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-187221864
Was this a hiccup in the build or an issue related to my changes? I really
can't tell from the error message.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157102#comment-15157102
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1688
[FLINK-3464] [docs] Add SBT template documentation to the quickstart
documentation
This PR also changes the order of the shown tabs for the java api
quickstart guide. Now the maven archetype i
[
https://issues.apache.org/jira/browse/FLINK-3464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157088#comment-15157088
]
ASF GitHub Bot commented on FLINK-3464:
---
GitHub user tillrohrmann opened a pull requ
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1687#issuecomment-187202268
Should be the correct code now. :smile:
---
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
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1687#discussion_r53629014
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -26,32 +25,46 @@
import java.io.File;
i
Vasia Kalavri created FLINK-3463:
Summary: Implement Calc Support
Key: FLINK-3463
URL: https://issues.apache.org/jira/browse/FLINK-3463
Project: Flink
Issue Type: Sub-task
Component
[
https://issues.apache.org/jira/browse/FLINK-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157046#comment-15157046
]
ASF GitHub Bot commented on FLINK-3418:
---
Github user aljoscha commented on the pull
Till Rohrmann created FLINK-3465:
Summary: Add SBT template script
Key: FLINK-3465
URL: https://issues.apache.org/jira/browse/FLINK-3465
Project: Flink
Issue Type: Improvement
Rep
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1617#issuecomment-187201289
I don't know enough about redis. Not sure how we can deal with the testing
situation.
---
If your project is set up for it, you can reply to this email and have your
r
Till Rohrmann created FLINK-3464:
Summary: Add SBT build tool description to quickstart documentation
Key: FLINK-3464
URL: https://issues.apache.org/jira/browse/FLINK-3464
Project: Flink
Issu
Robert Metzger created FLINK-3466:
-
Summary: Job might get stuck in restoreState() from HDFS due to
interrupt
Key: FLINK-3466
URL: https://issues.apache.org/jira/browse/FLINK-3466
Project: Flink
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1617#issuecomment-187199830
I guess we can just move on here by assuming that Redis must be started
manually before it can be uses as state backend. We still need to figure out
how to test this: it i
[
https://issues.apache.org/jira/browse/FLINK-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157029#comment-15157029
]
ASF GitHub Bot commented on FLINK-3418:
---
Github user aljoscha commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1687#discussion_r53628814
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -26,32 +25,46 @@
import java.io.File;
i
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157039#comment-15157039
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user mjsax commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157041#comment-15157041
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user aljoscha commented on the pull
1 - 100 of 142 matches
Mail list logo