[GitHub] flink issue #3105: [FLINK-4641] [cep] Support branching CEP patterns

2018-03-11 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/3105 why it is closed ? Is it has been merged in? ---

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394873#comment-16394873 ] ASF GitHub Bot commented on FLINK-4641: --- Github user Aitozi commented on the issue:

[jira] [Commented] (FLINK-8794) When using BucketingSink, it happens that one of the files is always in the [.in-progress] state

2018-03-11 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394856#comment-16394856 ] Piotr Nowojski commented on FLINK-8794: --- Thanks for the update and good to hear that

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394852#comment-16394852 ] ASF GitHub Bot commented on FLINK-8335: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5488: [FLINK-8335] [hbase] Upgrade hbase connector dependency t...

2018-03-11 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5488 I paste the the 1.3.1 and 1.4.1 ```flink-hbase``` pom dependency tree respectively below. I watched the difference between the two dependencies. But I would hope @StephanEwen can see th

[jira] [Commented] (FLINK-8918) Introduce Runtime Filter Join

2018-03-11 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394817#comment-16394817 ] Sihua Zhou commented on FLINK-8918: --- Hi [~fhueske] could you please have a look at this

[jira] [Created] (FLINK-8918) Introduce Runtime Filter Join

2018-03-11 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-8918: - Summary: Introduce Runtime Filter Join Key: FLINK-8918 URL: https://issues.apache.org/jira/browse/FLINK-8918 Project: Flink Issue Type: Bug Components: T

[jira] [Commented] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct agg on DataStream

2018-03-11 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394806#comment-16394806 ] Rong Rong commented on FLINK-8690: -- Sweet. Thank you [~hequn8128]! I am still a bit skept

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394805#comment-16394805 ] ASF GitHub Bot commented on FLINK-8689: --- Github user walterddr commented on the issu

[GitHub] flink issue #5555: [FLINK-8689][table]Add runtime support of distinct filter...

2018-03-11 Thread walterddr
Github user walterddr commented on the issue: https://github.com/apache/flink/pull/ Thanks @hequn8128 for the prompt review. Are you suggesting we created the mapView parallel with the accumulator? The reason why I kept `DistinctAccumulator` is to act as a delegate to enclose

[GitHub] flink pull request #5679: [FLINK-8916] Checkpointing Mode is always shown to...

2018-03-11 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5679 [FLINK-8916] Checkpointing Mode is always shown to be "At Least Once" in Web UI ## What is the purpose of the change *This pull request add a customized serializer for checkpoint processing

[jira] [Commented] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394800#comment-16394800 ] ASF GitHub Bot commented on FLINK-8916: --- GitHub user yanghua opened a pull request:

[jira] [Commented] (FLINK-8357) enable rolling in default log settings

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394784#comment-16394784 ] ASF GitHub Bot commented on FLINK-8357: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5371: [FLINK-8357] [conf] Enable rolling in default log setting...

2018-03-11 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5371 Actually , I want do some test under the latest master code. ---

[jira] [Commented] (FLINK-8357) enable rolling in default log settings

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394778#comment-16394778 ] ASF GitHub Bot commented on FLINK-8357: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5371: [FLINK-8357] [conf] Enable rolling in default log setting...

2018-03-11 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5371 Hi, @StephanEwen .Sorry for later. 1. For the first question, I do not have a machine for this test at this moment and wont test it until I have a linux machine. Can not get a linux mac

[jira] [Commented] (FLINK-8917) FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394776#comment-16394776 ] ASF GitHub Bot commented on FLINK-8917: --- GitHub user jianran opened a pull request:

[GitHub] flink pull request #5678: [FLINK-8917] [Job-Submission] FlinkMiniCluster haS...

2018-03-11 Thread jianran
GitHub user jianran opened a pull request: https://github.com/apache/flink/pull/5678 [FLINK-8917] [Job-Submission] FlinkMiniCluster haService not same as ClusterClient FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient, the FlinkMiniClus

[jira] [Assigned] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

2018-03-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8916: --- Assignee: vinoyang > Checkpointing Mode is always shown to be "At Least Once" in Web UI > ---

[jira] [Created] (FLINK-8917) FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient

2018-03-11 Thread jianran.tfh (JIRA)
jianran.tfh created FLINK-8917: -- Summary: FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient Key: FLINK-8917 URL: https://issues.apache.org/jira/browse/FLINK-8917 Projec

