[jira] [Closed] (FLINK-8196) Fix Hadoop Servlet Dependency Exclusion

2017-12-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8196. --- > Fix Hadoop Servlet Dependency Exclusion > --- > >

[jira] [Resolved] (FLINK-8196) Fix Hadoop Servlet Dependency Exclusion

2017-12-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8196. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in - 1.4.0 via

[jira] [Commented] (FLINK-6590) Integrate generated tables into documentation

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277285#comment-16277285 ] ASF GitHub Bot commented on FLINK-6590: --- Github user zentol closed the pull request at:

[jira] [Commented] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277300#comment-16277300 ] ASF GitHub Bot commented on FLINK-8176: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore i...

2017-12-04 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5107#discussion_r154747386 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -534,6 +536,40 @@ public void handleError(final Exception

[jira] [Commented] (FLINK-8193) Rework quickstart exclusions

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277258#comment-16277258 ] ASF GitHub Bot commented on FLINK-8193: --- Github user zentol commented on the issue:

[GitHub] flink issue #5118: [FLINK-8193][quickstart] Cleanup quickstart poms

2017-12-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5118 I'll add flink-clients again with a comment. ---

[jira] [Commented] (FLINK-8116) Stale comments referring to Checkpointed interface

2017-12-04 Thread Ankit Parashar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277280#comment-16277280 ] Ankit Parashar commented on FLINK-8116: --- Hi [~ggevay] , I have made the required changes, can you

[jira] [Commented] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277305#comment-16277305 ] ASF GitHub Bot commented on FLINK-8176: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore i...

2017-12-04 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5107#discussion_r154748301 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java --- @@ -244,7 +302,32 @@ protected JobManagerRunner

[jira] [Updated] (FLINK-8196) Fix Hadoop Servlet Dependency Exclusion

2017-12-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8196: -- Summary: Fix Hadoop Servlet Dependency Exclusion (was: Fix Hadoop Servled Dependency Exclusion) > Fix Hadoop

[GitHub] flink pull request #5121: [FLINK-8116] Stale comments referring to Checkpoin...

2017-12-04 Thread ankitiitb1069
GitHub user ankitiitb1069 opened a pull request: https://github.com/apache/flink/pull/5121 [FLINK-8116] Stale comments referring to Checkpointed interface ## What is the purpose of the change This pull request replaces the stale comments referring to Checkpointed interface

[GitHub] flink pull request #3916: [FLINK-6590] Integrate automatic docs generation

2017-12-04 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3916 ---

[GitHub] flink pull request #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore i...

2017-12-04 Thread GJL
GitHub user GJL reopened a pull request: https://github.com/apache/flink/pull/5107 [FLINK-8176][flip6] Start SubmittedJobGraphStore in Dispatcher ## What is the purpose of the change The FLIP-6 dispatcher never calls `start()` on its SubmittedJobGraphStore instance. Hence,

[jira] [Created] (FLINK-8197) Support include conf directories in flink config

2017-12-04 Thread Hao Sun (JIRA)
Hao Sun created FLINK-8197: -- Summary: Support include conf directories in flink config Key: FLINK-8197 URL: https://issues.apache.org/jira/browse/FLINK-8197 Project: Flink Issue Type: Improvement

[GitHub] flink issue #5114: [FLINK-8174] [mesos] Mesos RM unable to accept offers for...

2017-12-04 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5114 Thanks for your fast contribution @EronWright. I will take a closer look at the fix but from a first glance it seems that the `LaunchCoordinatorTest` fails. Could you fix this test case while I

[jira] [Commented] (FLINK-8174) Mesos RM unable to accept offers for unreserved resources

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277150#comment-16277150 ] ASF GitHub Bot commented on FLINK-8174: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277296#comment-16277296 ] ASF GitHub Bot commented on FLINK-8176: --- GitHub user GJL reopened a pull request:

[jira] [Created] (FLINK-8196) Fix Hadoop Servled Dependency Exclusion

