[jira] [Commented] (FLINK-7394) Implement basic InputChannel for credit-based logic

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119498#comment-16119498 ] ASF GitHub Bot commented on FLINK-7394: --- GitHub user zhijiangW opened a pull request

[GitHub] flink pull request #4499: [FLINK-7394][core] Implement basic InputChannel fo...

2017-08-08 Thread zhijiangW
GitHub user zhijiangW opened a pull request: https://github.com/apache/flink/pull/4499 [FLINK-7394][core] Implement basic InputChannel for credit-based logic ## What is the purpose of the change This pull request prepares the basic works for credit-based interaction with ne

[jira] [Commented] (FLINK-7352) ExecutionGraphRestartTest timeouts

2017-08-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119492#comment-16119492 ] Till Rohrmann commented on FLINK-7352: -- I think [~StephanEwen] is right and the probl

[jira] [Created] (FLINK-7394) Implement basic InputChannel for credit-based logic

2017-08-08 Thread zhijiang (JIRA)
zhijiang created FLINK-7394: --- Summary: Implement basic InputChannel for credit-based logic Key: FLINK-7394 URL: https://issues.apache.org/jira/browse/FLINK-7394 Project: Flink Issue Type: Sub-task

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

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119268#comment-16119268 ] ASF GitHub Bot commented on FLINK-6988: --- Github user rangadi commented on the issue:

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

2017-08-08 Thread rangadi
Github user rangadi commented on the issue: https://github.com/apache/flink/pull/4239 How does exactly-once sink handle large gap between `preCommit()` and `recoverAndCommit()` in case of a recovery? The server seems to abort a transaction after a timeout `max.transaction.timeout.ms`.

[jira] [Commented] (FLINK-7223) Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for Flink-kinesis-connector

2017-08-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119222#comment-16119222 ] Bowen Li commented on FLINK-7223: - I'm actually fine with the default value, since we are

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119163#comment-16119163 ] ASF GitHub Bot commented on FLINK-7367: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-08 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 Trying to understand the keys. Are keys like "aws.producer.collectionMaxCount" specified in flink-conf.yaml? --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119050#comment-16119050 ] ASF GitHub Bot commented on FLINK-7240: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #4497: [FLINK-7240] [tests] Stabilize ExternalizedCheckpointITCa...

2017-08-08 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4497 I actually think that this does not fully stabilize the test case. The problem is the following: Waiting for all `Tasks` to be in state `RUNNING` is not sufficient but only necessary. The `Strea

[jira] [Commented] (FLINK-7026) Add shaded asm dependency

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119032#comment-16119032 ] ASF GitHub Bot commented on FLINK-7026: --- Github user greghogan commented on the issu

[GitHub] flink issue #4494: [FLINK-7026] Introduce flink-shaded-asm-5

2017-08-08 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4494 +1 LGTM --- 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 f

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118969#comment-16118969 ] ASF GitHub Bot commented on FLINK-6281: --- Github user haohui commented on a diff in t

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-08 Thread haohui
Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132022891 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSink.java --- @@ -0,0 +1,85 @@ +/* + * Licensed

[jira] [Created] (FLINK-7393) Refactor FlinkKinesisConsumerTest

2017-08-08 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7393: --- Summary: Refactor FlinkKinesisConsumerTest Key: FLINK-7393 URL: https://issues.apache.org/jira/browse/FLINK-7393 Project: Flink Issue Type: Test Components:

[jira] [Resolved] (FLINK-7159) Semantics of OVERLAPS in Table API diverge from the SQL standard

2017-08-08 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai resolved FLINK-7159. --- Resolution: Fixed This has been resolved as a part of FLINK-6429. > Semantics of OVERLAPS in Table AP

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

2017-08-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118649#comment-16118649 ] Aljoscha Krettek commented on FLINK-7245: - Right now, this sounds more like an imp

[jira] [Assigned] (FLINK-7051) Bump up Calcite version to 1.14

2017-08-08 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-7051: - Assignee: Haohui Mai > Bump up Calcite version to 1.14 > --- > >

[jira] [Commented] (FLINK-7361) flink-web doesn't build with ruby 2.4

2017-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118596#comment-16118596 ] Chesnay Schepler commented on FLINK-7361: - Let's add it as a direct dependency, we

[jira] [Created] (FLINK-7392) Enable more predicate push-down in joins

2017-08-08 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-7392: - Summary: Enable more predicate push-down in joins Key: FLINK-7392 URL: https://issues.apache.org/jira/browse/FLINK-7392 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7361) flink-web doesn't build with ruby 2.4

2017-08-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118571#comment-16118571 ] Nico Kruber commented on FLINK-7361: I did some more digging and found out, that `yajl

