[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221299#comment-15221299
]
Matthias J. Sax commented on FLINK-2392:
https://s3.amazonaws.com/archive.travis-c
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1837#issuecomment-204301276
I think this is ready.
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221339#comment-15221339
]
ASF GitHub Bot commented on FLINK-3678:
---
Github user stefanobaghino commented on the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1837#issuecomment-204309933
Yes, I'm going to merge it later today.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221375#comment-15221375
]
ASF GitHub Bot commented on FLINK-3678:
---
Github user uce commented on the pull reque
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1846#discussion_r58177554
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221380#comment-15221380
]
ASF GitHub Bot commented on FLINK-3541:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1846#issuecomment-204310567
This seems to change the behavior. Are you sure that the current workaround
(catching the `NullPointerException`) is not needed any more?
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-3541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221382#comment-15221382
]
ASF GitHub Bot commented on FLINK-3541:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1845#issuecomment-204310736
Looks good, +1 to merge
---
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-3635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221385#comment-15221385
]
ASF GitHub Bot commented on FLINK-3635:
---
Github user StephanEwen commented on the pu
Nikolaas Steenbergen created FLINK-3686:
---
Summary: resourcemanager.ClusterShutdownITCase sometimes fails
Key: FLINK-3686
URL: https://issues.apache.org/jira/browse/FLINK-3686
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolaas Steenbergen updated FLINK-3686:
Description:
resourcemanager.ClusterShutdownITCase sometimes fails
~~~Tests run: 1,
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221397#comment-15221397
]
Maximilian Michels commented on FLINK-2392:
---
Have you seen this one before? Migh
[
https://issues.apache.org/jira/browse/FLINK-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolaas Steenbergen updated FLINK-3686:
Description:
resourcemanager.ClusterShutdownITCase sometimes fails
{code}
Tests run
Nikolaas Steenbergen created FLINK-3687:
---
Summary: runtime.leaderelection.ZooKeeperLeaderElectionTest fails
Key: FLINK-3687
URL: https://issues.apache.org/jira/browse/FLINK-3687
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolaas Steenbergen updated FLINK-3687:
Description:
{code}
Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed:
[
https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221404#comment-15221404
]
Till Rohrmann commented on FLINK-3687:
--
Shouldn't that be the {{org.apache.flink.runt
[
https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221412#comment-15221412
]
Nikolaas Steenbergen commented on FLINK-3687:
-
you are right, my bad ;)
> org
[
https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolaas Steenbergen updated FLINK-3687:
Summary: org.apache.flink.runtime.net.ConnectionUtilsTest fails (was:
runtime.leade
Konstantin Knauf created FLINK-3688:
---
Summary: ClassCastException in StreamRecordSerializer when
WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime
Key: FLINK-3688
URL: https://issues.apa
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221460#comment-15221460
]
Matthias J. Sax commented on FLINK-2392:
Yes. See post above from03/Dec/15
> Inst
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221467#comment-15221467
]
Maximilian Michels commented on FLINK-2392:
---
Ok great, then it's probably not du
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-204334976
Note on the tests of the streaming extensions: I couldn't find a more
specific class than `SingleOutputStreamOperator[_]`, thus assertion may not be
very meaningf
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221478#comment-15221478
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221486#comment-15221486
]
Aljoscha Krettek commented on FLINK-3688:
-
Yes, this is indeed a bug. I have a fou
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221496#comment-15221496
]
Aljoscha Krettek commented on FLINK-3688:
-
And, as [~StephanEwen] suggested, we co
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221514#comment-15221514
]
Konstantin Knauf commented on FLINK-3688:
-
>From what I know, watermarks should ju
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1821#discussion_r58191031
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -59,6 +59,8 @@ object Expression
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221548#comment-15221548
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user ramkrish86 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221567#comment-15221567
]
Dawid Wysakowicz commented on FLINK-2946:
-
I still have some problems with range p
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221572#comment-15221572
]
Dawid Wysakowicz commented on FLINK-3665:
-
Hi as I am working on [FLINK-2946] that
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221597#comment-15221597
]
Aljoscha Krettek commented on FLINK-3688:
-
Exactly, that's the reason. If we did t
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3688:
Assignee: Konstantin Knauf
> ClassCastException in StreamRecordSerializer when WindowOperato
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1818#issuecomment-204368378
That is a good idea @uce :-) I'll add a corresponding test for the
`ExecutionConfig`.
---
If your project is set up for it, you can reply to this email and have yo
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221598#comment-15221598
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221600#comment-15221600
]
Aljoscha Krettek commented on FLINK-3669:
-
Yes, the 3rd option would require addit
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221600#comment-15221600
]
Aljoscha Krettek edited comment on FLINK-3669 at 4/1/16 12:05 PM:
--
Maximilian Michels created FLINK-3689:
-
Summary: JobManager blocks cluster shutdown when not connected to
ResourceManager
Key: FLINK-3689
URL: https://issues.apache.org/jira/browse/FLINK-3689
Proj
[
https://issues.apache.org/jira/browse/FLINK-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221630#comment-15221630
]
ASF GitHub Bot commented on FLINK-3689:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1847
[FLINK-3689] fix shutdown of JM when RM is not available
Changes also include a test case which tests this explicitly.
You can merge this pull request into a Git repository by running:
$ git pull h
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-3633:
-
Description:
With the changes introduced by FLINK-3327, it is no longer possible to run
remote Fl
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221677#comment-15221677
]
Konstantin Knauf commented on FLINK-3669:
-
I would like to work on it, but not tod
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221682#comment-15221682
]
Aljoscha Krettek commented on FLINK-3669:
-
Sure, no pressure!
> WindowOperator re
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1818#issuecomment-204399612
I've added an additional test case for registered user code types in the
`ExecutionConfig`. I will rebase this PR and if travis gives green light, then
I'll merge i
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221695#comment-15221695
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3678.
--
Resolution: Fixed
Fix Version/s: (was: 1.0.1)
1.1.0
Fixed in 82b5824.
> M
[
https://issues.apache.org/jira/browse/FLINK-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221703#comment-15221703
]
ASF GitHub Bot commented on FLINK-3678:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1837
---
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
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1837#issuecomment-204405759
Thanks! Hope it will make it to 1.0.1. :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
[
https://issues.apache.org/jira/browse/FLINK-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221705#comment-15221705
]
ASF GitHub Bot commented on FLINK-3678:
---
Github user stefanobaghino commented on the
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221846#comment-15221846
]
Henry Saputra commented on FLINK-3667:
--
Will the new structure change the way the cli
Henry Saputra created FLINK-3690:
Summary: Create documentation on the new ResourceManager component
Key: FLINK-3690
URL: https://issues.apache.org/jira/browse/FLINK-3690
Project: Flink
Issue
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1818#issuecomment-204452690
Failing test case seems to be unrelated
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221896#comment-15221896
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on the p
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1818
---
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-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-3633.
Resolution: Fixed
Fixed via 0331882af124a1750a54b4c6a9bd13819d65f72e
> Job submission silently fail
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221900#comment-15221900
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user asfgit closed the pull request
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/1843
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1843#issuecomment-204467720
Manually merged in 9aa207c073f878d711ca8107627c1f9b2ac17507
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1847#issuecomment-204476710
Looks good to merge...
---
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-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222012#comment-15222012
]
ASF GitHub Bot commented on FLINK-3689:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1845#issuecomment-204477155
Merging 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 have this fe
[
https://issues.apache.org/jira/browse/FLINK-3635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222017#comment-15222017
]
ASF GitHub Bot commented on FLINK-3635:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222073#comment-15222073
]
Maximilian Michels commented on FLINK-3690:
---
The Resource Manager component is t
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r58244518
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/impl/acceptPartialFunctions/OnDataSet.scala
---
@@ -0,0 +1,111 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222081#comment-15222081
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222084#comment-15222084
]
Maximilian Michels commented on FLINK-3667:
---
The clients don't communicate direc
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-204500365
Looks pretty good. I noticed three remaining things:
- Sometimes, the package and the directory trees are different (example:
`OnCoGroupDataSetTest.scala`)
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222095#comment-15222095
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222136#comment-15222136
]
ASF GitHub Bot commented on FLINK-3689:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1847
---
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-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3689.
-
Resolution: Fixed
Fixed in c2f2122c0ba0d0b16eb59aa3ad7958c72fb486b7
> JobManager blocks c
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1764#issuecomment-204508742
The code looks good now.
- How about we move all the convenience timestamp extractors / watermark
generators into a separate packe `.functions.timestamps`?
[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222140#comment-15222140
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1752#issuecomment-204510235
From my side, +1 for removing the `ProgramDescription` interface.
I think it is a mismatch with the `main()` method based approach, because
it needs to insta
[
https://issues.apache.org/jira/browse/FLINK-3560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222147#comment-15222147
]
ASF GitHub Bot commented on FLINK-3560:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1724#issuecomment-204517362
Thanks, I like the docs now!
Sorry for nitpicking, but could you
- Make the bullet list in the docs use the html tags
(``)? It does not render properly
[
https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222156#comment-15222156
]
ASF GitHub Bot commented on FLINK-3519:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1520#comment-1520
]
Henry Saputra commented on FLINK-3690:
--
Thanks for the additional info, Max. From the
Gna Phetsarath created FLINK-3691:
-
Summary: Extend AvroInputFormat to support Avro GenericRecord
Key: FLINK-3691
URL: https://issues.apache.org/jira/browse/FLINK-3691
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gna Phetsarath updated FLINK-3691:
--
Priority: Minor (was: Major)
Component/s: Core
I already have a working version, I need
[
https://issues.apache.org/jira/browse/FLINK-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222423#comment-15222423
]
ASF GitHub Bot commented on FLINK-3657:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1829#issuecomment-204587443
I think @smarthi has a point that the functionality is a nice fit for
`DataSetUtils` and he has properly added it to the scala API and covered the
tests.
It is true
[
https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222431#comment-15222431
]
Fabian Hueske commented on FLINK-2946:
--
Hi Dawid,
at the moment, the Table API does
[
https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222460#comment-15222460
]
Fabian Hueske commented on FLINK-3664:
--
Hi Todd, thanks for sharing your work so far.
[
https://issues.apache.org/jira/browse/FLINK-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222578#comment-15222578
]
ASF GitHub Bot commented on FLINK-3657:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1829#issuecomment-204614791
@mbalassi : There is already request from @zentol and me to clean up the
PR, so would love to get this merge excluding the refactor parts. Thanks.
I think we sh
88 matches
Mail list logo
