[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

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 @@ +/*

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137174#comment-15137174 ] ASF GitHub Bot commented on FLINK-3226: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp

[ https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137181#comment-15137181 ] Stephan Ewen commented on FLINK-3334: - Would this pattern work? {{%d{-MM-dd HH:mm:ss,SSS} %-5p

[jira] [Commented] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

[ https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137149#comment-15137149 ] ASF GitHub Bot commented on FLINK-3243: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3243] Fix Interplay of TimeCharacterist...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1513#discussion_r52185124 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -163,7 +166,11 @@ public

[jira] [Updated] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3368: Priority: Blocker (was: Major) > Kafka 0.8 consumer fails to recover from broker shutdowns >

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137138#comment-15137138 ] Stephan Ewen commented on FLINK-3368: - I think this is a blocker > Kafka 0.8 consumer fails to

[jira] [Commented] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes

[ https://issues.apache.org/jira/browse/FLINK-3371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137159#comment-15137159 ] ASF GitHub Bot commented on FLINK-3371: --- GitHub user StephanEwen opened a pull request:

[jira] [Commented] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp

[ https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137197#comment-15137197 ] ASF GitHub Bot commented on FLINK-3334: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request: [FLINK-3334] [conf] Include year-month-day in ...

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

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

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 @@ +/* + *

[GitHub] flink pull request: [FLINK-2991] Add Folding State and use in Wind...

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,

[GitHub] flink pull request: [hotfix] typo IllegalArgumentException

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1602#issuecomment-181430823 Good catch, +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

[jira] [Commented] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

[ https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137101#comment-15137101 ] ASF GitHub Bot commented on FLINK-3243: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3357] [core] Drop AbstractID#toShortStr...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1601#issuecomment-181436492 In RocksDB it should work. It is just local filesystem paths and FileSystem paths that are affected by this. --- If your project is set up for it, you can reply to

[GitHub] flink pull request: [FLINK-2237] [runtime] Add hash-based combiner...

Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-181437507 I have added the strategy hint. At the moment, it defaults to sorting, but I couldn't actually find any case where hashing is slower, and it is often about 2 times

[jira] [Commented] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException

[ https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137137#comment-15137137 ] Stephan Ewen commented on FLINK-3369: - In the long run, I think it makes sense that this exception is

[jira] [Commented] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-2696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137146#comment-15137146 ] Ufuk Celebi commented on FLINK-2696:

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

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

[GitHub] flink pull request: [FLINK-3243] Fix Interplay of TimeCharacterist...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1513#discussion_r52184878 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/TimeCharacteristic.java --- @@ -34,7 +34,7 @@ * because the contents

[jira] [Commented] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

[ https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137099#comment-15137099 ] ASF GitHub Bot commented on FLINK-3243: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3243] Fix Interplay of TimeCharacterist...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1513#discussion_r52188674 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -163,7 +166,11 @@ public

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137205#comment-15137205 ] ASF GitHub Bot commented on FLINK-3226: --- Github user vasia commented on a diff in the pull request:

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137108#comment-15137108 ] ASF GitHub Bot commented on FLINK-2237: --- Github user ggevay commented on the pull request:

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

Github user chobeat commented on the pull request: https://github.com/apache/flink/pull/1186#issuecomment-181442715 Hello, any news on this PR? @smarthi PMML is actually an industry standard and widely used to support model portability in complex infrastructures.

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137142#comment-15137142 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chobeat commented on the pull request:

[jira] [Assigned] (FLINK-3370) Add an aligned version of the window operator

[ https://issues.apache.org/jira/browse/FLINK-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-3370: --- Assignee: Stephan Ewen > Add an aligned version of the window operator >

[jira] [Created] (FLINK-3370) Add an aligned version of the window operator

Stephan Ewen created FLINK-3370: --- Summary: Add an aligned version of the window operator Key: FLINK-3370 URL: https://issues.apache.org/jira/browse/FLINK-3370 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp

[ https://issues.apache.org/jira/browse/FLINK-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137181#comment-15137181 ] Stephan Ewen edited comment on FLINK-3334 at 2/8/16 4:35 PM: - Would this

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137200#comment-15137200 ] ASF GitHub Bot commented on FLINK-3226: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

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 @@ +/*

[jira] [Commented] (FLINK-3357) Drop JobId.toShortString()

[ https://issues.apache.org/jira/browse/FLINK-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137103#comment-15137103 ] ASF GitHub Bot commented on FLINK-3357: --- Github user aljoscha commented on the pull request:

[jira] [Created] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes

Stephan Ewen created FLINK-3371: --- Summary: Move TriggerCotext and TriggerResult to their own classes Key: FLINK-3371 URL: https://issues.apache.org/jira/browse/FLINK-3371 Project: Flink Issue

[jira] [Assigned] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp

[ 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

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137210#comment-15137210 ] ASF GitHub Bot commented on FLINK-3226: --- Github user vasia commented on a diff in the pull request:

[jira] [Commented] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

[ https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137209#comment-15137209 ] ASF GitHub Bot commented on FLINK-2991: --- GitHub user aljoscha opened a pull request:

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136704#comment-15136704 ] Maximilian Michels commented on FLINK-1502: --- I was working on this in FLINK-3170 but priorities

[jira] [Updated] (FLINK-3333) Documentation about object reuse should be improved

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-: --- Priority: Major (was: Minor) > Documentation about object reuse should be improved >

[jira] [Updated] (FLINK-3363) JobManager does not shut down dedicated executor properly

[ https://issues.apache.org/jira/browse/FLINK-3363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3363: Issue Type: Sub-task (was: Bug) Parent: FLINK-3266 > JobManager does not shut down

[jira] [Commented] (FLINK-3353) CSV-related tests may fail depending on locale

[ https://issues.apache.org/jira/browse/FLINK-3353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136784#comment-15136784 ] ASF GitHub Bot commented on FLINK-3353: --- Github user mxm commented on the pull request:

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136816#comment-15136816 ] Andrea Sella commented on FLINK-3311: - Hi, Should move flink-connector-cassandra from

[jira] [Comment Edited] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136816#comment-15136816 ] Andrea Sella edited comment on FLINK-3311 at 2/8/16 11:09 AM: -- Hi, Should I

[GitHub] flink pull request: [FLINK-3034][Streaming Connectors] Redis Sink ...

Github user subhankarb commented on the pull request: https://github.com/apache/flink/pull/1580#issuecomment-181340467 @rmetzger sorry for late reply. plz take a look at the gist https://gist.github.com/subhankarb/6a503378063819eb47e9 user can choose which one they want to

[jira] [Resolved] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream

[ https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3336. - Resolution: Fixed Added in

[jira] [Commented] (FLINK-3034) Redis SInk Connector

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136868#comment-15136868 ] ASF GitHub Bot commented on FLINK-3034: --- Github user subhankarb commented on the pull request:

[jira] [Commented] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens

[ https://issues.apache.org/jira/browse/FLINK-3358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136800#comment-15136800 ] Aljoscha Krettek commented on FLINK-3358: - I think {{MemoryStateBackend}} is useless, except for

[jira] [Closed] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number

[ https://issues.apache.org/jira/browse/FLINK-3120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3120. -- Resolution: Fixed Fixed in 168c1f0. > Set number of event loop thread and number of buffer pool arenas

[jira] [Assigned] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values

[ https://issues.apache.org/jira/browse/FLINK-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-3361: --- Assignee: Stephan Ewen > Wrong error messages for execution retry delay and akka ask pause

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136892#comment-15136892 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on the pull request:

[jira] [Created] (FLINK-3366) Rename @Experimental annotation to @PublicEvolving

Fabian Hueske created FLINK-3366: Summary: Rename @Experimental annotation to @PublicEvolving Key: FLINK-3366 URL: https://issues.apache.org/jira/browse/FLINK-3366 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3354) RocksDB should compute checkpoint size based on backup file size

[ https://issues.apache.org/jira/browse/FLINK-3354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136802#comment-15136802 ] Aljoscha Krettek commented on FLINK-3354: - If {{getLength()}} really returns the size of the whole

[jira] [Commented] (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:comment-tabpanel=15136812#comment-15136812 ] Gabor Gevay commented on FLINK-3266: These are two thread dumps, one before running the job, and one

[jira] [Created] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving

Fabian Hueske created FLINK-3367: Summary: Annotate all user-facing API classes with @Public or @PublicEvolving Key: FLINK-3367 URL: https://issues.apache.org/jira/browse/FLINK-3367 Project: Flink

[jira] [Comment Edited] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136904#comment-15136904 ] Matthias J. Sax edited comment on FLINK-3035 at 2/8/16 12:52 PM: - The

[jira] [Assigned] (FLINK-3350) Increase timeouts on Travis Builds

[ https://issues.apache.org/jira/browse/FLINK-3350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-3350: -- Assignee: Ufuk Celebi > Increase timeouts on Travis Builds >

[jira] [Created] (FLINK-3363) JobManager does not shut down dedicated executor properly

Stephan Ewen created FLINK-3363: --- Summary: JobManager does not shut down dedicated executor properly Key: FLINK-3363 URL: https://issues.apache.org/jira/browse/FLINK-3363 Project: Flink Issue

[jira] [Commented] (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:comment-tabpanel=15136814#comment-15136814 ] Stephan Ewen commented on FLINK-3266: - Okay, I found the reason for the "ForkJoinPool" threads. Still

[jira] [Commented] (FLINK-3339) Checkpointing NPE when using filterWithState

[ https://issues.apache.org/jira/browse/FLINK-3339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136875#comment-15136875 ] ASF GitHub Bot commented on FLINK-3339: --- Github user aljoscha closed the pull request at:

[jira] [Created] (FLINK-3365) BlobLibraryCacheManager does not shutdown Timer thread

Stephan Ewen created FLINK-3365: --- Summary: BlobLibraryCacheManager does not shutdown Timer thread Key: FLINK-3365 URL: https://issues.apache.org/jira/browse/FLINK-3365 Project: Flink Issue

[jira] [Closed] (FLINK-3286) Remove JDEB Debian Package code from flink-dist

[ https://issues.apache.org/jira/browse/FLINK-3286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3286. --- > Remove JDEB Debian Package code from flink-dist > --- > >

[jira] [Resolved] (FLINK-3339) Checkpointing NPE when using filterWithState

[ https://issues.apache.org/jira/browse/FLINK-3339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3339. - Resolution: Fixed Fix Version/s: 1.0.0 Resolved in

[jira] [Comment Edited] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136704#comment-15136704 ] Maximilian Michels edited comment on FLINK-1502 at 2/8/16 8:37 AM: --- I

[GitHub] flink pull request:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/21a715867d655bb61df9a9f7eef37e42b99e206a#commitcomment-15944874 No problem, it's quite a common problem that maven caches get inconsistent. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3351) RocksDB Backend cannot determine correct local db path

[ https://issues.apache.org/jira/browse/FLINK-3351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136798#comment-15136798 ] Aljoscha Krettek commented on FLINK-3351: - I did it like this because it is really different from

[jira] [Created] (FLINK-3364) Don't initialize SavepointStore in JobManager constructor

Ufuk Celebi created FLINK-3364: -- Summary: Don't initialize SavepointStore in JobManager constructor Key: FLINK-3364 URL: https://issues.apache.org/jira/browse/FLINK-3364 Project: Flink Issue

[jira] [Commented] (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:comment-tabpanel=15136722#comment-15136722 ] ASF GitHub Bot commented on FLINK-3337: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3360) Clear up StateBackend, AbstractStateBackend abstractions

[ https://issues.apache.org/jira/browse/FLINK-3360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136799#comment-15136799 ] Aljoscha Krettek commented on FLINK-3360: - {{StateBackend}} could be {{StateBinder}}. > Clear up

[jira] [Updated] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number

[ https://issues.apache.org/jira/browse/FLINK-3120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-3120: --- Fix Version/s: (was: 0.10.2) 1.0.0 > Set number of event loop thread and

[jira] [Commented] (FLINK-3354) RocksDB should compute checkpoint size based on backup file size

[ https://issues.apache.org/jira/browse/FLINK-3354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136815#comment-15136815 ] Gyula Fora commented on FLINK-3354: --- Yes, this (in contrast with fileStatus.getSize()) returns the

[jira] [Commented] (FLINK-3363) JobManager does not shut down dedicated executor properly

[ https://issues.apache.org/jira/browse/FLINK-3363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136813#comment-15136813 ] Gabor Gevay commented on FLINK-3363: Is this a different issue from

[jira] [Commented] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream

[ https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136874#comment-15136874 ] ASF GitHub Bot commented on FLINK-3336: --- Github user aljoscha closed the pull request at:

[jira] [Commented] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136904#comment-15136904 ] Matthias J. Sax commented on FLINK-3035: The embedded-redis project seems not to be something

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138450#comment-15138450 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on the pull request:

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

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

[jira] [Updated] (FLINK-3333) Documentation about object reuse should be improved

[ 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 >

[jira] [Assigned] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ 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. >

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136956#comment-15136956 ] Robert Metzger commented on FLINK-3311: --- I'm not so sure about this. User's will not see which

[jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend

[ https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136977#comment-15136977 ] ASF GitHub Bot commented on FLINK-3310: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1600#discussion_r52175496 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala --- @@ -0,0 +1,136 @@

[jira] [Commented] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137042#comment-15137042 ] ASF GitHub Bot commented on FLINK-3367: --- GitHub user uce opened a pull request:

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1600 [FLINK-3226] Translate logical aggregations to physical This PR builds on #1567 and addresses @fhueske's comments on translating aggregations. Join translation is not part of this PR. You can

[GitHub] flink pull request: [FLINK-3310] [runtime, runtime-web] Add back p...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1578 --- 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

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137003#comment-15137003 ] ASF GitHub Bot commented on FLINK-3226: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137006#comment-15137006 ] ASF GitHub Bot commented on FLINK-3226: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-181402377 Ok. Your arguments are very strong. I will update this PR accordingly. About `FlinkKafkaConsumer08` (and actually all other available sources). IMHO, we need a new

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137016#comment-15137016 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on the pull request:

[jira] [Resolved] (FLINK-3201) Enhance Partitioned State Interface with State Types

[ https://issues.apache.org/jira/browse/FLINK-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3201. - Resolution: Fixed Fix Version/s: 1.0.0 Implemented in

[jira] [Resolved] (FLINK-3278) Add Partitioned State Backend Based on RocksDB

[ https://issues.apache.org/jira/browse/FLINK-3278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3278. - Resolution: Fixed Fix Version/s: 1.0.0 Added in

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1600#discussion_r52176834 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala --- @@ -0,0 +1,76 @@ +/* + *

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137018#comment-15137018 ] ASF GitHub Bot commented on FLINK-3226: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137069#comment-15137069 ] Gyula Fora commented on FLINK-3355: --- Since the Options class is not serializable it is probably better

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136933#comment-15136933 ] Robert Metzger commented on FLINK-3343: --- Can you maybe ask on the u...@kafka.apache.org mailing

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136967#comment-15136967 ] Andrea Sella commented on FLINK-3311: - I agree with [~Zentol]. I can create a new module, which it

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1600#discussion_r52175572 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala --- @@ -0,0 +1,136 @@

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137057#comment-15137057 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-181419327 Yes exactly. Let us tackle the next steps (adding stopping functionality to more sources, consistent behaviour, drawing savepoint, etc.) once we have a first

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136945#comment-15136945 ] Farouk Salem commented on FLINK-3343: - Thanks. I will send an email right now :) > Exception while

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136954#comment-15136954 ] Chesnay Schepler commented on FLINK-3311: - i think we should have to separate modules, one for

[GitHub] flink pull request: [FLINK-3353] CSV-related tests may fail depend...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1598 --- 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

[jira] [Commented] (FLINK-3353) CSV-related tests may fail depending on locale

[ https://issues.apache.org/jira/browse/FLINK-3353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136964#comment-15136964 ] ASF GitHub Bot commented on FLINK-3353: --- Github user asfgit closed the pull request at:

  1   2   >