[jira] [Assigned] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-7373: Assignee: Rong Rong > Using URLClassLoader to load UDF triggers HepPlanner unexpected > ClassNotFo

[jira] [Commented] (FLINK-7316) always use off-heap network buffers

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118511#comment-16118511 ] ASF GitHub Bot commented on FLINK-7316: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4481: [FLINK-7316][network] always use off-heap network buffers

2017-08-08 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4481 ok, one test fixed, the other is not so simple but maybe @tillrohrmann can help with it: Inside `ContaineredTaskManagerParameters#create()`, we calculate the amount of off-heap space that we n

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2017-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118510#comment-16118510 ] Chesnay Schepler commented on FLINK-6997: - This was probably fixed in d7f9f9e3ef4c

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

2017-08-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118503#comment-16118503 ] Fabian Hueske commented on FLINK-7245: -- Great that we are on the same page! Let's se

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

2017-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118491#comment-16118491 ] Xingcan Cui commented on FLINK-7245: Thanks for your responses, [~fhueske]. Actually,

[jira] [Updated] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-08-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7368: Fix Version/s: 1.3.3 1.4.0 > MetricStore makes cpu spin at 100% > ---

[jira] [Updated] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-08-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7368: Priority: Blocker (was: Major) > MetricStore makes cpu spin at 100% > -

[jira] [Commented] (FLINK-7352) ExecutionGraphRestartTest timeouts

2017-08-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118372#comment-16118372 ] Till Rohrmann commented on FLINK-7352: -- Another instance: https://travis-ci.org/apach

[jira] [Commented] (FLINK-7054) remove LibraryCacheManager#getFile()

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

[jira] [Resolved] (FLINK-7054) remove LibraryCacheManager#getFile()

2017-08-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7054. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 849990c00c1e7979b366088dbdba3f02a6123445

[GitHub] flink pull request #4235: [FLINK-7054] [blob] remove LibraryCacheManager#get...

2017-08-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4235 --- 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 enab

[jira] [Commented] (FLINK-7065) separate the flink-streaming-java module from flink-clients

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118354#comment-16118354 ] ASF GitHub Bot commented on FLINK-7065: --- Github user XuPingyong commented on the iss

[GitHub] flink issue #4273: [FLINK-7065] Separate the flink-streaming-java module fro...

2017-08-08 Thread XuPingyong
Github user XuPingyong commented on the issue: https://github.com/apache/flink/pull/4273 Thanks @tillrohrmann , I have updated this PR according to your advice. --- 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 proj

[jira] [Commented] (FLINK-7065) separate the flink-streaming-java module from flink-clients

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118352#comment-16118352 ] ASF GitHub Bot commented on FLINK-7065: --- Github user XuPingyong commented on a diff

[GitHub] flink pull request #4273: [FLINK-7065] Separate the flink-streaming-java mod...

2017-08-08 Thread XuPingyong
Github user XuPingyong commented on a diff in the pull request: https://github.com/apache/flink/pull/4273#discussion_r131918248 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamGraphExecutor.java --- @@ -0,0 +1,52 @@ +/* + * Lic

[jira] [Commented] (FLINK-7065) separate the flink-streaming-java module from flink-clients

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118348#comment-16118348 ] ASF GitHub Bot commented on FLINK-7065: --- Github user XuPingyong commented on a diff

[GitHub] flink pull request #4273: [FLINK-7065] Separate the flink-streaming-java mod...

2017-08-08 Thread XuPingyong
Github user XuPingyong commented on a diff in the pull request: https://github.com/apache/flink/pull/4273#discussion_r131916494 --- Diff: flink-contrib/flink-connector-wikiedits/pom.xml --- @@ -37,7 +37,7 @@ under the License. org.ap

[jira] [Commented] (FLINK-7387) Let RpcEndpoint directly implement RpcGateways

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118345#comment-16118345 ] ASF GitHub Bot commented on FLINK-7387: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #4498: [FLINK-7387] [rpc] Require RpcEndpoints to directl...

2017-08-08 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4498 [FLINK-7387] [rpc] Require RpcEndpoints to directly implement RpcGateways ## What is the purpose of the change This commit changes the relation between `RpcEndpoints` and `RpcGateways`.

[jira] [Updated] (FLINK-7390) Source download links broken for 1.2.0 to 1.3.1

