[jira] [Commented] (FLINK-5783) flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory

[ https://issues.apache.org/jira/browse/FLINK-5783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970154#comment-15970154 ] Eron Wright commented on FLINK-5783: - I suspect that the root cause of this is FLINK-6125. >

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970149#comment-15970149 ] Eron Wright commented on FLINK-5697: - My understanding is that per-partition watermarks make sense

[jira] [Commented] (FLINK-5966) Document Running Flink on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970094#comment-15970094 ] StephenWithPH commented on FLINK-5966: -- [~larrywu] It is not. I plan to resume work on this... as

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

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3477 Hi @eliaslevy , @dawidwys is right, in fact if the state's name is "a" and it has 2 matching events, there will be two returned keys "a_0" and "a_1". This is definitely counterintuitive and the reason

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

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/3477 Right now if the pattern name is "a" the events will be returned with keys: "a[0]", "a[1]" and so on, but agree it may be counterintuitive. Please file a JIRA for it. --- If your project is set

[jira] [Closed] (FLINK-5629) Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader()

[ https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5629. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: be26f7ed1e2b97bc2e6ab06d6267f8d542d78aee

[jira] [Closed] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler

[ https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6172. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: be26f7ed1e2b97bc2e6ab06d6267f8d542d78aee

[jira] [Closed] (FLINK-6299) make all IT cases extend from TestLogger

[ https://issues.apache.org/jira/browse/FLINK-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6299. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: 06db242ea12936fd62d243a1778bb32ca98e9232

[jira] [Closed] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore

[ https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6292. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: c96002cef5f1867573a473746241f86b59aeddd2

[jira] [Closed] (FLINK-6271) NumericBetweenParametersProvider NullPointer

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

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPointer

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

[jira] [Commented] (FLINK-6299) make all IT cases extend from TestLogger

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

[GitHub] flink pull request #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a s...

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

[GitHub] flink pull request #3708: [FLINK-6292] fix transfer.sh upload by using https

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3708 --- 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-6292) Travis: transfer.sh not accepting uploads via http:// anymore

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

[jira] [Commented] (FLINK-5629) Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader()

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

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

[GitHub] flink pull request #3710: [FLINK-6143] [clients] Fix unprotected access to t...

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

[GitHub] flink pull request #3713: [FLINK-6299] make all IT cases extend from TestLog...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3713 --- 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] [Updated] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6143: Affects Version/s: 1.3.0 > Unprotected access to this.flink in LocalExecutor#endSession() >

[GitHub] flink pull request #3678: [FLINK-5629] [runtime-web] Close RAF in FileServer...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3678 --- 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] [Closed] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

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

Github user eliaslevy commented on the issue: https://github.com/apache/flink/pull/3477 Am I missing something or is there no way to get access to access to multiple events matched by these new quantifiers? The `PatternSelectFunction.select` takes an argument of `Map` and

[jira] [Commented] (FLINK-6307) Refactor JDBC tests

[ https://issues.apache.org/jira/browse/FLINK-6307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970011#comment-15970011 ] ASF GitHub Bot commented on FLINK-6307: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3723: [FLINK-6307] [jdbc] Refactor JDBC tests

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3723 [FLINK-6307] [jdbc] Refactor JDBC tests Builds on top of #3686. List of changes: JDBCFullTest: - split testJdbcInOut into 2 methods to avoid manul test-lifecycle calls

[jira] [Created] (FLINK-6307) Refactor JDBC tests

Chesnay Schepler created FLINK-6307: --- Summary: Refactor JDBC tests Key: FLINK-6307 URL: https://issues.apache.org/jira/browse/FLINK-6307 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

[GitHub] flink issue #3710: [FLINK-6143] [clients] Fix unprotected access to this.fli...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3710 @zentol I am appreciate it. --- 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

[GitHub] flink issue #3710: [FLINK-6143] [clients] Fix unprotected access to this.fli...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3710 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] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

[GitHub] flink issue #3710: [FLINK-6143] [clients] Fix unprotected access to this.fli...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3710 @zentol I have updated the code. Thanks again. --- 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

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

[GitHub] flink pull request #3710: [FLINK-6143] [clients] Fix unprotected access to t...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/3710#discussion_r111666520 --- Diff: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java --- @@ -59,7 +59,7 @@ private final Object lock = new

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

[GitHub] flink pull request #3710: [FLINK-6143] [clients] Fix unprotected access to t...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/3710#discussion_r111666373 --- Diff: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java --- @@ -59,7 +59,7 @@ private final Object lock = new

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

[ https://issues.apache.org/jira/browse/FLINK-5646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969981#comment-15969981 ] ASF GitHub Bot commented on FLINK-5646: --- GitHub user hamstah opened a pull request:

[GitHub] flink pull request #3722: [FLINK-5646] Document JAR upload with the REST API

GitHub user hamstah opened a pull request: https://github.com/apache/flink/pull/3722 [FLINK-5646] Document JAR upload with the REST API Hi, It took me a while to get my upload working so I thought I would fix the documentation to help others. I wasn't sure if code examples

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

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

[GitHub] flink issue #3260: [FLINK-4604] Add support for standard deviation/variance

Github user ex00 commented on the issue: https://github.com/apache/flink/pull/3260 Hello, I updated PR for calcite 1.12. --- 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

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPointer

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

[GitHub] flink issue #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a single s...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3686 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] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

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

[GitHub] flink pull request #3710: [FLINK-6143] [clients] Fix unprotected access to t...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3710#discussion_r111663699 --- Diff: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java --- @@ -59,7 +59,7 @@ private final Object lock = new Object();

[GitHub] flink issue #3708: [FLINK-6292] fix transfer.sh upload by using https

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3708 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] [Commented] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore

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

[GitHub] flink issue #3713: [FLINK-6299] make all IT cases extend from TestLogger

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3713 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] [Commented] (FLINK-6299) make all IT cases extend from TestLogger

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