[
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
[
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-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
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-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
[
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
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-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
[
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
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-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/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-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/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-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 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:comment-tabpanel&focusedCommentId=15222136#comment-15222136
]
ASF GitHub Bot commented on FLINK-3689:
---
Github user asfgit closed the pull request
[
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
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-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
[
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
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-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
[
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
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-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/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
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 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
[
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
[
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
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:comment-tabpanel&focusedCommentId=15221896#comment-15221896
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on the p
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
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
[
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
[
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
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
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
[
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
[
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
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-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
[
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-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
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-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:
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-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:
--
[
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-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
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-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3688:
Assignee: Konstantin Knauf
> ClassCastException in StreamRecordSerializer when WindowOperato
[
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-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-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-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
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-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
[
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=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-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
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-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
[
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
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-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
[
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: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:all-tabpanel
]
Nikolaas Steenbergen updated FLINK-3687:
Description:
{code}
Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed:
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-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolaas Steenbergen updated FLINK-3686:
Description:
resourcemanager.ClusterShutdownITCase sometimes fails
{code}
Tests run
[
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
~~~Tests run: 1,
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-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
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
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
[
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 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-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 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=15221339#comment-15221339
]
ASF GitHub Bot commented on FLINK-3678:
---
Github user stefanobaghino commented on the
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-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
88 matches
Mail list logo