2017-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7390: Summary: Source download links broken for 1.2.0 to 1.3.1 (was: Download links broken for 1.

[jira] [Created] (FLINK-7391) Normalize release entries

2017-08-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7391: --- Summary: Normalize release entries Key: FLINK-7391 URL: https://issues.apache.org/jira/browse/FLINK-7391 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118336#comment-16118336 ] ASF GitHub Bot commented on FLINK-7337: --- Github user wuchong commented on the issue:

[GitHub] flink issue #4488: [FLINK-7337] [table] Refactor internal handling of time i...

2017-08-08 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4488 @twalthr I'm working on other issues before Thursday, so I would like to have a look at it at Thursday (Beijing). But if you are hurry, I'm fine to merge this first. --- If your project is set up

[jira] [Created] (FLINK-7390) Download links for broken for 1.2.0 to 1.3.1

2017-08-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7390: --- Summary: Download links for broken for 1.2.0 to 1.3.1 Key: FLINK-7390 URL: https://issues.apache.org/jira/browse/FLINK-7390 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7390) Download links broken for 1.2.0 to 1.3.1

2017-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7390: Summary: Download links broken for 1.2.0 to 1.3.1 (was: Download links for broken for 1.2.0

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

2017-08-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118321#comment-16118321 ] Dawid Wysakowicz commented on FLINK-7169: - Hi [~ychen], Sorry for the delay. I wil

[GitHub] flink pull request #4454: [hotfix][docs] Add section in docs about writing u...

2017-08-08 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4454#discussion_r131906203 --- Diff: docs/dev/testing.md --- @@ -0,0 +1,189 @@ +--- +title: "Testing" +nav-parent_id: dev +nav-id: testing +nav-pos: 99 +---

[jira] [Commented] (FLINK-7365) excessive warning logs of attempt to override final parameter: fs.s3.buffer.dir

2017-08-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118314#comment-16118314 ] Aljoscha Krettek commented on FLINK-7365: - This can, for example, be achieved by e

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

2017-08-08 Thread Yueting Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118297#comment-16118297 ] Yueting Chen commented on FLINK-7169: - [~dawidwys] [~dian.fu] I hava updated the PR se

[GitHub] flink issue #4454: [hotfix][docs] Add section in docs about writing unit/int...

2017-08-08 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4454 Maybe we can merge this as it is and we can create a follow up ticket for figuring out what should be mentioned in watermarks testing section? To be honest I don't feel good enough qualified to des

[GitHub] flink pull request #4454: [hotfix][docs] Add section in docs about writing u...

2017-08-08 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4454#discussion_r131900306 --- Diff: docs/dev/testing.md --- @@ -0,0 +1,189 @@ +--- +title: "Testing" +nav-parent_id: dev +nav-id: testing +nav-pos: 99 +---

[jira] [Resolved] (FLINK-7382) Broken links in `Apache Flink Documentation` page

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7382. - Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed in 1.4: 8c7b3d9af5ffe

[jira] [Commented] (FLINK-7382) Broken links in `Apache Flink Documentation` page

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

[GitHub] flink pull request #4490: [FLINK-7382][docs] Fix some broken links in docs

2017-08-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4490 --- 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 enab

[jira] [Commented] (FLINK-7382) Broken links in `Apache Flink Documentation` page

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

[GitHub] flink issue #4490: [FLINK-7382][docs] Fix some broken links in docs

2017-08-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4490 Merging... --- 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

[jira] [Resolved] (FLINK-7301) Rework state documentation

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7301. - Resolution: Fixed Fix Version/s: 1.4.0 Fixed in 1.4.0: 470706740d5d89de69844a5662166ce94d71

[jira] [Commented] (FLINK-7301) Rework state documentation

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

[GitHub] flink pull request #4441: [FLINK-7301] [docs] Rework state documentation

2017-08-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4441 --- 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 enab

[jira] [Commented] (FLINK-7301) Rework state documentation

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

[GitHub] flink issue #4441: [FLINK-7301] [docs] Rework state documentation

2017-08-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4441 Thanks @alpinegizmo. I will merge this now. --- 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

[jira] [Closed] (FLINK-7300) End-to-end tests are instable on Travis

2017-08-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7300. --- Resolution: Fixed Fixed in 65402e034c32e47824fe46427d83eb9c9ea22d30 2ed74ca060ba64fefc7b53a236

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

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

[GitHub] flink issue #4488: [FLINK-7337] [table] Refactor internal handling of time i...

2017-08-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4488 @wuchong @sunjincheng121 @shaoxuan-wang do you also want to take a look at it? Otherwise I would merge this and work on the followup issue for more efficiency. --- If your project is set up for it,

[jira] [Resolved] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7385. Resolution: Fixed Thanks for the contribution! Merged to master via 6f5fa7f74153820

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

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

[GitHub] flink pull request #4496: [FLINK-7385] Fix ArrayIndexOutOfBoundsException wh...

2017-08-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4496 --- 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 enab

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

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

[GitHub] flink issue #4488: [FLINK-7337] [table] Refactor internal handling of time i...

2017-08-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4488 I'm fine with a followup issue. +1 to merge this. --- 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 fe

[jira] [Updated] (FLINK-7389) Remove Calcite PushProjector

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7389: Issue Type: Sub-task (was: Improvement) Parent: FLINK-7051 > Remove Calcite PushProjector >

[jira] [Created] (FLINK-7389) Remove Calcite PushProjector

2017-08-08 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7389: --- Summary: Remove Calcite PushProjector Key: FLINK-7389 URL: https://issues.apache.org/jira/browse/FLINK-7389 Project: Flink Issue Type: Improvement Co

[jira] [Closed] (FLINK-7236) Bump up the Calcite version to 1.14

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-7236. --- Resolution: Duplicate > Bump up the Calcite version to 1.14 > --- > >

[jira] [Updated] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7237: Issue Type: Sub-task (was: Bug) Parent: FLINK-7051 > Remove DateTimeUtils from Flink once C

[jira] [Updated] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7237: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7236) > Remove DateTimeUtils from F

[jira] [Updated] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7235: Issue Type: Sub-task (was: Bug) Parent: FLINK-7051 > Backport CALCITE-1884 to the Flink rep

[jira] [Updated] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

2017-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7235: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-6429) > Backport CALCITE-1884 to th

