[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-:
---
Priority: Critical (was: Major)
> Documentation about object reuse should be improved
> -
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongwon Kim reassigned FLINK-1502:
--
Assignee: Dongwon Kim
> Expose metrics to graphite, ganglia and JMX.
>
[
https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15138450#comment-15138450
]
ASF GitHub Bot commented on FLINK-1966:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181739512
Hi @chobeat, thanks for leaving your comments.
About compatibility with other system (such as R or MLlib), I meant that we
cannot achieve compatibility with t
[
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-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137969#comment-15137969
]
ASF GitHub Bot commented on FLINK-3334:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1604#issuecomment-181614932
Manually merged in d51bec1524a9832a7e6c0f6c5d5be5a42712d365
---
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/1604
---
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-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137970#comment-15137970
]
ASF GitHub Bot commented on FLINK-3334:
---
Github user StephanEwen closed the pull req
[
https://issues.apache.org/jira/browse/FLINK-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3337.
---
> mvn test fails on flink-runtime because curator classes not found
>
[
https://issues.apache.org/jira/browse/FLINK-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3337.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via 4cc4f6022c5935dffc52a37de7ebd5b272e95487
[
https://issues.apache.org/jira/browse/FLINK-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3361.
-
Resolution: Fixed
Fixed via af3e689010f3d8e08b6ff70dd5eb6d45429d4981
> Wrong error messages for e
[
https://issues.apache.org/jira/browse/FLINK-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3361.
---
> Wrong error messages for execution retry delay and akka ask pause config
> values
> ---
[
https://issues.apache.org/jira/browse/FLINK-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3266.
---
> LocalFlinkMiniCluster leaks resources when multiple jobs are submitted
> ---
[
https://issues.apache.org/jira/browse/FLINK-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3266.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 1.0.0
Fixed via resolution
[
https://issues.apache.org/jira/browse/FLINK-3363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3363.
-
Resolution: Fixed
Fixed via a277543c57f7c633e0f8b610b241eac5a95aa7cc
> JobManager does not shut d
[
https://issues.apache.org/jira/browse/FLINK-3363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3363.
---
> JobManager does not shut down dedicated executor properly
>
[
https://issues.apache.org/jira/browse/FLINK-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3365.
---
> BlobLibraryCacheManager does not shutdown Timer thread
> ---
[
https://issues.apache.org/jira/browse/FLINK-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3365.
-
Resolution: Fixed
Fixed via 457cb14537c0e6f89cdbcc0564054f86bfbbb3eb
> BlobLibraryCacheManager do
[
https://issues.apache.org/jira/browse/FLINK-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3357.
---
> Drop JobId.toShortString()
> --
>
> Key: FLINK-3357
>
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3334.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via d51bec1524a9832a7e6c0f6c5d5be5a42712d365
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3334.
---
> Change default log4j.properties Conversion pattern to include year-month-day
> in the timestamp
> -
[
https://issues.apache.org/jira/browse/FLINK-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3357.
-
Resolution: Fixed
Fixed via 28feede7d40dc73ec861cf93393650b8b10afc3a
> Drop JobId.toShortString()
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1596
---
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-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137947#comment-15137947
]
ASF GitHub Bot commented on FLINK-3337:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137948#comment-15137948
]
ASF GitHub Bot commented on FLINK-3357:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1602
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1601
---
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-3340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3340:
--
Summary: Fix object juggling in drivers (was: Fix object juggling in
reduce drivers)
> Fix object jugg
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137767#comment-15137767
]
Robert Metzger commented on FLINK-3368:
---
It seems that the issue depends on the numb
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181578375
Hi @chiwanpark,
> What is main purpose to support PMML? Is this feature for only model
portability in FlinkML?
I've used PMML extensively in a previous
[
https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137745#comment-15137745
]
ASF GitHub Bot commented on FLINK-1966:
---
Github user chobeat commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3295:
--
Component/s: Kafka Connector
> Flink Kafka consumer fails with NoNodeException if zkConnect stri
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52225586
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/SumAggregate.scala
---
@@ -0,0 +1,130 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137691#comment-15137691
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137685#comment-15137685
]
ASF GitHub Bot commented on FLINK-3226:
---
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/1600#discussion_r52225277
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,76 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137662#comment-15137662
]
Robert Metzger commented on FLINK-3066:
---
I further looked into the issue. There is a
[
https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137637#comment-15137637
]
ASF GitHub Bot commented on FLINK-3243:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1513#issuecomment-181557496
IMO, it is not a question of taste but a question of trying to make the
code base adhere to Java coding standards.
I can roll back that change if we want this,
[
https://issues.apache.org/jira/browse/FLINK-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137610#comment-15137610
]
Robert Metzger commented on FLINK-3066:
---
I have to correct my comment from november
[
https://issues.apache.org/jira/browse/FLINK-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3066:
--
Description:
I got the following exception during my streaming job:
{code}
16:44:50,637 INFO o
[
https://issues.apache.org/jira/browse/FLINK-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3066:
--
Summary: Kafka producer fails on leader change (was: Kafka source fails on
leader change)
> Ka
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137525#comment-15137525
]
Greg Hogan commented on FLINK-3335:
---
No, I came across this issue while fixing a differe
[
https://issues.apache.org/jira/browse/FLINK-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137495#comment-15137495
]
ASF GitHub Bot commented on FLINK-3355:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1608
[FLINK-3355] [rocksdb backend] Allow passing options to the RocksDB backend
This introduces an `OptionsFactory` to lazily create RocksDB Options and
uses those to initialize the
RocksDB inst
[
https://issues.apache.org/jira/browse/FLINK-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137489#comment-15137489
]
ASF GitHub Bot commented on FLINK-3357:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1601#issuecomment-181523979
Looks good, 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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1602#issuecomment-181522714
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-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-3355:
---
Assignee: Stephan Ewen
> Allow passing RocksDB Option to RocksDBStateBackend
> --
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137439#comment-15137439
]
Stephan Ewen commented on FLINK-1502:
-
Quick comment: I recently had a look at how Sam
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137435#comment-15137435
]
Stephan Ewen commented on FLINK-1502:
-
[~eastcirclek] I gave you contributor permissio
[
https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137431#comment-15137431
]
ASF GitHub Bot commented on FLINK-3243:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1513#issuecomment-181511999
Is the switch from `ProcessingTime` to `PROCESSING_TIME` actually necessary?
Breaks yet one more thing for users just because of a matter of taste.
There
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1604#issuecomment-181510175
Yeah, streaming systems tend to run for longer than a day, so it makes
sense to log the day...
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137427#comment-15137427
]
Nick Dimiduk commented on FLINK-3372:
-
Verified this change with local yarn cluster, p
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137426#comment-15137426
]
ASF GitHub Bot commented on FLINK-3372:
---
GitHub user ndimiduk opened a pull request:
GitHub user ndimiduk opened a pull request:
https://github.com/apache/flink/pull/1607
[FLINK-3372] Setting custom YARN application name is ignored
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ndimiduk/flink 3372-yarn-applicati
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137423#comment-15137423
]
Stephan Ewen commented on FLINK-3335:
-
Yeah, the current way of doing it is not optima
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137414#comment-15137414
]
ASF GitHub Bot commented on FLINK-3334:
---
Github user StephanEwen commented on the pu
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52204752
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/SumAggregate.scala
---
@@ -0,0 +1,130 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137409#comment-15137409
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user vasia commented on a diff in th
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181509602
Hi @chobeat, thanks for pinging this issue. I forgot sending a discuss
email to mailing thread. I think we have to discuss about followings:
* What is main pu
[
https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137408#comment-15137408
]
ASF GitHub Bot commented on FLINK-1966:
---
Github user chiwanpark commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137392#comment-15137392
]
Nick Dimiduk commented on FLINK-3372:
-
For context, this bug means that all flink appl
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1604#issuecomment-181506978
+1 also from my side.
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137389#comment-15137389
]
ASF GitHub Bot commented on FLINK-3334:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137377#comment-15137377
]
ASF GitHub Bot commented on FLINK-3334:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1604#issuecomment-181503516
Looks good :) Thanks Stephan!
---
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 hav
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1604#issuecomment-181501036
This will make log files harder to read but I see that it is necessary for
production systems.
---
If your project is set up for it, you can reply to this email and have yo
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137368#comment-15137368
]
ASF GitHub Bot commented on FLINK-3334:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137365#comment-15137365
]
Greg Hogan commented on FLINK-3335:
---
{{InputFormat}} is a public interface. I don't know
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137358#comment-15137358
]
ASF GitHub Bot commented on FLINK-3341:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1597#discussion_r52202024
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/LegacyFetcher.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137349#comment-15137349
]
Fabian Hueske commented on FLINK-3372:
--
Ah, that explains why I didn't cherry-pick it
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137347#comment-15137347
]
ASF GitHub Bot commented on FLINK-3341:
---
Github user shikhar commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137345#comment-15137345
]
ASF GitHub Bot commented on FLINK-3367:
---
GitHub user fhueske opened a pull request:
Github user shikhar commented on a diff in the pull request:
https://github.com/apache/flink/pull/1597#discussion_r52201602
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/LegacyFetcher.java
---
@@
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/1606
[FLINK-3367] Add PublicEvolving and Internal annotations to classes in API
modules
This PR includes the commit from #1599.
It adds annotations to all classes in the following modules:
-
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137338#comment-15137338
]
Nick Dimiduk commented on FLINK-3372:
-
YARN launch code is pretty different between 0.
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137328#comment-15137328
]
Fabian Hueske commented on FLINK-3372:
--
Just saw that the vote for RC2 was already st
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137325#comment-15137325
]
Fabian Hueske commented on FLINK-3372:
--
I think this is a duplicate of FLINK-3293 whi
Nick Dimiduk created FLINK-3372:
---
Summary: Setting custom YARN application name is ignored
Key: FLINK-3372
URL: https://issues.apache.org/jira/browse/FLINK-3372
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137205#comment-15137205
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137209#comment-15137209
]
ASF GitHub Bot commented on FLINK-2991:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137210#comment-15137210
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52192844
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,76 @@
+/*
+ * Lic
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1605
[FLINK-2991] Add Folding State and use in WindowOperator
This enables efficient incremental aggregation of fold window.
This also adds:
- WindowedStream.apply(initVal, foldFunction, win
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52192508
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/logical/FlinkAggregate.scala
---
@@ -58,19 +58,23 @@ class FlinkAggr
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137200#comment-15137200
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52192307
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala
---
@@ -0,0 +1,136 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137197#comment-15137197
]
ASF GitHub Bot commented on FLINK-3334:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1604
[FLINK-3334] [conf] Include year-month-day in the log output
Modifies the date pattern in all log config files
You can merge this pull request into a Git repository by running:
$ git pull h
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-3334:
---
Assignee: Stephan Ewen
> Change default log4j.properties Conversion pattern to include year-m
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137181#comment-15137181
]
Stephan Ewen edited comment on FLINK-3334 at 2/8/16 4:35 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137181#comment-15137181
]
Stephan Ewen commented on FLINK-3334:
-
Would this pattern work? {{%d{-MM-dd HH:mm:
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137174#comment-15137174
]
ASF GitHub Bot commented on FLINK-3226:
---
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/1600#discussion_r52190250
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/SumAggregate.scala
---
@@ -0,0 +1,130 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137159#comment-15137159
]
ASF GitHub Bot commented on FLINK-3371:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1603
[FLINK-3371] [api breaking] Move TriggerResult and TriggerContext to
dedicated classes
**This change should go into 1.0, because it is API breaking**
In order to prepare for adding alig
1 - 100 of 207 matches
Mail list logo
