[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66797799 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -300,18 +309,82 @@ public static boolean

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66797580 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java --- @@ -211,18 +185,45 @@ public void run() {

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66797696 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -300,18 +309,82 @@ public static boolean

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66794085 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -551,19 +657,28 @@ public

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66795439 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -108,24 +131,83 @@ public FlinkYarnSessionCli(String

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66795170 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -415,62 +513,83 @@ public int run(String[] args) {

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66794640 --- Diff: docs/apis/cli.md --- @@ -105,6 +105,10 @@ The command line can be used to ./bin/flink list -r +- List running Flink

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66794535 --- Diff: docs/apis/cli.md --- @@ -105,6 +105,10 @@ The command line can be used to ./bin/flink list -r +- List running Flink

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters

[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327406#comment-15327406 ] Ken Krugler commented on FLINK-3839: -C (or --classpath) seems like the right approach. Interesting

[GitHub] flink issue #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2093 I had some inline comments. One other thing I would like to see changed is moving the logic that checks whether to do cleanup from `cleanup()` to the call-site. So in `processElement()` it

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[GitHub] flink pull request #2096: [FLINK-3800] [runtime] Introduce SUSPENDED job sta...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2096 [FLINK-3800] [runtime] Introduce SUSPENDED job status The SUSPENDED job status is a new ExecutionGraph state which can be reached from all non-terminal states when calling suspend on the

[jira] [Created] (FLINK-4066) RabbitMQ source, customize queue arguments

Kanstantsin Kamkou created FLINK-4066: - Summary: RabbitMQ source, customize queue arguments Key: FLINK-4066 URL: https://issues.apache.org/jira/browse/FLINK-4066 Project: Flink Issue

[jira] [Comment Edited] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15325710#comment-15325710 ] Kanstantsin Kamkou edited comment on FLINK-3763 at 6/13/16 1:35 PM:

[jira] [Commented] (FLINK-3800) ExecutionGraphs can become orphans

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

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66791210 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java --- @@ -211,18 +185,45 @@ public void run() {

[jira] [Commented] (FLINK-4064) Allow calling MetricGroup methods multiple times

[ https://issues.apache.org/jira/browse/FLINK-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327359#comment-15327359 ] Chesnay Schepler commented on FLINK-4064: - This would effectively mean a mandatory additional

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66789406 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -121,6 +124,23 @@ public

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66789723 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java --- @@ -181,11 +198,30 @@ public boolean

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66788457 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -121,6 +124,23 @@ public

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66787877 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -264,7 +274,9 @@ public void

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66787496 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -129,6 +130,12 @@

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66787353 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -121,6 +124,23 @@ public

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66787298 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/EventTimeTrigger.java --- @@ -36,12 +36,17 @@ private

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66787046 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -121,6 +124,23 @@ public

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r66786965 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -121,6 +124,23 @@ public

[jira] [Updated] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test

[ https://issues.apache.org/jira/browse/FLINK-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4065: -- Labels: test-stability (was: ) > Unstable Kafka09ITCase.testMultipleSourcesOnePartition test >

[jira] [Created] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test

Kostas Kloudas created FLINK-4065: - Summary: Unstable Kafka09ITCase.testMultipleSourcesOnePartition test Key: FLINK-4065 URL: https://issues.apache.org/jira/browse/FLINK-4065 Project: Flink

[jira] [Commented] (FLINK-4064) Allow calling MetricGroup methods multiple times

[ https://issues.apache.org/jira/browse/FLINK-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327301#comment-15327301 ] Aljoscha Krettek commented on FLINK-4064: - Technically, that can be a problem yes. In the

[jira] [Commented] (FLINK-4064) Allow calling MetricGroup methods multiple times

[ https://issues.apache.org/jira/browse/FLINK-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327294#comment-15327294 ] Chesnay Schepler commented on FLINK-4064: - technically yes, just check the map and return it if it

[jira] [Commented] (FLINK-4064) Allow calling MetricGroup methods multiple times

[ https://issues.apache.org/jira/browse/FLINK-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327273#comment-15327273 ] Aljoscha Krettek commented on FLINK-4064: - [~Zentol] Do you think this is alright? I think we just

[jira] [Created] (FLINK-4064) Allow calling MetricGroup methods multiple times

Aljoscha Krettek created FLINK-4064: --- Summary: Allow calling MetricGroup methods multiple times Key: FLINK-4064 URL: https://issues.apache.org/jira/browse/FLINK-4064 Project: Flink Issue

[jira] Akshay Shingote shared "FLINK-4059: Requirement of Streaming layer for Complex Event Processing" with you

Akshay Shingote shared an issue with you > Requirement of Streaming layer for Complex Event Processing > --- > > Key: FLINK-4059 > URL:

[jira] [Commented] (FLINK-4063) Add Metrics Support for Triggers

[ https://issues.apache.org/jira/browse/FLINK-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327247#comment-15327247 ] Aljoscha Krettek commented on FLINK-4063: - User functions access metrics using

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327244#comment-15327244 ] Aljoscha Krettek commented on FLINK-3758: - [~knaufk] Would it be alright if I closed in favor of

[jira] [Created] (FLINK-4063) Add Metrics Support for Triggers

Aljoscha Krettek created FLINK-4063: --- Summary: Add Metrics Support for Triggers Key: FLINK-4063 URL: https://issues.apache.org/jira/browse/FLINK-4063 Project: Flink Issue Type: Improvement

[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=15327219#comment-15327219 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/1771 The merging will probably be a bit delayed because there are some memory issues: ``` --- T E S T S

[jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters

[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327195#comment-15327195 ] Robert Thorman commented on FLINK-3839: --- I've been working through the debugger on CliFrontend and

[jira] [Commented] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug

[ https://issues.apache.org/jira/browse/FLINK-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327122#comment-15327122 ] Chesnay Schepler commented on FLINK-4061: - this could easily be caused by a version diffference

[jira] [Closed] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running

[ https://issues.apache.org/jira/browse/FLINK-3078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3078. -- Resolution: Duplicate > JobManager does not shutdown when checkpointed jobs are running >

[jira] [Updated] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4062: Summary: Update Windowing Documentation (was: Update Window Documentation) > Update

[jira] [Assigned] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :(

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-3516: -- Assignee: Ufuk Celebi > JobManagerHACheckpointRecoveryITCase

[jira] [Updated] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-3516: --- Summary: JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails (was:

[jira] [Created] (FLINK-4062) Update Window Documentation

Aljoscha Krettek created FLINK-4062: --- Summary: Update Window Documentation Key: FLINK-4062 URL: https://issues.apache.org/jira/browse/FLINK-4062 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug

[ https://issues.apache.org/jira/browse/FLINK-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327105#comment-15327105 ] Flavio Pompermaier commented on FLINK-4061: --- Are you sure that you have only that exception? A

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[jira] [Closed] (FLINK-4059) Requirement of Streaming layer for Complex Event Processing

[ https://issues.apache.org/jira/browse/FLINK-4059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4059. --- Resolution: Invalid > Requirement of Streaming layer for Complex Event Processing >

[jira] [Commented] (FLINK-4059) Requirement of Streaming layer for Complex Event Processing

[ https://issues.apache.org/jira/browse/FLINK-4059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327093#comment-15327093 ] Aljoscha Krettek commented on FLINK-4059: - Hi, please ask questions such as this on the user

[GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2085#discussion_r66765910 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -980,110 +845,41 @@ protected ActorGateway

[GitHub] flink issue #2049: [FLINK-3971] [tableAPI] Aggregates handle null values inc...

Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/2049 @fhueske fixed! :) --- 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

[jira] [Commented] (FLINK-3971) Aggregates handle null values incorrectly.

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

[jira] [Created] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug

dengchangfu created FLINK-4061: -- Summary: about flink jdbc connect oracle db exists a crital bug Key: FLINK-4061 URL: https://issues.apache.org/jira/browse/FLINK-4061 Project: Flink Issue

[jira] [Commented] (FLINK-3971) Aggregates handle null values incorrectly.

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

[GitHub] flink pull request #2049: [FLINK-3971] [tableAPI] Aggregates handle null val...

Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/2049#discussion_r66765029 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/MaxAggregate.scala --- @@ -48,8 +57,16 @@ abstract

[jira] [Commented] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

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

[GitHub] flink pull request #2095: [FLINK-4046] [runtime] Add direct state transition...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2095 [FLINK-4046] [runtime] Add direct state transition from RESTARTING to FAILED A job can get stuck in FAILING if fail is called on a restarting job which has not yet reset its

[jira] [Updated] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4060: - Labels: test-stability (was: ) > WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed

[jira] [Created] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis

Till Rohrmann created FLINK-4060: Summary: WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis Key: FLINK-4060 URL: https://issues.apache.org/jira/browse/FLINK-4060 Project:

[jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :(

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327077#comment-15327077 ] Till Rohrmann commented on FLINK-3516: -- Another instance:

[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=15327056#comment-15327056 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/1771 Thank you for testing the cassandra connector. I'll merge the pull request now. --- 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-3971) Aggregates handle null values incorrectly.

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

[GitHub] flink issue #2049: [FLINK-3971] [tableAPI] Aggregates handle null values inc...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2049 Hi @gallenvara, thanks for the update! Looks good. After my last comment is fix, the PR should be good to merge. Thanks, Fabian --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327049#comment-15327049 ] Maximilian Michels commented on FLINK-3677: --- I assigned the issue to you. Please have a look at

[GitHub] flink pull request #2049: [FLINK-3971] [tableAPI] Aggregates handle null val...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2049#discussion_r66762005 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/MaxAggregate.scala --- @@ -48,8 +57,16 @@ abstract class

[jira] [Commented] (FLINK-3971) Aggregates handle null values incorrectly.

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

[jira] [Updated] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3677: -- Assignee: Ivan Mushketyk > FileInputFormat: Allow to specify include/exclude file name

[jira] [Assigned] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle

[ https://issues.apache.org/jira/browse/FLINK-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-4024: - Assignee: Kostas Kloudas > FileSourceFunction not adjusted to new IF lifecycle >

[jira] [Commented] (FLINK-3971) Aggregates handle null values incorrectly.

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

[GitHub] flink issue #2049: [FLINK-3971] [tableAPI] Aggregates handle null values inc...

Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/2049 @fhueske sorry for the late update. Codes have been modified based on your comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Created] (FLINK-4059) Requirement of Streaming layer for Complex Event Processing

Akshay Shingote created FLINK-4059: -- Summary: Requirement of Streaming layer for Complex Event Processing Key: FLINK-4059 URL: https://issues.apache.org/jira/browse/FLINK-4059 Project: Flink

<    1   2