[jira] [Created] (FLINK-8301) Support Unicode in codegen for TableAPI && SQL

2017-12-21 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-8301: - Summary: Support Unicode in codegen for TableAPI && SQL Key: FLINK-8301 URL: https://issues.apache.org/jira/browse/FLINK-8301 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8301) Support Unicode in codegen for TableAPI && SQL

2017-12-21 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-8301: -- Description: The current code generation do not support Unicode, "\u0001" will be generated to

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

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

[GitHub] flink issue #5185: [FLINK-8297] [flink-rocksdb] optionally use RocksDBMapSta...

2017-12-21 Thread je-ik
Github user je-ik commented on the issue: https://github.com/apache/flink/pull/5185 I think that the failed test is not related to this PR. ---

[GitHub] flink issue #5192: [FLINK-8257] [conf] Unify the value checks for setParalle...

2017-12-21 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5192 Hi @aljoscha, I wonder if you could help review this PR when you are convenient. Thanks, Xingcan ---

[GitHub] flink pull request #5187: Merge pull request #1 from apache/master

2017-12-21 Thread laolang113
Github user laolang113 closed the pull request at: https://github.com/apache/flink/pull/5187 ---

[jira] [Commented] (FLINK-8258) Enable query configuration for batch queries

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

[jira] [Commented] (FLINK-8257) Unify the value checks for setParallelism()

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

[GitHub] flink issue #5169: [FLINK-8258] [table] Enable query configuration for batch...

2017-12-21 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5169 Hi @twalthr, I wonder if you could help review this PR when you are convenient. Thanks, Xingcan ---

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

2017-12-21 Thread DuBin (JIRA)
DuBin created FLINK-8302: Summary: Support shift_left and shift_right in TableAPI Key: FLINK-8302 URL: https://issues.apache.org/jira/browse/FLINK-8302 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

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

[GitHub] flink issue #3915: [FLINK-6352] Support to use timestamp to set the initial ...

2017-12-21 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/3915 @tzulitai I notice that there's some update of this issue, so rebase master to this PR, could you please take a look when you're free, thanks ---

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158264752 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/StreamingProgramTestBase.java --- @@ -66,47 +47,34 @@

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158265225 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.java --- @@ -19,81 +19,61 @@ package

[jira] [Created] (FLINK-8303) Update Savepoint Compatibility Table for 1.4

2017-12-21 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8303: Summary: Update Savepoint Compatibility Table for 1.4 Key: FLINK-8303 URL: https://issues.apache.org/jira/browse/FLINK-8303 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158254745 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.java --- @@ -19,81 +19,61 @@ package

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158257284 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.java --- @@ -19,81 +19,61 @@ package

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158259149 --- Diff: flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkSecuredITCase.java --- @@ -215,23

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

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

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

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

2017-12-21 Thread dubin555
GitHub user dubin555 opened a pull request: https://github.com/apache/flink/pull/5196 [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT supported in SQL In this PR, SHIFT_LEFT and SHIFT_RIGHT are added. *(General:)* - *The pull request references the related JIRA

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158259995 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.java --- @@ -55,6 +55,7 @@

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158260663 --- Diff: flink-examples/flink-examples-streaming/src/test/scala/org/apache/flink/streaming/scala/examples/StreamingExamplesITCase.scala --- @@ -23,8 +23,7 @@

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

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

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

2017-12-21 Thread dubin555
Github user dubin555 closed the pull request at: https://github.com/apache/flink/pull/5196 ---

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

2017-12-21 Thread dubin555
GitHub user dubin555 opened a pull request: https://github.com/apache/flink/pull/5197 [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT supported in SQL In this PR, SHIFT_LEFT and SHIFT_RIGHT are added. ## General - *The pull request references the related JIRA issue,

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

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

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

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

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

2017-12-21 Thread dubin555
GitHub user dubin555 opened a pull request: https://github.com/apache/flink/pull/5198 [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT supported in SQL In this PR, SHIFT_LEFT and SHIFT_RIGHT are added. General The pull request references the related JIRA issue,

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink pull request #4896: [FLINK-7909] Unify Flink test bases

2017-12-21 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4896#discussion_r158261437 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/TimeAttributesITCase.scala --- @@ -18,8 +18,8 @@ package

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink pull request #5204: Release 1.4

2017-12-21 Thread zhentaowang
GitHub user zhentaowang opened a pull request: https://github.com/apache/flink/pull/5204 Release 1.4 *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your contribution in the best possible

[jira] [Updated] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments

