[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572174#comment-15572174 ] Maximilian Michels commented on FLINK-2821: --- Just to add another option: - Apply the patch that

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

[ https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572276#comment-15572276 ] ASF GitHub Bot commented on FLINK-3660: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572274#comment-15572274 ] Maximilian Michels commented on FLINK-4824: --- I agree that we should differentiate here and print

[jira] [Commented] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available

[ https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572133#comment-15572133 ] Cody Koeninger commented on FLINK-3037: --- As a user, I want to be able to start low-value,

[jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572151#comment-15572151 ] Greg Hogan commented on FLINK-4824: --- {{WordCount}} should be able to convey to {{ClusterClient}} that

[GitHub] flink issue #2386: [FLINK-3660] Measure latency and exposes them via a metri...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2386 I had an offline discussion with @aljoscha about this PR, and we decided to remove the `isSink` flag from the `AbstractStreamOperator`. I updated the PR. --- If your project is set up for it,

[jira] [Updated] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation

[ https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4825: Description: The added {{ReduceExpressionRule}} leads to inconsistent behavior. Because some parts

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572115#comment-15572115 ] Anton Mushin commented on FLINK-4604: - Sorry, I will try explain my problem. I have two tests

[GitHub] flink issue #2497: [FLINK-4339][cluster management] Implement Slot Pool core...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2497 Merged into the `flip-6` feature branch in 48c936eeda7b265f32bbf9f14d15f78eae15c06f --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-4339) Implement Slot Pool Core

[ https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572293#comment-15572293 ] ASF GitHub Bot commented on FLINK-4339: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572142#comment-15572142 ] Aljoscha Krettek commented on FLINK-4576: - Hi, first off, sorry for the late response, I was on

[jira] [Commented] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

[ https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572160#comment-15572160 ] Greg Hogan commented on FLINK-4823: --- Adding \{code\} before and after this code block will format much

[jira] [Assigned] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-4824: - Assignee: Greg Hogan > CliFrontend shows misleading error message when main() method returns

[GitHub] flink issue #2624: [FLINK-4516] update leadership information in ResourceMan...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2624 Merged to `flip-6`. --- 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

[GitHub] flink pull request #2624: [FLINK-4516] update leadership information in Reso...

Github user mxm closed the pull request at: https://github.com/apache/flink/pull/2624 --- 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-4516) ResourceManager leadership election

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

[jira] [Resolved] (FLINK-4791) Fix issues caused by expression reduction

[ https://issues.apache.org/jira/browse/FLINK-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4791. - Resolution: Fixed Fix Version/s: 1.2.0 Temporarily fixed by disabling the rule in

[jira] [Commented] (FLINK-4516) ResourceManager leadership election

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

[GitHub] flink issue #2588: [FLINK-4735] [cluster management] Migrate some job execut...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2588 Merged to the `flip-6` feature branch in 34fef4752e94b3d0c7afe7a9525799bb651a07b4 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

[ https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572286#comment-15572286 ] ASF GitHub Bot commented on FLINK-4735: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4691) Add group-windows for streaming tables

[ https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572347#comment-15572347 ] ASF GitHub Bot commented on FLINK-4691: --- Github user twalthr commented on the issue:

[GitHub] flink issue #2562: [FLINK-4691] [table] Add group-windows for streaming tabl...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2562 @fhueske I updated the PR. The only thing that is missing now are tests for the `DataStreamAggregate` class. I will add unit tests tomorrow. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-4129) HITSAlgorithm should test for element-wise convergence

[ https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572513#comment-15572513 ] Greg Hogan commented on FLINK-4129: --- [~vkalavri] what do you think we should do with this issue? This is

[jira] [Commented] (FLINK-1472) Web frontend config overview shows wrong value

[ https://issues.apache.org/jira/browse/FLINK-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572753#comment-15572753 ] Greg Hogan commented on FLINK-1472: --- Building a registry of configuration options will be

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572639#comment-15572639 ] Philipp von dem Bussche commented on FLINK-2821: [~mxm] thats awesome ! That might work

[jira] [Updated] (FLINK-4117) Wait for CuratorFramework connection to be established

[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4117: -- Description: Received the following error when locally running {{mvn verify}}. Searching on the error

[jira] [Commented] (FLINK-720) Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle

[ https://issues.apache.org/jira/browse/FLINK-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572652#comment-15572652 ] Greg Hogan commented on FLINK-720: -- Are we still looking to add this check? > Forbid catching exceptions

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572723#comment-15572723 ] Philipp von dem Bussche commented on FLINK-2821: [~StephanEwen] yes more than happy to try

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572364#comment-15572364 ] Maximilian Michels commented on FLINK-2821: --- Just out of fun, I actually tried that and got the

[jira] [Updated] (FLINK-4117) Wait for CuratorFramework connection to be established

[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4117: -- Description: Received the following error when locally running {{mvn verify}}. Searching on the error

[jira] [Resolved] (FLINK-1936) Normalize keys and default values in ConfigConstants.java

[ https://issues.apache.org/jira/browse/FLINK-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-1936. --- Resolution: Fixed > Normalize keys and default values in ConfigConstants.java >

[jira] [Resolved] (FLINK-2603) Flink hangs before starting execution

[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-2603. --- Resolution: Not A Problem I believe this is due to a configured limit in the size of Akka messages as

[jira] [Resolved] (FLINK-4117) Wait for CuratorFramework connection to be established

[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-4117. --- Resolution: Cannot Reproduce > Wait for CuratorFramework connection to be established >

[jira] [Commented] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572633#comment-15572633 ] Greg Hogan commented on FLINK-1890: --- Do we still want this documented or can we close this issue? > Add

[jira] [Resolved] (FLINK-787) Custom termination criterion in delta iteration

[ https://issues.apache.org/jira/browse/FLINK-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-787. -- Resolution: Duplicate > Custom termination criterion in delta iteration >

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572671#comment-15572671 ] Stephan Ewen commented on FLINK-2821: - That's pretty amazing. [~philipp.bussche] do you have the time

[jira] [Closed] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-. --- Resolution: Invalid No longer valid as we no longer show graphs in the WebFrontend. >

[jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job

[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572952#comment-15572952 ] Greg Hogan commented on FLINK-3302: --- I recently closed the aforementioned FLINK-3263 since these

[jira] [Commented] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile

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

[GitHub] flink pull request #2630: [FLINK-4373] [cluster management] Introduce Alloca...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2630 [FLINK-4373] [cluster management] Introduce AllocationID, ResourceProfile, and AllocatedSlot These classes are introduced as part of the cluster management rework (FLIP-6) The

[jira] [Commented] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572810#comment-15572810 ] Fabian Hueske commented on FLINK-1890: -- I'd keep the issue open. I'll add the starter tag to it.

[jira] [Closed] (FLINK-3302) Save Taskmanager Metrics per Job

[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3302. - Resolution: Not A Problem > Save Taskmanager Metrics per Job > > >

[jira] [Resolved] (FLINK-2024) Table API mentioned only in Batch in documentation site

[ https://issues.apache.org/jira/browse/FLINK-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-2024. --- Resolution: Fixed This is fixed in the 1.1 and 1.2-SNAPSHOT documentation currently linked to from

[jira] [Commented] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572830#comment-15572830 ] Greg Hogan commented on FLINK-: --- Is this fixed since we no longer have memory/CPU graphs? And

[jira] [Commented] (FLINK-2247) Improve the way memory is reported in the web frontend

[ https://issues.apache.org/jira/browse/FLINK-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572863#comment-15572863 ] Greg Hogan commented on FLINK-2247: --- It doesn't look like these warnings are present in the new web

[jira] [Closed] (FLINK-2223) Web frontend shows wrong accumulator results for latest job

[ https://issues.apache.org/jira/browse/FLINK-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2223. --- Resolution: Invalid > Web frontend shows wrong accumulator results for latest job >

[jira] [Resolved] (FLINK-4188) Support for outer joins on DataStream

[ https://issues.apache.org/jira/browse/FLINK-4188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-4188. --- Resolution: Duplicate > Support for outer joins on DataStream > -

[jira] [Commented] (FLINK-2223) Web frontend shows wrong accumulator results for latest job

[ https://issues.apache.org/jira/browse/FLINK-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572799#comment-15572799 ] Greg Hogan commented on FLINK-2223: --- Is this still an issue? > Web frontend shows wrong accumulator

[jira] [Closed] (FLINK-2247) Improve the way memory is reported in the web frontend

[ https://issues.apache.org/jira/browse/FLINK-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2247. --- Resolution: Invalid We no longer show such warnings in the WebFrontend. We are also showing

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83289172 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83290286 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83288193 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83290431 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573068#comment-15573068 ] Greg Hogan commented on FLINK-4370: --- [~StephanEwen] have you discovered a third way? Our options so far

[jira] [Updated] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1890: - Labels: starter (was: ) > Add note to docs that ReadFields annotations are currently not

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

Github user qingdao81 commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83307880 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310338 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83308572 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310395 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83308865 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[jira] [Created] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment

Vijay Srinivasaraghavan created FLINK-4826: -- Summary: Add keytab based kerberos support to run Flink in Mesos environment Key: FLINK-4826 URL: https://issues.apache.org/jira/browse/FLINK-4826

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support in Mesos environment

[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support in Mesos environment (was: Add

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support for Mesos environment

[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support for Mesos environment (was: Add

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment

[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support to run Flink in Mesos environment

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319240 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319026 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318311 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319036 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Closed] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

[ https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4561. - Resolution: Won't Fix > replace all the scala version as a `scala.binary.version` property >

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318228 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318661 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310436 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318300 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83316946 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319084 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83309671 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[jira] [Commented] (FLINK-3932) Implement State Backend Security

[ https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573487#comment-15573487 ] ASF GitHub Bot commented on FLINK-3932: --- Github user vijikarthi commented on the issue:

[GitHub] flink issue #2589: FLINK-3932 State Backend Security

Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2589 Are we waiting for any additional review? --- 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] [Comment Edited] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

[ https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15571746#comment-15571746 ] Sajeev Ramakrishnan edited comment on FLINK-4823 at 10/14/16 5:16 AM: --

[jira] [Created] (FLINK-4827) Sql on streaming example use scala with wrong variable name

yuemeng created FLINK-4827: -- Summary: Sql on streaming example use scala with wrong variable name Key: FLINK-4827 URL: https://issues.apache.org/jira/browse/FLINK-4827 Project: Flink Issue Type:

  1   2   >