[jira] [Resolved] (FLINK-6429) Bump up Calcite version to 1.13

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

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

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

[GitHub] flink pull request #4373: [FLINK-6429] [table] Bump up Calcite version to 1....

2017-08-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4373 --- 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 enab

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118124#comment-16118124 ] ASF GitHub Bot commented on FLINK-7385: --- Github user aljoscha commented on the issue

[GitHub] flink issue #4496: [FLINK-7385] Fix ArrayIndexOutOfBoundsException when obje...

2017-08-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4496 Thanks, @tzulitai ! 😃 --- 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 wishe

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

2017-08-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118122#comment-16118122 ] Aljoscha Krettek commented on FLINK-7388: - This sounds legit, as long as we don't

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

2017-08-08 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7388: Summary: ProcessFunction.onTimer() sets processing time as timestamp Key: FLINK-7388 URL: https://issues.apache.org/jira/browse/FLINK-7388 Project: Flink Is

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118114#comment-16118114 ] ASF GitHub Bot commented on FLINK-7337: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4488: [FLINK-7337] [table] Refactor internal handling of time i...

2017-08-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4488 Thanks for the review @twalthr. I addressed your comments and updated the PR. I think it would be very good to handle the timestamps internally as longs. The change seems to be a bit more in

[jira] [Closed] (FLINK-7343) Kafka010ProducerITCase instability

2017-08-08 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-7343. - Resolution: Fixed Fix Version/s: 1.4.0 Hopefully with two recent changes this issue will no

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118105#comment-16118105 ] ASF GitHub Bot commented on FLINK-7343: --- Github user pnowojski closed the pull reque

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118104#comment-16118104 ] ASF GitHub Bot commented on FLINK-7343: --- Github user pnowojski commented on the issu

[GitHub] flink pull request #4470: [FLINK-7343] Simulate network failures in kafka at...

2017-08-08 Thread pnowojski
Github user pnowojski closed the pull request at: https://github.com/apache/flink/pull/4470 --- 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 e

[GitHub] flink issue #4470: [FLINK-7343] Simulate network failures in kafka at-least-...

2017-08-08 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4470 Thanks :) --- 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

[GitHub] flink issue #3580: [FLINK-5791] Support an optimal matching based slot manag...

2017-08-08 Thread shuai-xu
Github user shuai-xu commented on the issue: https://github.com/apache/flink/pull/3580 @tillrohrmann Could you please help to review this pr? And there is a question, the pending requests in slot managers are not in order. So requests arrived later may be fulfilled earlier, does this

[jira] [Commented] (FLINK-5791) Support an optimal matching based slot manager for flip6 yarn mode

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118098#comment-16118098 ] ASF GitHub Bot commented on FLINK-5791: --- Github user shuai-xu commented on the issue

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 +1 to option 3. Looks like we all agree on that :) @bowenli86 please feel free to continue with that. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

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

[GitHub] flink issue #4496: [FLINK-7385] Fix ArrayIndexOutOfBoundsException when obje...

2017-08-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4496 Thanks! Merging this to `master` and `release-1.3` .. --- 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 th

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

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

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

2017-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118073#comment-16118073 ] ASF GitHub Bot commented on FLINK-4499: --- Github user aljoscha commented on the issue

  1   2   >