2017-12-04 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8196: --- Summary: Fix Hadoop Servled Dependency Exclusion Key: FLINK-8196 URL: https://issues.apache.org/jira/browse/FLINK-8196 Project: Flink Issue Type: Bug

[GitHub] flink issue #5118: [FLINK-8193][quickstart] Cleanup quickstart poms

2017-12-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5118 `flink-core` is a direct dependency due to the usage of the

[jira] [Commented] (FLINK-8193) Rework quickstart exclusions

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277250#comment-16277250 ] ASF GitHub Bot commented on FLINK-8193: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8116) Stale comments referring to Checkpointed interface

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277274#comment-16277274 ] ASF GitHub Bot commented on FLINK-8116: --- GitHub user ankitiitb1069 opened a pull request:

[jira] [Created] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig

2017-12-04 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8198: - Summary: Useless check against -1 in LimitedConnectionsFileSystem#fromConfig Key: FLINK-8198 URL: https://issues.apache.org/jira/browse/FLINK-8198 Project: Flink Issue

[jira] [Commented] (FLINK-8197) Support include conf directories in flink config

2017-12-04 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277767#comment-16277767 ] Eron Wright commented on FLINK-8197: - Just an (obvious) suggestion: consider the included path to be

[jira] [Commented] (FLINK-7129) Dynamically changing patterns

