[jira] [Comment Edited] (FLINK-7782) Flink CEP not recognizing pattern

[ https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198175#comment-16198175 ] Ajay edited comment on FLINK-7782 at 10/10/17 5:18 AM: --- Hi Kostas,

[jira] [Comment Edited] (FLINK-7782) Flink CEP not recognizing pattern

[ https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198175#comment-16198175 ] Ajay edited comment on FLINK-7782 at 10/10/17 5:15 AM: --- Hi Kostas,

[jira] [Commented] (FLINK-7782) Flink CEP not recognizing pattern

[ https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198175#comment-16198175 ] Ajay commented on FLINK-7782: - Hi Kostas, My stream is pretty much unbounded in an endless lo

[jira] [Assigned] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7764: -- Assignee: Xingcan Cui > FlinkKafkaProducer010 does not accept name, uid, or parallelism > -

[jira] [Commented] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

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

[GitHub] flink issue #4316: [FLINK-6105] Use InterruptedIOException instead of IOExce...

Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4316 I think InterruptedException should be handled uniformly in HadoopInputFormatBase.java ---

[jira] [Updated] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7049: -- Description: After integration tests finish, TestingApplicationMaster is still running. Toward the end of flin

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197673#comment-16197673 ] Fabian Hueske commented on FLINK-7548: -- I've created a proposal for a reworked TableS

[jira] [Commented] (FLINK-7787) Remove guava dependency in the cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197582#comment-16197582 ] Chesnay Schepler commented on FLINK-7787: - we can't get rid of the cassandra guava

[jira] [Created] (FLINK-7788) Allow port range for queryable state client proxy.

Kostas Kloudas created FLINK-7788: - Summary: Allow port range for queryable state client proxy. Key: FLINK-7788 URL: https://issues.apache.org/jira/browse/FLINK-7788 Project: Flink Issue Type

[jira] [Created] (FLINK-7787) Remove guava dependency in the cassandra connector

Haohui Mai created FLINK-7787: - Summary: Remove guava dependency in the cassandra connector Key: FLINK-7787 URL: https://issues.apache.org/jira/browse/FLINK-7787 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

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

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3748 Given we have dropped the support for Java 7, it might make sense to just rewrite the class to use the completablefuture in java 8. ---

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

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

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3748 When importing guava you have to explicitly add an exclusion to https://github.com/apache/flink/blob/master/tools/maven/suppressions.xml. ---

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197419#comment-16197419 ] ASF GitHub Bot commented on FLINK-6988: --- Github user pnowojski closed the pull reque

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197420#comment-16197420 ] ASF GitHub Bot commented on FLINK-6988: --- Github user pnowojski commented on the issu

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4239 Thanks :) ---

[GitHub] flink pull request #4239: [FLINK-6988] flink-connector-kafka-0.11 with exact...

Github user pnowojski closed the pull request at: https://github.com/apache/flink/pull/4239 ---

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

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

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @fhueske Hi zentol hasn't replied can you help to take a look. thx ---

[jira] [Commented] (FLINK-7731) Trigger on GlobalWindow does not clean state completely

[ https://issues.apache.org/jira/browse/FLINK-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197372#comment-16197372 ] Aljoscha Krettek commented on FLINK-7731: - No, FLINK-7700 is not related because w

[jira] [Commented] (FLINK-7072) Create RESTful cluster endpoint

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

[GitHub] flink pull request #4742: [FLINK-7072] [REST] Add Flip-6 client for submit/j...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4742 ---

[jira] [Closed] (FLINK-6988) Add Apache Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6988. --- Resolution: Fixed Implemented in 2f651e9a69a9929ef154e7bf6fcba624b0e8b9a1 and surrounding comm

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

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

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4239 Merged! 😃 Could you please close this PR? ---

[jira] [Commented] (FLINK-6219) Add a sorted state primitive

[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197278#comment-16197278 ] Fabian Hueske commented on FLINK-6219: -- Thanks [~phoenixjiangnan], I updated the link

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197245#comment-16197245 ] ASF GitHub Bot commented on FLINK-7388: --- Github user bowenli86 commented on a diff i

[GitHub] flink pull request #4786: [FLINK-7388][DataStream API] ProcessFunction.onTim...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4786#discussion_r143517965 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java --- @@ -79,7 +79,6 @@ public void onEventT

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197240#comment-16197240 ] ASF GitHub Bot commented on FLINK-6615: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #4787: [FLINK-6615][core] simplify FileUtils

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4787 I was looking into [FLINK-6615](https://issues.apache.org/jira/browse/FLINK-6615), and I think 6615 is not a problem due to files may be created concurrently. But I found the current impl of `dele

[jira] [Comment Edited] (FLINK-6219) Add a sorted state primitive

[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197188#comment-16197188 ] Bowen Li edited comment on FLINK-6219 at 10/9/17 4:18 PM: -- [~fhue

[jira] [Created] (FLINK-7786) JarActionHandler.tokenizeArguments removes all quotes from program arguments

Brice Bingman created FLINK-7786: Summary: JarActionHandler.tokenizeArguments removes all quotes from program arguments Key: FLINK-7786 URL: https://issues.apache.org/jira/browse/FLINK-7786 Project: F

[GitHub] flink pull request #4773: [FLINK-7761] [examples] Include shaded guava depen...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4773 ---

[jira] [Closed] (FLINK-7761) Twitter example is not self-contained

[ https://issues.apache.org/jira/browse/FLINK-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7761. --- Resolution: Fixed 1.4: 08bfdae684548c2e9edf189f29d892335fd27dd3 > Twitter example is not self

[jira] [Commented] (FLINK-7761) Twitter example is not self-contained

[ https://issues.apache.org/jira/browse/FLINK-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197215#comment-16197215 ] ASF GitHub Bot commented on FLINK-7761: --- Github user zentol closed the pull request

[jira] [Created] (FLINK-7785) DispatcherTest failure

Chesnay Schepler created FLINK-7785: --- Summary: DispatcherTest failure Key: FLINK-7785 URL: https://issues.apache.org/jira/browse/FLINK-7785 Project: Flink Issue Type: Bug Componen

[jira] [Commented] (FLINK-6219) Add a sorted state primitive

[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197188#comment-16197188 ] Bowen Li commented on FLINK-6219: - [~fhueske] I think the dependency in 'Issues Link' is s

[jira] [Reopened] (FLINK-6219) Add a sorted state primitive

[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reopened FLINK-6219: - > Add a sorted state primitive > > > Key: FLINK-6219 >

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197180#comment-16197180 ] ASF GitHub Bot commented on FLINK-7709: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

[ https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197181#comment-16197181 ] ASF GitHub Bot commented on FLINK-7739: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4777: [FLINK-7739] Enable dependency convergence

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4777#discussion_r143480344 --- Diff: flink-core/pom.xml --- @@ -77,6 +88,12 @@ under the License. org.apache.commons c

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4763#discussion_r143508371 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java --- @@ -33,8 +33,7 @@ objectMapper.enable

[jira] [Closed] (FLINK-7750) Strange behaviour in savepoints

[ https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7750. --- Resolution: Not A Problem > Strange behaviour in savepoints > ---

[jira] [Commented] (FLINK-7750) Strange behaviour in savepoints

[ https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197175#comment-16197175 ] Aljoscha Krettek commented on FLINK-7750: - If the data was not split when using Fl

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197170#comment-16197170 ] ASF GitHub Bot commented on FLINK-7709: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4763#discussion_r143505801 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -0,0 +1,534 @@ +/* +

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4763#discussion_r143504804 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -0,0 +1,534 @@ +/* +

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197163#comment-16197163 ] ASF GitHub Bot commented on FLINK-7709: --- Github user tillrohrmann commented on a dif

[jira] [Updated] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7495: Component/s: (was: State Backends, Checkpointing) DataStream API > Abst

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

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

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4763#discussion_r143502870 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -0,0 +1,534 @@ +/* + * Lice

[GitHub] flink pull request #4786: [FLINK-7388][DataStream API] ProcessFunction.onTim...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4786#discussion_r143502884 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java --- @@ -79,7 +79,6 @@ public void onEventTi

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197156#comment-16197156 ] ASF GitHub Bot commented on FLINK-7709: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-7167) Job can't set checkpoint meta directory to cover the system setting state.checkpoints.dir

[ https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197144#comment-16197144 ] Aljoscha Krettek commented on FLINK-7167: - Thanks for pointing this out, [~phoenix

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197137#comment-16197137 ] ASF GitHub Bot commented on FLINK-7709: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4763#discussion_r143500886 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -0,0 +1,534 @@ +/* +

[jira] [Closed] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient

[ https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5510. --- Resolution: Duplicate With the QS client reworking of FLINK-7770 this issue becomes obsolete s

[jira] [Commented] (FLINK-7736) Fix some of the alerts raised by lgtm.com

[ https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197132#comment-16197132 ] ASF GitHub Bot commented on FLINK-7736: --- Github user 1m2c3t4 commented on the issue:

[GitHub] flink issue #4784: FLINK-7736: fix some lgtm.com alerts

Github user 1m2c3t4 commented on the issue: https://github.com/apache/flink/pull/4784 All review comments addressed ---

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197131#comment-16197131 ] ASF GitHub Bot commented on FLINK-7709: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4763#discussion_r143499239 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -0,0 +1,534 @@ +/* +

[jira] [Commented] (FLINK-7782) Flink CEP not recognizing pattern

[ https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197108#comment-16197108 ] Kostas Kloudas commented on FLINK-7782: --- Hi [~ajkrishna], as seen in the JIRA that y

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197099#comment-16197099 ] ASF GitHub Bot commented on FLINK-7709: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4763#discussion_r143489310 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java --- @@ -33,8 +33,7 @@ objectMapper.enable(

[jira] [Commented] (FLINK-7606) CEP operator leaks state

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197094#comment-16197094 ] Kostas Kloudas commented on FLINK-7606: --- I do not think that this would solve the pr

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143487841 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,410 @@ +/* +

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197091#comment-16197091 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in th

[jira] [Created] (FLINK-7784) Don't fail TwoPhaseCommitSinkFunction when failing to commit

Aljoscha Krettek created FLINK-7784: --- Summary: Don't fail TwoPhaseCommitSinkFunction when failing to commit Key: FLINK-7784 URL: https://issues.apache.org/jira/browse/FLINK-7784 Project: Flink

[jira] [Updated] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7783: Summary: Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover() (wa

[jira] [Created] (FLINK-7783) Don't always remove checkpoints ZooKeeperCompletedCheckpointStore#recover()

Aljoscha Krettek created FLINK-7783: --- Summary: Don't always remove checkpoints ZooKeeperCompletedCheckpointStore#recover() Key: FLINK-7783 URL: https://issues.apache.org/jira/browse/FLINK-7783 Proje

[jira] [Commented] (FLINK-7782) Flink CEP not recognizing pattern

[ https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197028#comment-16197028 ] Ajay commented on FLINK-7782: - Here is an example of a simple event I am trying to detect. Th

[jira] [Commented] (FLINK-7782) Flink CEP not recognizing pattern

[ https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197027#comment-16197027 ] Ajay commented on FLINK-7782: - 1. Using an env parallelism of 1 performed similar with the add

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

[ https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197024#comment-16197024 ] ASF GitHub Bot commented on FLINK-7739: --- Github user pnowojski commented on the issu

[jira] [Commented] (FLINK-7782) Flink CEP not recognizing pattern

[ https://issues.apache.org/jira/browse/FLINK-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197023#comment-16197023 ] Ajay commented on FLINK-7782: - Related to FLINK-7606 > Flink CEP not recognizing pattern > --

[GitHub] flink pull request #4647: [FLINK-7575] [WEB-DASHBOARD] Display "Fetching..."...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4647 ---

[jira] [Commented] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

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

[GitHub] flink issue #4749: [FLINK-7739][tests] Properly shutdown resources in tests

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4749 Users shouldn't be able to call `shutdown()` and if they are, they shouldn't be using it (it would be incorrect). `shutdown()` was a protected method and shouldn't be used the users. Unfortunately

[jira] [Commented] (FLINK-7761) Twitter example is not self-contained

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

[jira] [Closed] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

[ https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7575. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: c7968e9c2ad6601f9f38b673ead5bc71611a6fbd >

[GitHub] flink issue #4773: [FLINK-7761] [examples] Include shaded guava dependency i...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4773 merging. ---

[jira] [Created] (FLINK-7782) Flink CEP not recognizing pattern

Ajay created FLINK-7782: --- Summary: Flink CEP not recognizing pattern Key: FLINK-7782 URL: https://issues.apache.org/jira/browse/FLINK-7782 Project: Flink Issue Type: Bug Reporter: Ajay I

[GitHub] flink issue #4787: [FLINK-6615][core] simplify FileUtils

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4787 Is there any problem with the current implementation? The current implementation was carefully done to gracefully handle concurrent removals and allow to pick whether to clean directories with

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

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

[jira] [Commented] (FLINK-5005) Remove Scala 2.10 support; add Scala 2.12 support

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

[jira] [Commented] (FLINK-5005) Remove Scala 2.10 support; add Scala 2.12 support

[ https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196947#comment-16196947 ] ASF GitHub Bot commented on FLINK-5005: --- Github user DieBauer closed the pull reques

[GitHub] flink pull request #3703: [FLINK-5005] WIP: publish scala 2.12 artifacts

Github user DieBauer closed the pull request at: https://github.com/apache/flink/pull/3703 ---

[GitHub] flink issue #3703: [FLINK-5005] WIP: publish scala 2.12 artifacts

Github user DieBauer commented on the issue: https://github.com/apache/flink/pull/3703 Hi, I'm sorry for the late reaction. I haven't found the time to work on this anymore (also priorities shifted... ) Therefore this pull request is stale. (it still could be used as a refere

[jira] [Created] (FLINK-7781) Support sime on-demand metrics aggregation

Chesnay Schepler created FLINK-7781: --- Summary: Support sime on-demand metrics aggregation Key: FLINK-7781 URL: https://issues.apache.org/jira/browse/FLINK-7781 Project: Flink Issue Type: Im

[jira] [Closed] (FLINK-5316) Make the GenericWriteAheadSink backwards compatible.

[ https://issues.apache.org/jira/browse/FLINK-5316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5316. --- Resolution: Won't Fix Closing for now since there was no noise about this. > Make the Generic

[jira] [Updated] (FLINK-5235) Don't automatically add HBase classpath to Flink classpath

[ https://issues.apache.org/jira/browse/FLINK-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5235: Summary: Don't automatically add HBase classpath to Flink classpath (was: HBase classpath a

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196863#comment-16196863 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143448956 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,410 @@ +/* +

[jira] [Commented] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

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

[GitHub] flink issue #4647: [FLINK-7575] [WEB-DASHBOARD] Display "Fetching..." instea...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4647 merging. ---

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143445293 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,410 @@ +/* +

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196845#comment-16196845 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in th

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196831#comment-16196831 ] Kostas Kloudas commented on FLINK-7756: --- Hi [~shashank734], thanks a lot for reporti

[jira] [Created] (FLINK-7780) Integrate savepoint command into REST client

Chesnay Schepler created FLINK-7780: --- Summary: Integrate savepoint command into REST client Key: FLINK-7780 URL: https://issues.apache.org/jira/browse/FLINK-7780 Project: Flink Issue Type:

  1   2   >