[jira] [Commented] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-11 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394732#comment-16394732 ] mingleizhang commented on FLINK-8907: - I test this on a linux machine. All works well.

[jira] [Updated] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

2018-03-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7897: -- Description: nio.Files#delete() provides better clue as to why the deletion may fail: https://docs.oracle.com/j

[jira] [Updated] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown

2018-03-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8394: -- Description: {code} public void shutdown() { running = false; interrupt(); expectedRecord.complete

[jira] [Commented] (FLINK-8832) Create a SQL Client Kafka fat-jar

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

[GitHub] flink issue #5673: [FLINK-8832] [sql-client] Create a SQL Client Kafka 0.11 ...

2018-03-11 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5673 @zentol there is no big difference. It just an explicit suffix for users. It is not intended to be used in Maven projects. We will deploy it on Maven central and link to the jar in a special download

[jira] [Commented] (FLINK-8832) Create a SQL Client Kafka fat-jar

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394568#comment-16394568 ] ASF GitHub Bot commented on FLINK-8832: --- Github user zentol commented on the issue:

[GitHub] flink issue #5673: [FLINK-8832] [sql-client] Create a SQL Client Kafka 0.11 ...

2018-03-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5673 How is this any different to a regular fat jar? I'm wondering what the purpose of the `sql-jar` suffix is. ---

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

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

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394545#comment-16394545 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha closed the pull reques

[jira] [Closed] (FLINK-8487) State loss after multiple restart attempts

2018-03-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8487. --- Resolution: Fixed Added final tests. on release-1.5 b4f9e61b5d061f2fa9166bc5ea83ef6cd80eb0e6

[GitHub] flink issue #5656: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour ...

2018-03-11 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5656 merged ---

[GitHub] flink pull request #5656: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-11 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5656 ---

[jira] [Commented] (FLINK-8911) Add separate script for nightly end-to-end tests

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394542#comment-16394542 ] ASF GitHub Bot commented on FLINK-8911: --- Github user aljoscha closed the pull reques

[GitHub] flink issue #5674: [FLINK-8911] Add separate script for nightly end-to-end t...

2018-03-11 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5674 Thanks, @zentol! merged ---

[jira] [Commented] (FLINK-8911) Add separate script for nightly end-to-end tests

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

[GitHub] flink pull request #5674: [FLINK-8911] Add separate script for nightly end-t...

2018-03-11 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5674 ---

[jira] [Closed] (FLINK-8911) Add separate script for nightly end-to-end tests

2018-03-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8911. --- Resolution: Fixed On release-1.5 b4136d24831fe00d95e6d840748a6ee59b5336f8 On master 0f3b3f940

[GitHub] flink pull request #5589: [FLINK-8797] Port AbstractOperatorRestoreTestBase ...

2018-03-11 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5589 ---

[jira] [Closed] (FLINK-8778) Migrate queryable state ITCases to use MiniClusterResource

2018-03-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8778. --- Resolution: Fixed On release-1.5 735c95fbb93316475dc6dd6daa2aa91a7158c843 On master 8365c90b8

[jira] [Commented] (FLINK-8797) Port AbstractOperatorRestoreTestBase to MiniClusterResource

2018-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394538#comment-16394538 ] ASF GitHub Bot commented on FLINK-8797: --- Github user aljoscha closed the pull reques

[GitHub] flink issue #5589: [FLINK-8797] Port AbstractOperatorRestoreTestBase to Mini...

2018-03-11 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5589 merged ---

[jira] [Commented] (FLINK-8797) Port AbstractOperatorRestoreTestBase to MiniClusterResource

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

[jira] [Closed] (FLINK-8797) Port AbstractOperatorRestoreTestBase to MiniClusterResource

2018-03-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8797. --- Resolution: Fixed On release-1.5 7ab8ac352f5cedff8f95357c66d2631eee2fba52 On master 6732669a6

[jira] [Updated] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

2018-03-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8916: Description: This only happens in flip6 mode. The {{CheckpointConfigHandler}} returns the checkpoint mode u

[jira] [Created] (FLINK-8916) Checkpointing Mode is shown to be always "At Least Once" in Web UI

2018-03-11 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8916: --- Summary: Checkpointing Mode is shown to be always "At Least Once" in Web UI Key: FLINK-8916 URL: https://issues.apache.org/jira/browse/FLINK-8916 Project: Flink Issue

[jira] [Updated] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

2018-03-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8916: Summary: Checkpointing Mode is always shown to be "At Least Once" in Web UI (was: Checkpointing Mode is sho