[jira] [Created] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

2018-01-01 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8336: Summary: YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability Key: FLINK-8336 URL: https://issues.apache.org/jira/browse/FLINK-8336 Project: Flink

[jira] [Commented] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

2018-01-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307518#comment-16307518 ] ASF GitHub Bot commented on FLINK-8317: --- GitHub user GJL opened a pull request:

[GitHub] flink pull request #5223: [FLINK-8317][flip6] Implement Triggering of Savepo...

2018-01-01 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5223 [FLINK-8317][flip6] Implement Triggering of Savepoints ## What is the purpose of the change *Implement triggering of savepoints through HTTP and through command line in FLIP-6 mode. This PR is

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

2018-01-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8335: -- Description: hbase 1.4.0 has been released. 1.4.0 shows speed improvement over previous 1.x releases.

[jira] [Created] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

2018-01-01 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8335: - Summary: Upgrade hbase connector dependency to 1.4.0 Key: FLINK-8335 URL: https://issues.apache.org/jira/browse/FLINK-8335 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8334) Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer

2018-01-01 Thread Bhaskar Divya (JIRA)
Bhaskar Divya created FLINK-8334: Summary: Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer Key: FLINK-8334 URL:

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-01 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159153854 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/ContentDump.java --- @@ -0,0 +1,134 @@ +/* + * Licensed to

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-01 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159154132 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java --- @@ -492,6 +503,10 @@ public void

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307394#comment-16307394 ] ASF GitHub Bot commented on FLINK-8302: --- Github user dubin555 commented on the issue:

[GitHub] flink issue #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT support...

2018-01-01 Thread dubin555
Github user dubin555 commented on the issue: https://github.com/apache/flink/pull/5202 Hi @sunjincheng121 . Thanks for the review. I already finished some changed for code cleaning and remove the duplicate test case base on your comment. There are some similar implements

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-01 Thread dubin555
Github user dubin555 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r159151505 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala --- @@ -1216,6 +1216,69 @@ class

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307391#comment-16307391 ] ASF GitHub Bot commented on FLINK-8302: --- Github user dubin555 commented on a diff in the pull