2017-12-04 Thread Che Lui Shum (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277802#comment-16277802 ] Che Lui Shum commented on FLINK-7129: - Hi [~dawidwys], is there any plan to include this JIRA in the

[GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen...

2017-12-04 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/3359 @shixiaogang Sounds nice! Can you please open a PR if possible? Thanks! ---

[jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278040#comment-16278040 ] ASF GitHub Bot commented on FLINK-5544: --- Github user bowenli86 commented on the issue:

[jira] [Closed] (FLINK-8195) Add Redis Sink

2017-12-04 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wind closed FLINK-8195. --- Resolution: Fixed > Add Redis Sink > -- > > Key: FLINK-8195 > URL:

[jira] [Commented] (FLINK-7574) Remove unused dependencies from flink-clients

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277998#comment-16277998 ] ASF GitHub Bot commented on FLINK-7574: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #5076: [FLINK-7574][build] POM Cleanup flink-clients

2017-12-04 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/5076 @zentol thanks for your review. I have updated the PR. `mvn clean verify -Dverbose -pl flink-clients`,No dependency problems found: ``` [INFO] ---

[jira] [Commented] (FLINK-8192) Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal

2017-12-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278030#comment-16278030 ] mingleizhang commented on FLINK-8192: - [~tzulitai] I would create a subtask of Elasticsearch if you

[jira] [Created] (FLINK-8199) Annotation for Elasticsearch connector

2017-12-04 Thread mingleizhang (JIRA)
mingleizhang created FLINK-8199: --- Summary: Annotation for Elasticsearch connector Key: FLINK-8199 URL: https://issues.apache.org/jira/browse/FLINK-8199 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name

2017-12-04 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-8200: -- Summary: RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name Key: FLINK-8200 URL: https://issues.apache.org/jira/browse/FLINK-8200 Project:

[jira] [Assigned] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name

2017-12-04 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu reassigned FLINK-8200: -- Assignee: Wenlong Lyu > RocksDBAsyncSnapshotTest should use temp fold instead of fold with

[jira] [Created] (FLINK-8201) YarnResourceManagerTest causes license checking failure

2017-12-04 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-8201: -- Summary: YarnResourceManagerTest causes license checking failure Key: FLINK-8201 URL: https://issues.apache.org/jira/browse/FLINK-8201 Project: Flink Issue

[jira] [Commented] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278134#comment-16278134 ] ASF GitHub Bot commented on FLINK-8200: --- GitHub user wenlong88 opened a pull request:

[GitHub] flink issue #4976: [FLINK-8017] Fix High availability cluster-id key in docu...

2017-12-04 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/4976 Hi, @aljoscha Could you please merge this PR to `release-1.3` branch as well? Thank you. ---

[jira] [Commented] (FLINK-8192) Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal

2017-12-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278159#comment-16278159 ] Tzu-Li (Gordon) Tai commented on FLINK-8192: Sure thing [~mingleizhang]. It would also be good

[jira] [Commented] (FLINK-8017) High availability cluster-id option incorrect in documentation

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278092#comment-16278092 ] ASF GitHub Bot commented on FLINK-8017: --- Github user tony810430 commented on the issue:

[GitHub] flink pull request #5122: [FLINK-8200] RocksDBAsyncSnapshotTest should use t...

2017-12-04 Thread wenlong88
GitHub user wenlong88 opened a pull request: https://github.com/apache/flink/pull/5122 [FLINK-8200] RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name Using fixed folder in test makes test fail when different users run the test in the same machine. We

[GitHub] flink pull request #5123: [FLINK-8201] YarnResourceManagerTest causes licens...

2017-12-04 Thread wenlong88
GitHub user wenlong88 opened a pull request: https://github.com/apache/flink/pull/5123 [FLINK-8201] YarnResourceManagerTest causes license checking failure YarnResourceManagerTest generates a temporary taskmanager config file in flink-yarn module root folder and never clear

[jira] [Commented] (FLINK-8201) YarnResourceManagerTest causes license checking failure

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278165#comment-16278165 ] ASF GitHub Bot commented on FLINK-8201: --- GitHub user wenlong88 opened a pull request:

[jira] [Updated] (FLINK-8146) Potential resource leak in PythonPlanBinder#unzipPythonLibrary

2017-12-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8146: -- Component/s: Python API > Potential resource leak in PythonPlanBinder#unzipPythonLibrary >

[jira] [Commented] (FLINK-8100) Consider introducing log4j-extras

2017-12-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277130#comment-16277130 ] Ted Yu commented on FLINK-8100: --- I did a brief search and found:

[GitHub] flink issue #5118: [FLINK-8193][quickstart] Cleanup quickstart poms

2017-12-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5118 I think that the change of `1.` is actually not necessary. The dependencies were good in my opinion: - `flink-core` is not directly needed, because it is a transitive dependency of

[GitHub] flink issue #5118: [FLINK-8193][quickstart] Cleanup quickstart poms

2017-12-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5118 Is there a way to fail the build if users do not use the `-Pbuild-jar` profile? I would assume that right now, at least half of the users build a mother-of-all-jars that includes all of Flink.

[jira] [Commented] (FLINK-8193) Rework quickstart exclusions

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277142#comment-16277142 ] ASF GitHub Bot commented on FLINK-8193: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-8193) Rework quickstart exclusions

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277144#comment-16277144 ] ASF GitHub Bot commented on FLINK-8193: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

2017-12-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277149#comment-16277149 ] Stephan Ewen commented on FLINK-5297: - [~till.rohrmann] Is this still valid, or can we close this due

[GitHub] flink pull request #5040: [FLINK-8104][Table API] fixing ROW type value cons...

2017-12-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5040 ---

[jira] [Commented] (FLINK-7907) Flink Metrics documentation missing Scala examples

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276481#comment-16276481 ] ASF GitHub Bot commented on FLINK-7907: --- Github user zentol commented on the issue:

[GitHub] flink pull request #5110: [hotfix][docs] Fix typo in Checkpointing doc

2017-12-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5110 ---

[jira] [Resolved] (FLINK-8104) Fix Row value constructor

2017-12-04 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8104. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5:

[jira] [Updated] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7595: Fix Version/s: 1.4.0 > Removing stateless task from task chain breaks savepoint restore >

[jira] [Updated] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7595: Priority: Blocker (was: Major) > Removing stateless task from task chain breaks savepoint

[jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8186: Priority: Blocker (was: Minor) > AvroInputFormat regression: fails to deserialize

[GitHub] flink issue #5048: [Flink-7871] [flip6] SlotPool should release unused slots...

2017-12-04 Thread ifndef-SleePy
Github user ifndef-SleePy commented on the issue: https://github.com/apache/flink/pull/5048 Hi Till, thank you for reviewing. I agree that it is much simpler to use `scheduleRunAsync`. [PR-5091](https://github.com/apache/flink/pull/5091) is not a small reworking. But

[jira] [Updated] (FLINK-8148) Test instability in YarnFileStageTest

2017-12-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8148: Fix Version/s: 1.5.0 > Test instability in YarnFileStageTest >

[jira] [Commented] (FLINK-8148) Test instability in YarnFileStageTest

2017-12-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276477#comment-16276477 ] Chesnay Schepler commented on FLINK-8148: - master: 4bd0ef1b5208ff3a853fbb7c3d74edc5317d0245 >

[jira] [Closed] (FLINK-7907) Flink Metrics documentation missing Scala examples

2017-12-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7907. --- Resolution: Fixed Fix Version/s: 1.4.0 master:

[GitHub] flink pull request #5099: [FLINK-8080][metrics] Remove need for "metrics.rep...

2017-12-04 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5099#discussion_r154598676 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java --- @@ -43,8 +46,8 @@ private static

[jira] [Commented] (FLINK-7883) Stop fetching source before a cancel with savepoint

2017-12-04 Thread Antoine Philippot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276539#comment-16276539 ] Antoine Philippot commented on FLINK-7883: -- ok [~aljoscha], thanks for your feedback, it is far

[jira] [Commented] (FLINK-8080) Remove need for "metrics.reporters"

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276538#comment-16276538 ] ASF GitHub Bot commented on FLINK-8080: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink issue #5040: [FLINK-8104][Table API] fixing ROW type value constructor...

2017-12-04 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5040 Thanks for the update @walterddr. I will merge this... ---

[jira] [Commented] (FLINK-8104) Fix Row value constructor

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276451#comment-16276451 ] ASF GitHub Bot commented on FLINK-8104: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-8080) Remove need for "metrics.reporters"

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276465#comment-16276465 ] ASF GitHub Bot commented on FLINK-8080: --- Github user zentol commented on the issue:

[GitHub] flink issue #5099: [FLINK-8080][metrics] Remove need for "metrics.reporters"...

2017-12-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5099 only checking for the class makes sense. ---

[GitHub] flink issue #5099: [FLINK-8080][metrics] Remove need for "metrics.reporters"...

2017-12-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5099 We could also make `metrics.reporters` an optional list of reporters to enable; by default we include all reporters we can find. This would be more user-friendly since you wouldn't have to modify the

[jira] [Commented] (FLINK-8080) Remove need for "metrics.reporters"

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276476#comment-16276476 ] ASF GitHub Bot commented on FLINK-8080: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8148) Test instability in YarnFileStageTest

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276471#comment-16276471 ] ASF GitHub Bot commented on FLINK-8148: --- Github user asfgit closed the pull request at:

[GitHub] flink issue #5071: [FLINK-7907][docs] The metrics documentation missing scal...

2017-12-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5071 merging. ---

[jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8186: Fix Version/s: 1.4.0 > AvroInputFormat regression: fails to deserialize GenericRecords on

[jira] [Assigned] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector

2017-12-04 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-8191: --- Assignee: Aegeaner > Add a RoundRobinPartitioner to be shipped with the Kafka connector >

[jira] [Commented] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0

2017-12-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276469#comment-16276469 ] Fabian Hueske commented on FLINK-8177: -- +1 for mocking the `Container` as proposed by [~aljoscha]. >

[GitHub] flink issue #5071: [FLINK-7907][docs] The metrics documentation missing scal...

2017-12-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5071 merged, could you close the PR? Thanks! ---

[jira] [Commented] (FLINK-7907) Flink Metrics documentation missing Scala examples

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276489#comment-16276489 ] ASF GitHub Bot commented on FLINK-7907: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276432#comment-16276432 ] Timo Walther commented on FLINK-8186: - I think we should rework the dependencies of our quickstarts.

[GitHub] flink pull request #5066: [FLINK-8148][yarn/s3] fix test instability in Yarn...

2017-12-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5066 ---

[GitHub] flink issue #5110: [hotfix][docs] Fix typo in Checkpointing doc

2017-12-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5110 merging. ---

[jira] [Commented] (FLINK-8104) Fix Row value constructor

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276478#comment-16276478 ] ASF GitHub Bot commented on FLINK-8104: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-8190) Add extra FlinkKafkaConsumer constructors to expose pattern-based topic subscription functionality

2017-12-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8190: --- Description: The required internals for pattern-based topic discovery was implemented

[jira] [Commented] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276657#comment-16276657 ] Tzu-Li (Gordon) Tai commented on FLINK-8181: Closing this issue. For a full view of the

[jira] [Resolved] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8181. Resolution: Won't Fix > Kafka producer's FlinkFixedPartitioner returns different

[jira] [Closed] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8181. -- > Kafka producer's FlinkFixedPartitioner returns different partitions when a > target

[GitHub] flink pull request #5071: [FLINK-7907][docs] The metrics documentation missi...

2017-12-04 Thread yew1eb
Github user yew1eb closed the pull request at: https://github.com/apache/flink/pull/5071 ---

[GitHub] flink pull request #5118: [FLINK-8193][quickstart] Cleanup quickstart poms

2017-12-04 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5118 [FLINK-8193][quickstart] Cleanup quickstart poms ## What is the purpose of the change This PR addresses 2 problems in the quick start poms: 1) The poms declared unused dependencies

[jira] [Commented] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276612#comment-16276612 ] ASF GitHub Bot commented on FLINK-8191: --- GitHub user Aegeaner opened a pull request:

[GitHub] flink pull request #5116: [FLINK-8191] [Kafka Connector] Add a RoundRobinPar...

2017-12-04 Thread Aegeaner
GitHub user Aegeaner opened a pull request: https://github.com/apache/flink/pull/5116 [FLINK-8191] [Kafka Connector] Add a RoundRobinPartitioner to be shipped with the Kafka… Add a RoundRobinPartitioner to be shipped with the Kafka connector *Thank you very much for

[jira] [Commented] (FLINK-8164) JobManager's archiving does not work on S3

2017-12-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276651#comment-16276651 ] Chesnay Schepler commented on FLINK-8164: - This is caused by a too restrictive check in the

[jira] [Commented] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276655#comment-16276655 ] ASF GitHub Bot commented on FLINK-8181: --- Github user tzulitai closed the pull request at:

[GitHub] flink issue #5108: [FLINK-8181] [kafka] Make FlinkFixedPartitioner insensiti...

2017-12-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5108 After some offline discussion with @aljoscha, we decided to leave the `FlinkFixedPartitioner` as it is, and close this PR. I personally also agree with this mainly due to: > However, if we

[jira] [Commented] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276653#comment-16276653 ] ASF GitHub Bot commented on FLINK-8181: --- Github user tzulitai commented on the issue:

[GitHub] flink pull request #5108: [FLINK-8181] [kafka] Make FlinkFixedPartitioner in...

2017-12-04 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/5108 ---

[GitHub] flink pull request #4651: [FLINK-7595] [Savepoints] Allow removing stateless...

2017-12-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4651 ---

[jira] [Closed] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-12-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7595. --- Resolution: Fixed master: 80348d653b48e1b7d6a0b9275dbfa510eaea151f > Removing stateless task

[jira] [Updated] (FLINK-8148) Test instability in YarnFileStageTest

2017-12-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8148: Fix Version/s: (was: 1.5.0) 1.4.0 > Test instability in

[jira] [Created] (FLINK-8192) Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal

2017-12-04 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8192: -- Summary: Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal Key: FLINK-8192 URL:

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

2017-12-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276692#comment-16276692 ] Fabian Hueske commented on FLINK-8182: -- The {{TextInputFormat}} recursively lists files in the

[GitHub] flink pull request #5102: [FLINK-7762, FLINK-8167] Clean up and harden Wikip...

2017-12-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5102 ---

[jira] [Updated] (FLINK-8167) Failing WikipediaEditsSourceTest on Travis

2017-12-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8167: Affects Version/s: (was: 1.5.0) 1.4.0 > Failing

  1   2   3   >