[jira] [Resolved] (FLINK-1946) Make yarn tests logging less verbose

[ https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-1946. Resolution: Fixed This is resolved with 5b2ad7f03ef67ce529551e7b464d7db94e2a1d90.

[jira] [Closed] (FLINK-4837) flink-streaming-akka source connector

[ https://issues.apache.org/jira/browse/FLINK-4837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-4837. -- Resolution: Won't Fix Assignee: Subhobrata Dey > flink-streaming-akka source

[jira] [Commented] (FLINK-4837) flink-streaming-akka source connector

[ https://issues.apache.org/jira/browse/FLINK-4837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839390#comment-15839390 ] Tzu-Li (Gordon) Tai commented on FLINK-4837: Seems like this JIRA can be closed, as the

[jira] [Created] (FLINK-5650) flink-python unit test costs more than half hour

shijinkui created FLINK-5650: Summary: flink-python unit test costs more than half hour Key: FLINK-5650 URL: https://issues.apache.org/jira/browse/FLINK-5650 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-4463) FLIP-3: Restructure Documentation

[ https://issues.apache.org/jira/browse/FLINK-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839354#comment-15839354 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4463 at 1/26/17 7:12 AM: -

[jira] [Commented] (FLINK-4463) FLIP-3: Restructure Documentation

[ https://issues.apache.org/jira/browse/FLINK-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839354#comment-15839354 ] Tzu-Li (Gordon) Tai commented on FLINK-4463: I think some of the subtasks here are actually

[jira] [Issue Comment Deleted] (FLINK-4473) Add docs about end-to-end exactly once

[ https://issues.apache.org/jira/browse/FLINK-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4473: --- Comment: was deleted (was: I think some of the subtasks here are actually already

[jira] [Commented] (FLINK-4473) Add docs about end-to-end exactly once

[ https://issues.apache.org/jira/browse/FLINK-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839352#comment-15839352 ] Tzu-Li (Gordon) Tai commented on FLINK-4473: I think some of the subtasks here are actually

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

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

[GitHub] flink issue #605: [FLINK-1297] Added OperatorStatsAccumulator for tracking o...

Github user coveralls commented on the issue: https://github.com/apache/flink/pull/605 [](https://coveralls.io/builds/9850383) Changes Unknown when pulling **342f5c99cc530ccf2a6281223d1f4f917f1fb497 on

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink issue #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/3149 Fixed all the minor comments given above. @tonycox , @wuchong , @fhueske . --- 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

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

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

[GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1962 Thank you for picking this up again @sbcd90. I would wait until #3112 is merged before rebasing. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request #3031: [FLINK-4616] Added functionality through which wat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3031#discussion_r97935636 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java --- @@

[GitHub] flink pull request #3031: [FLINK-4616] Added functionality through which wat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3031#discussion_r97757847 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -101,7

[jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

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

[jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

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

[jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

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

[jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

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

[jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

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

[jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

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

[GitHub] flink pull request #3031: [FLINK-4616] Added functionality through which wat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3031#discussion_r97935971 --- Diff:

[GitHub] flink pull request #3031: [FLINK-4616] Added functionality through which wat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3031#discussion_r97935696 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java --- @@

[GitHub] flink pull request #3031: [FLINK-4616] Added functionality through which wat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3031#discussion_r97758477 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -345,39

[GitHub] flink pull request #3031: [FLINK-4616] Added functionality through which wat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3031#discussion_r97935720 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java --- @@

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97936002 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/* + *

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97934537 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/*

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97934510 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/*

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97934502 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/*

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97934495 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSource.java --- @@ -0,0 +1,65 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97934428 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,137 @@ +/* + * Licensed

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97934446 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,137 @@ +/* + * Licensed

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97934406 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,137 @@ +/* + * Licensed

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97927186 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/* + *

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t...

Github user sbcd90 commented on the issue: https://github.com/apache/flink/pull/1962 Hi @tzulitai , thanks for the updates. I'll refactor the code & will rebase the PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

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

[jira] [Commented] (FLINK-5546) java.io.tmpdir setted as project build directory in surefire plugin

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

[GitHub] flink issue #3190: [FLINK-5546][build] java.io.tmpdir setted as project buil...

Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3190 " /tmp/cacheFile (Permission denied)" exception of unit test can be replay. 1. on linux env, `sudo - userA`, clone the flink code, start to `mvn clean test verify` 2. on the linux

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

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

[GitHub] flink issue #3205: [FLINK-5635] Improve Docker tooling to make it easier to ...

Github user jgrier commented on the issue: https://github.com/apache/flink/pull/3205 Thanks @ex00. I missed that. Actually there is a new Flink on Docker stub in the top-level docs and I was planning to document these scripts there, however we may want to keep this here and just

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839036#comment-15839036 ] Jamie Grier commented on FLINK-5635: [~greghogan] I actually wasn't aware of [FLINK-4326]. However

[jira] [Assigned] (FLINK-5634) Flink should not always redirect stdout to a file.

[ https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Grier reassigned FLINK-5634: -- Assignee: Jamie Grier > Flink should not always redirect stdout to a file. >

[jira] [Assigned] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Grier reassigned FLINK-5635: -- Assignee: Jamie Grier > Improve Docker tooling to make it easier to build images and launch

[jira] [Updated] (FLINK-5640) configure the explicit Unit Test file suffix

[ https://issues.apache.org/jira/browse/FLINK-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5640: - Affects Version/s: 1.2.1 > configure the explicit Unit Test file suffix >

[jira] [Updated] (FLINK-5649) KryoException when starting job from Flink 1.2.0 rc0 savepoint

[ https://issues.apache.org/jira/browse/FLINK-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Kidder updated FLINK-5649: Description: I tried to submit a job using a savepoint taken with Flink 1.2.0 rc0 and encountered

[jira] [Created] (FLINK-5649) KryoException when starting job from Flink 1.2.0 rc0 savepoint

Scott Kidder created FLINK-5649: --- Summary: KryoException when starting job from Flink 1.2.0 rc0 savepoint Key: FLINK-5649 URL: https://issues.apache.org/jira/browse/FLINK-5649 Project: Flink

[jira] [Commented] (FLINK-5648) Task Manager ID missing from logs link in Job Manager UI

[ https://issues.apache.org/jira/browse/FLINK-5648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838860#comment-15838860 ] Scott Kidder commented on FLINK-5648: - May have been introduced in FLINK-5382 pull-request

[jira] [Updated] (FLINK-5648) Task Manager ID missing from logs link in Job Manager UI

[ https://issues.apache.org/jira/browse/FLINK-5648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Kidder updated FLINK-5648: Description: This appears to be a regression introduced in Flink 1.2.0 rc2. I've been using 1.2.0

[jira] [Created] (FLINK-5648) Task Manager ID missing from logs link in Job Manager UI

Scott Kidder created FLINK-5648: --- Summary: Task Manager ID missing from logs link in Job Manager UI Key: FLINK-5648 URL: https://issues.apache.org/jira/browse/FLINK-5648 Project: Flink Issue

[GitHub] flink issue #3189: [FLINK-5608] [webfrontend] Cancel button stays visible in...

Github user rehevkor5 commented on the issue: https://github.com/apache/flink/pull/3189 Thanks @uce that's helpful! Didn't think of putting screenshots in the PR. @zentol The global job state counts didn't seem like the most important thing to show when the browser is narrow,

[jira] [Commented] (FLINK-5608) Cancel button not always visible

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97898531 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,137 @@ +/* + * Licensed to

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97903962 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/* + *

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97897602 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,137 @@ +/* + * Licensed to

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97903708 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/* + *

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

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

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97901774 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSource.java --- @@ -0,0 +1,65 @@ +/* + * Licensed to

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97904966 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java --- @@ -0,0 +1,248 @@ +/* + *

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97900030 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,137 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-5612) GlobPathFilter not-serializable exception

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

[GitHub] flink issue #3206: [FLINK-5612] Fix GlobPathFilter not-serializable exceptio...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/3206 Hi @StephanEwen, @zentol Thank you for your comments. I've update the PR accordingly. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Created] (FLINK-5647) Fix RocksDB Backend Cleanup

Aljoscha Krettek created FLINK-5647: --- Summary: Fix RocksDB Backend Cleanup Key: FLINK-5647 URL: https://issues.apache.org/jira/browse/FLINK-5647 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5630) Followups to AggregationFunction

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

[jira] [Commented] (FLINK-5630) Followups to AggregationFunction

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

[GitHub] flink issue #3207: [FLINK-5630] [streaming api] Followups to the AggregateFu...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3207 Manually merged to `master` in 1542260d52238e87de4fa040e6079465777e8263 --- 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

[GitHub] flink pull request #3207: [FLINK-5630] [streaming api] Followups to the Aggr...

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

[jira] [Closed] (FLINK-5632) Typo in StreamGraph

[ https://issues.apache.org/jira/browse/FLINK-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5632. --- > Typo in StreamGraph > --- > > Key: FLINK-5632 > URL:

[jira] [Closed] (FLINK-5630) Followups to AggregationFunction

[ https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5630. --- > Followups to AggregationFunction > > > Key: FLINK-5630

[jira] [Resolved] (FLINK-5630) Followups to AggregationFunction

[ https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5630. - Resolution: Fixed Fixed in 1542260d52238e87de4fa040e6079465777e8263 > Followups to

[jira] [Commented] (FLINK-5632) Typo in StreamGraph

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

[jira] [Resolved] (FLINK-5632) Typo in StreamGraph

[ https://issues.apache.org/jira/browse/FLINK-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5632. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 6f5c7d8a68e3a1fa88902d8d314f350563b76752

[GitHub] flink pull request #3203: [FLINK-5632] [streaming] Typo in StreamGraph

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3203 --- 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-4912) Introduce RECONCILING state in ExecutionGraph

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

[GitHub] flink issue #3113: [FLINK-4912] Introduce RECONCILIATING state in ExecutionG...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3113 Considering the possible state transitions: ## ExecutionState - `RECONCILING` can only be entered from `CREATED` Simple: - `RECONCILING` can go to `RUNNING` if the

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

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

[GitHub] flink pull request #2836: [FLINK-5092] Add maven profile with code coverage ...

Github user BorisOsipov commented on a diff in the pull request: https://github.com/apache/flink/pull/2836#discussion_r97863068 --- Diff: flink-contrib/flink-storm-examples/pom.xml --- @@ -364,6 +363,18 @@ under the License.

[jira] [Created] (FLINK-5646) REST api documentation missing details on jar upload

Cliff Resnick created FLINK-5646: Summary: REST api documentation missing details on jar upload Key: FLINK-5646 URL: https://issues.apache.org/jira/browse/FLINK-5646 Project: Flink Issue

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

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

[GitHub] flink issue #2361: [FLINK-3318][cep] Add support for quantifiers to CEP's pa...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2361 Hi @mushketyk ! Yes. In this case we would expect to have everything apart from the "end" event in the result, right? --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #3113: [FLINK-4912] Introduce RECONCILIATING state in ExecutionG...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3113 Will merge this. To make it proper robust, I will add some tests that validate the state transitions of the state machine... --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

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

[GitHub] flink pull request #:

Github user mindprince commented on the pull request: https://github.com/apache/flink/commit/6342d6db1de5f38a921732e35abd83e6c5b9305a#commitcomment-20615018 In flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java: In

[jira] [Commented] (FLINK-5637) Default Flink configuration contains whitespace characters, causing parser WARNings

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

[GitHub] flink pull request #3216: [FLINK-5637] Avoid warning while parsing YAML conf...

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

  1   2   3   4   >