2017-12-21 Thread Colin Williams (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin Williams updated FLINK-8307: -- Description: I need to set

[jira] [Commented] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

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

[jira] [Commented] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

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

[GitHub] flink pull request #5189: [FLINK-8283] [kafka] Introduce KafkaOffsetCommitte...

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

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

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

[jira] [Commented] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

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

[GitHub] flink pull request #5201: [FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerB...

2017-12-21 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5201 [FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerBaseTest::testScaleUp() ## What is the purpose of the change This PR sits upon other `FlinkKafkaConsumerBaseTest` changes from #5188 and

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Updated] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

2017-12-21 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-8301: -- Summary: Support Unicode in codegen for SQL && TableAPI (was: Support Unicode in codegen for SQL) >

[GitHub] flink issue #5189: [FLINK-8283] [kafka] Introduce KafkaOffsetCommitter inter...

2017-12-21 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5189 It seems like that the mock issue on `AbstractFetcher::commitInternalOffsetsToKafka` is not the root cause of the test instabilities mentioned in FLINK-8283. It is rather just a separate issue.

[jira] [Commented] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods

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

[GitHub] flink pull request #5200: [FLINK-8306] [kafka] Introduce KafkaOffsetCommitte...

2017-12-21 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5200 [FLINK-8306] [kafka] Introduce KafkaOffsetCommitter interface ## What is the purpose of the change This PR is built upon the reworked `FlinkKafkaConsumerBaseTest` in #5188. Prior

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

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

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

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

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

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

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

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

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

2017-12-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r158400738 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java --- @@ -98,7 +99,13 @@

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

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

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

2017-12-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r158397131 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TaskTestBase.java --- @@ -145,19 +145,7 @@ public MemoryManager

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

2017-12-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r158401883 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java --- @@ -179,9 +179,6 @@

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

2017-12-21 Thread dubin555
GitHub user dubin555 opened a pull request: https://github.com/apache/flink/pull/5202 [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT supported in SQL In this PR, SHIFT_LEFT and SHIFT_RIGHT are added. ## General The pull request references the related JIRA issue,

[jira] [Commented] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

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

[GitHub] flink pull request #5203: [FLINK-8301] Support Unicode in codegen for SQL &&...

2017-12-21 Thread Xpray
GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/5203 [FLINK-8301] Support Unicode in codegen for SQL && TableAPI ## What is the purpose of the change *support unicode literal in sql and handles code generation correctly

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

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

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

2017-12-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r158394094 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java --- @@ -277,88 +263,67 @@

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

2017-12-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r158398663 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java --- @@ -823,39 +839,44 @@

[jira] [Created] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments

2017-12-21 Thread Colin Williams (JIRA)
Colin Williams created FLINK-8307: - Summary: org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments Key: FLINK-8307 URL: https://issues.apache.org/jira/browse/FLINK-8307

[jira] [Assigned] (FLINK-7712) Port JarDeleteHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7712: Assignee: Fang Yong > Port JarDeleteHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7711) Port JarListHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7711: Assignee: Fang Yong > Port JarListHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7714) Port JarPlanHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7714: Assignee: Fang Yong > Port JarPlanHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7715) Port JarRunHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7715: Assignee: Fang Yong > Port JarRunHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7713: Assignee: Fang Yong > Port JarUploadHandler to new REST endpoint >

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

2017-12-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r158401540 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/SourceFunctionUtil.java --- @@ -42,22 +41,32 @@ public class

[jira] [Updated] (FLINK-8301) Support Unicode in codegen for SQL

2017-12-21 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-8301: -- Summary: Support Unicode in codegen for SQL (was: Support Unicode in codegen for TableAPI && SQL) >

[GitHub] flink issue #5178: [hotfix] Fix typo in TestableKinesisDataFetcher

2017-12-21 Thread casidiablo
Github user casidiablo commented on the issue: https://github.com/apache/flink/pull/5178 👍 ---

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

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

[GitHub] flink pull request #5199: [hotfix] [javadoc] Fix typos in MemorSegment class

2017-12-21 Thread casidiablo
GitHub user casidiablo opened a pull request: https://github.com/apache/flink/pull/5199 [hotfix] [javadoc] Fix typos in MemorSegment class You can merge this pull request into a Git repository by running: $ git pull https://github.com/casidiablo/flink

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-12-21 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7756: Affects Version/s: 1.4.0 > RocksDB state backend Checkpointing (Async and Incremental) is

[jira] [Reopened] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-12-21 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-7756: - Checked with version 1.4.0 still coming this issue, I have checked it's creating files and

[jira] [Commented] (FLINK-8031) Provide configuration to enable/disable ability to cancel jobs in Web Frontend

2017-12-21 Thread Stephen Hesketh (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16300228#comment-16300228 ] Stephen Hesketh commented on FLINK-8031: This is one particular UI permission control that is

[jira] [Updated] (FLINK-8031) Provide configuration to enable/disable ability to cancel jobs in Web Frontend

2017-12-21 Thread Stephen Hesketh (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Hesketh updated FLINK-8031: --- Description: The Web API can be configured to prevent job submission by setting

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

2017-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16300222#comment-16300222 ] Fabian Hueske commented on FLINK-8240: -- Thanks for starting this discussion [~twalthr]. I agree, we

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

2017-12-21 Thread dubin555
Github user dubin555 closed the pull request at: https://github.com/apache/flink/pull/5197 ---

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

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

[jira] [Created] (FLINK-8304) Document Kubernetes and Flink HA setup

2017-12-21 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-8304: -- Summary: Document Kubernetes and Flink HA setup Key: FLINK-8304 URL: https://issues.apache.org/jira/browse/FLINK-8304 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8278) Scala examples in Metric documentation do not compile

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

[GitHub] flink issue #5177: [FLINK-8278] [doc] Fix the private member init problem fo...

2017-12-21 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5177 Hi @fhueske, I wonder if you could have a look at this PR when you are convenient. Thanks, Xingcan ---

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

2017-12-21 Thread dubin555
Github user dubin555 closed the pull request at: https://github.com/apache/flink/pull/5198 ---

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

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

[jira] [Created] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods

2017-12-21 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8306: -- Summary: FlinkKafkaConsumerBaseTest has invalid mocks on final methods Key: FLINK-8306 URL: https://issues.apache.org/jira/browse/FLINK-8306 Project:

  1   2   >