[jira] [Created] (FLINK-11503) Remove invalid test TaskManagerLossFailsTasksTest

2019-01-31 Thread TisonKun (JIRA)
TisonKun created FLINK-11503: Summary: Remove invalid test TaskManagerLossFailsTasksTest Key: FLINK-11503 URL: https://issues.apache.org/jira/browse/FLINK-11503 Project: Flink Issue Type: Sub-tas

[GitHub] TisonKun opened a new pull request #7628: [FLINK-11503] Remove invalid test TaskManagerLossFailsTasksTest

2019-01-31 Thread GitBox
TisonKun opened a new pull request #7628: [FLINK-11503] Remove invalid test TaskManagerLossFailsTasksTest URL: https://github.com/apache/flink/pull/7628 ## What is the purpose of the change TaskManagerLossFailsTasksTest tests an instance fail would cause the execution graph failing.

[jira] [Updated] (FLINK-11503) Remove invalid test TaskManagerLossFailsTasksTest

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11503: --- Labels: pull-request-available (was: ) > Remove invalid test TaskManagerLossFailsTasksTest

[jira] [Created] (FLINK-11504) Remove invalid test JobManagerConnectionTest

2019-01-31 Thread TisonKun (JIRA)
TisonKun created FLINK-11504: Summary: Remove invalid test JobManagerConnectionTest Key: FLINK-11504 URL: https://issues.apache.org/jira/browse/FLINK-11504 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11505) Remove invalid test JobManagerRegistrationTest

2019-01-31 Thread TisonKun (JIRA)
TisonKun created FLINK-11505: Summary: Remove invalid test JobManagerRegistrationTest Key: FLINK-11505 URL: https://issues.apache.org/jira/browse/FLINK-11505 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-11505) Remove invalid test JobManagerRegistrationTest

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11505: --- Labels: pull-request-available (was: ) > Remove invalid test JobManagerRegistrationTest > -

[GitHub] lincoln-lil commented on issue #7583: Blink init

2019-01-31 Thread GitBox
lincoln-lil commented on issue #7583: Blink init URL: https://github.com/apache/flink/pull/7583#issuecomment-459611450 hi, liukaiyi the `org.apache.flink.sql.parser.impl.FlinkSqlParserImpl` is a generated class, you can run maven local install before testing (testing the extende

[GitHub] TisonKun opened a new pull request #7629: [FLINK-11504] Remove invalid test JobManagerConnectionTest

2019-01-31 Thread GitBox
TisonKun opened a new pull request #7629: [FLINK-11504] Remove invalid test JobManagerConnectionTest URL: https://github.com/apache/flink/pull/7629 ## What is the purpose of the change This test tests really legacy classes. We now have rpc abstractions and their own tests. ##

[jira] [Updated] (FLINK-11504) Remove invalid test JobManagerConnectionTest

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11504: --- Labels: pull-request-available (was: ) > Remove invalid test JobManagerConnectionTest > ---

[GitHub] TisonKun opened a new pull request #7630: [FLINK-11505] Remove invalid test JobManagerRegistrationTest

2019-01-31 Thread GitBox
TisonKun opened a new pull request #7630: [FLINK-11505] Remove invalid test JobManagerRegistrationTest URL: https://github.com/apache/flink/pull/7630 ## What is the purpose of the change A TaskExecutor is now registered in ResourceManager and we have ResourceManagerTaskExecutorTest

[jira] [Assigned] (FLINK-11362) Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary

2019-01-31 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-11362: Assignee: TisonKun > Check and port TaskManagerComponentsStartupShutdownTest to new code base if

[GitHub] zhijiangW opened a new pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

2019-01-31 Thread GitBox
zhijiangW opened a new pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631 ## What is the purpose of the change *This is a sub task for introducing `ShuffleMaster` component on

[jira] [Updated] (FLINK-11391) Introduce ShuffleMaster in Job Master

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11391: --- Labels: pull-request-available (was: ) > Introduce ShuffleMaster in Job Master > --

[GitHub] TisonKun opened a new pull request #7632: [FLINK-11362] Port TaskManagerComponentsStartupShutdownTest to new co…

2019-01-31 Thread GitBox
TisonKun opened a new pull request #7632: [FLINK-11362] Port TaskManagerComponentsStartupShutdownTest to new co… URL: https://github.com/apache/flink/pull/7632 ## What is the purpose of the change Port TaskManagerComponentsStartupShutdownTest to TaskExecutorTest#testTaskManagerServi

[jira] [Updated] (FLINK-11362) Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11362: --- Labels: pull-request-available (was: ) > Check and port TaskManagerComponentsStartupShutdow

[jira] [Commented] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-01-31 Thread Yang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758024#comment-16758024 ] Yang Wang commented on FLINK-11484: --- [~pijing] You do not need 200 slots because the s

[jira] [Created] (FLINK-11506) 通过sql-client.sh登录后,执行sql语句报IO异常,然后客户端中断退出

2019-01-31 Thread Chen Zun (JIRA)
Chen Zun created FLINK-11506: Summary: 通过sql-client.sh登录后,执行sql语句报IO异常,然后客户端中断退出 Key: FLINK-11506 URL: https://issues.apache.org/jira/browse/FLINK-11506 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-11506) 通过sql-client.sh登录后,执行sql语句报IO异常,然后客户端中断退出

2019-01-31 Thread Chen Zun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Zun updated FLINK-11506: - Environment: windows7 cygwin64  java -version java version "1.8.0_101" Java(TM) SE Runtime Environment

[jira] [Updated] (FLINK-11506) 通过sql-client.sh登录后,执行sql语句报IO异常,然后客户端中断退出

2019-01-31 Thread Chen Zun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Zun updated FLINK-11506: - Description: {code:java} Exception in thread "main" org.apache.flink.table.client.SqlClientException: U

[jira] [Updated] (FLINK-11506) 通过sql-client.sh登录后,执行sql语句报IO异常,然后客户端中断退出

2019-01-31 Thread Chen Zun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Zun updated FLINK-11506: - Description: {code:java} 进入sql客户端之后,执行select * from TaixFares; Exception in thread "main" org.apache.fli

[jira] [Commented] (FLINK-11506) 通过sql-client.sh登录后,执行sql语句报IO异常,然后客户端中断退出

2019-01-31 Thread xueyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758030#comment-16758030 ] xueyu commented on FLINK-11506: --- Hi, [~chenzun], please update the issue title using Engli

[jira] [Created] (FLINK-11507) Remove invalid test JobClientActorTest

2019-01-31 Thread TisonKun (JIRA)
TisonKun created FLINK-11507: Summary: Remove invalid test JobClientActorTest Key: FLINK-11507 URL: https://issues.apache.org/jira/browse/FLINK-11507 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11508) Remove invalid test AkkaJobManagerRetrieverTest

2019-01-31 Thread TisonKun (JIRA)
TisonKun created FLINK-11508: Summary: Remove invalid test AkkaJobManagerRetrieverTest Key: FLINK-11508 URL: https://issues.apache.org/jira/browse/FLINK-11508 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11509) Remove invalid test ClientConnectionTest#testJobManagerRetrievalWithHAServices

2019-01-31 Thread TisonKun (JIRA)
TisonKun created FLINK-11509: Summary: Remove invalid test ClientConnectionTest#testJobManagerRetrievalWithHAServices Key: FLINK-11509 URL: https://issues.apache.org/jira/browse/FLINK-11509 Project: Flink

[jira] [Commented] (FLINK-11449) Uncouple the Expression class from RexNodes

2019-01-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758054#comment-16758054 ] Dawid Wysakowicz commented on FLINK-11449: -- Ad.1 Here, I agree I think they sho

[GitHub] tillrohrmann opened a new pull request #7614: [BP-1.7][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
tillrohrmann opened a new pull request #7614: [BP-1.7][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7614 Backport of #7606 for `release-1.7`. -

[GitHub] tillrohrmann opened a new pull request #7615: [BP-1.6][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
tillrohrmann opened a new pull request #7615: [BP-1.6][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7615 Backport of #7606 for `release-1.6`. -

[GitHub] wenhuitang opened a new pull request #7616: [hotfix][docs] Fix typo in windows.md.

2019-01-31 Thread GitBox
wenhuitang opened a new pull request #7616: [hotfix][docs] Fix typo in windows.md. URL: https://github.com/apache/flink/pull/7616 [hotfix][docs] Fix typo in windows.md. This is an automated message from the Apache Git Service

[jira] [Closed] (FLINK-11471) Job is reported RUNNING prematurely for queued scheduling

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11471. Resolution: Duplicate Assignee: (was: vinoyang) > Job is reported RUNNING premat

[jira] [Commented] (FLINK-11471) Job is reported RUNNING prematurely for queued scheduling

2019-01-31 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757022#comment-16757022 ] vinoyang commented on FLINK-11471: -- [~Zentol] What do you think about the solution to t

[GitHub] tzulitai commented on issue #7496: [FLINK-11323] Upgrade KryoSerializer snapshot to implement new TypeSerializerSnapshot interface

2019-01-31 Thread GitBox
tzulitai commented on issue #7496: [FLINK-11323] Upgrade KryoSerializer snapshot to implement new TypeSerializerSnapshot interface URL: https://github.com/apache/flink/pull/7496#issuecomment-459266478 FYI for other potential reviewers: We've decided to postpone moving forward with this P

[jira] [Commented] (FLINK-11429) Flink fails to authenticate s3a with core-site.xml

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757031#comment-16757031 ] Aljoscha Krettek commented on FLINK-11429: -- Thanks for keeping us posted! > Fl

[jira] [Commented] (FLINK-11472) KafkaITCase.testCancelingEmptyTopic failed on Travis

2019-01-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757032#comment-16757032 ] Dawid Wysakowicz commented on FLINK-11472: -- [~till.rohrmann] I guess this happe

[GitHub] twalthr commented on issue #7587: [FLINK-11064] [table] Setup a new flink-table module structure

2019-01-31 Thread GitBox
twalthr commented on issue #7587: [FLINK-11064] [table] Setup a new flink-table module structure URL: https://github.com/apache/flink/pull/7587#issuecomment-459267800 Thanks everyone. I will merge this now... This is an autom

[GitHub] tzulitai commented on issue #7612: [FLINK-11483][tests] Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized

2019-01-31 Thread GitBox
tzulitai commented on issue #7612: [FLINK-11483][tests] Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized URL: https://github.com/apache/flink/pull/7612#issuecomment-459268292 Thanks, fixed the ping. This i

[GitHub] dawidwys commented on a change in pull request #7608: FLINK-11473 [documentation][ Clarify documenation on Latency Tracking

2019-01-31 Thread GitBox
dawidwys commented on a change in pull request #7608: FLINK-11473 [documentation][ Clarify documenation on Latency Tracking URL: https://github.com/apache/flink/pull/7608#discussion_r252581663 ## File path: docs/monitoring/metrics.md ## @@ -1628,16 +1628,18 @@ bypassing th

[GitHub] tzulitai commented on a change in pull request #7612: [FLINK-11483][tests] Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized

2019-01-31 Thread GitBox
tzulitai commented on a change in pull request #7612: [FLINK-11483][tests] Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized URL: https://github.com/apache/flink/pull/7612#discussion_r252582271 ## File path: flink-tests/src/test/java/org/apache/flink/test/state/o

[GitHub] dawidwys closed pull request #7597: fix wrong format

2019-01-31 Thread GitBox
dawidwys closed pull request #7597: fix wrong format URL: https://github.com/apache/flink/pull/7597 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL abo

[GitHub] dawidwys closed pull request #7596: Release 1.7 sortPartition bug

2019-01-31 Thread GitBox
dawidwys closed pull request #7596: Release 1.7 sortPartition bug URL: https://github.com/apache/flink/pull/7596 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and us

[GitHub] dawidwys commented on issue #7596: Release 1.7 sortPartition bug

2019-01-31 Thread GitBox
dawidwys commented on issue #7596: Release 1.7 sortPartition bug URL: https://github.com/apache/flink/pull/7596#issuecomment-459269267 If you want to report a bug please use [JIRA](https://issues.apache.org/jira/projects/FLINK). -

[jira] [Closed] (FLINK-11429) Flink fails to authenticate s3a with core-site.xml

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11429. Resolution: Not A Problem > Flink fails to authenticate s3a with core-site.xml > -

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

2019-01-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757037#comment-16757037 ] Dawid Wysakowicz commented on FLINK-11445: -- Sounds good to me. > Deprecate sta

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

2019-01-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757035#comment-16757035 ] Hequn Cheng commented on FLINK-11445: - Hi [~twalthr] [~sunjincheng121], will impleme

[jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11484: -- Labels: blink (was: ) > Blink java.util.concurrent.TimeoutException > ---

[GitHub] asfgit closed pull request #7587: [FLINK-11064] [table] Setup a new flink-table module structure

2019-01-31 Thread GitBox
asfgit closed pull request #7587: [FLINK-11064] [table] Setup a new flink-table module structure URL: https://github.com/apache/flink/pull/7587 This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Closed] (FLINK-11064) Setup a new flink-table module structure

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11064. Resolution: Fixed Fix Version/s: 1.8.0 Fixed in 1.8.0: 0ab1549f52f1f544e8492757c6b0d562bf50

[jira] [Commented] (FLINK-11472) KafkaITCase.testCancelingEmptyTopic failed on Travis

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757041#comment-16757041 ] Till Rohrmann commented on FLINK-11472: --- Yes you are right [~dawidwys]. The failin

[jira] [Closed] (FLINK-11472) KafkaITCase.testCancelingEmptyTopic failed on Travis

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11472. - Resolution: Duplicate Fix Version/s: (was: 1.8.0) > KafkaITCase.testCancelingEmptyTop

[jira] [Updated] (FLINK-11395) Support for Avro StreamingFileSink

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11395: - Priority: Major (was: Blocker) > Support for Avro StreamingFileSink > -

[jira] [Updated] (FLINK-11440) ChainLengthIncreaseTest failed on Travis

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11440: - Issue Type: Bug (was: Test) > ChainLengthIncreaseTest failed on Travis > --

[jira] [Updated] (FLINK-11437) EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism caused CancellationException

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11437: -- Labels: test-stability (was: ) > EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWit

[jira] [Closed] (FLINK-11440) ChainLengthIncreaseTest failed on Travis

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11440. Resolution: Not A Problem I'm closing for now, since this might be a problem with the new

[jira] [Updated] (FLINK-11437) EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism caused CancellationException

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11437: -- Priority: Critical (was: Major) > EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWi

[GitHub] knaufk commented on a change in pull request #7608: FLINK-11473 [documentation][ Clarify documenation on Latency Tracking

2019-01-31 Thread GitBox
knaufk commented on a change in pull request #7608: FLINK-11473 [documentation][ Clarify documenation on Latency Tracking URL: https://github.com/apache/flink/pull/7608#discussion_r252587587 ## File path: docs/monitoring/metrics.md ## @@ -1628,16 +1628,18 @@ bypassing them

[jira] [Updated] (FLINK-11437) EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism caused CancellationException

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11437: - Issue Type: Bug (was: Test) > EventTimeWindowCheckpointingITCase#testTumblingTimeWindow

[GitHub] kl0u commented on issue #7588: [FLINK-11419][filesystem] For recovery, wait until lease is revoked before truncate file

2019-01-31 Thread GitBox
kl0u commented on issue #7588: [FLINK-11419][filesystem] For recovery, wait until lease is revoked before truncate file URL: https://github.com/apache/flink/pull/7588#issuecomment-459275009 Hi @EAlexRojas, I will have a look on this PR today. ---

[jira] [Updated] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11428: -- Priority: Critical (was: Major) > BufferFileWriterFileSegmentReaderTest#testWriteRead failed

[jira] [Updated] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11428: -- Issue Type: Bug (was: Test) > BufferFileWriterFileSegmentReaderTest#testWriteRead failed on T

[jira] [Updated] (FLINK-11437) EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism caused CancellationException

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11437: -- Fix Version/s: 1.8.0 > EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMax

[jira] [Closed] (FLINK-11435) Different jobs same consumer group are treated as separate groups

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11435. Resolution: Not A Problem As [~elevy] mentioned, this is a core design decision of the Fli

[jira] [Closed] (FLINK-11437) EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism caused CancellationException

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11437. Resolution: Not A Problem Fix Version/s: (was: 1.8.0) I think this might also b

[jira] [Reopened] (FLINK-11064) Setup a new flink-table module structure

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-11064: -- > Setup a new flink-table module structure > > >

[jira] [Updated] (FLINK-11426) Kafka09ProducerITCase test case failed while starting KafkaCluster

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11426: -- Fix Version/s: 1.8.0 > Kafka09ProducerITCase test case failed while starting KafkaCluster > --

[jira] [Updated] (FLINK-11426) Kafka09ProducerITCase test case failed while starting KafkaCluster

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11426: -- Labels: test-stability (was: ) > Kafka09ProducerITCase test case failed while starting KafkaC

[jira] [Updated] (FLINK-11426) Kafka09ProducerITCase test case failed while starting KafkaCluster

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11426: -- Issue Type: Bug (was: Test) > Kafka09ProducerITCase test case failed while starting KafkaClus

[jira] [Updated] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11428: -- Labels: test-stability (was: ) > BufferFileWriterFileSegmentReaderTest#testWriteRead failed o

[jira] [Updated] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBoundsException

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11420: - Priority: Critical (was: Major) > Serialization of case classes containing a Map[String

[jira] [Updated] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBoundsException

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11420: - Fix Version/s: 1.8.0 > Serialization of case classes containing a Map[String, Any] somet

[jira] [Closed] (FLINK-11064) Setup a new flink-table module structure

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11064. Resolution: Fixed Release Note: Users that had a `flink-table` dependency before need to upd

[jira] [Resolved] (FLINK-11423) Propagate the error message from Main method to JarRunHandler

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11423. --- Resolution: Fixed Fix Version/s: 1.8.0 Fixed via b721ac7ed687500c48a862d6d9ce3ee23f8b

[GitHub] asfgit closed pull request #7573: [FLINK-11423] Propagate the error message from Main method to JarRunHandler

2019-01-31 Thread GitBox
asfgit closed pull request #7573: [FLINK-11423] Propagate the error message from Main method to JarRunHandler URL: https://github.com/apache/flink/pull/7573 This is an automated message from the Apache Git Service. To respon

[jira] [Updated] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11419: - Priority: Blocker (was: Major) > StreamingFileSink fails to recover after taskmanager f

[jira] [Updated] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11419: - Fix Version/s: 1.8.0 > StreamingFileSink fails to recover after taskmanager failure > --

[jira] [Updated] (FLINK-11426) Kafka09ProducerITCase test case failed while starting KafkaCluster

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11426: -- Priority: Critical (was: Major) > Kafka09ProducerITCase test case failed while starting Kafka

[jira] [Updated] (FLINK-11426) Kafka09ProducerITCase test case failed while starting KafkaCluster

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11426: -- Summary: Kafka09ProducerITCase test case failed while starting KafkaCluster (was: FlinkKafkaP

[jira] [Assigned] (FLINK-11334) Migrate enum serializers to use new serialization compatibility abstractions

2019-01-31 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11334: --- Assignee: boshu Zheng > Migrate enum serializers to use new serialization compatibility abs

[GitHub] zentol merged pull request #7616: [hotfix][docs] Fix typo in windows.md.

2019-01-31 Thread GitBox
zentol merged pull request #7616: [hotfix][docs] Fix typo in windows.md. URL: https://github.com/apache/flink/pull/7616 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub

[jira] [Commented] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces

2019-01-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757063#comment-16757063 ] Aljoscha Krettek commented on FLINK-11409: -- One reason for them being abstract

[jira] [Updated] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11428: -- Fix Version/s: 1.8.0 > BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis >

[GitHub] kl0u commented on issue #7588: [FLINK-11419][filesystem] For recovery, wait until lease is revoked before truncate file

2019-01-31 Thread GitBox
kl0u commented on issue #7588: [FLINK-11419][filesystem] For recovery, wait until lease is revoked before truncate file URL: https://github.com/apache/flink/pull/7588#issuecomment-459280946 By the way, try to rebase on the master and relaunch the build on Travis. I will do the same, but if

[jira] [Created] (FLINK-11486) Remove RecoveryITCase for jobmanager

2019-01-31 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-11486: --- Summary: Remove RecoveryITCase for jobmanager Key: FLINK-11486 URL: https://issues.apache.org/jira/browse/FLINK-11486 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-11364) Check and port TaskManagerFailsITCase to new code base if necessary

2019-01-31 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-11364: --- Assignee: Shimin Yang > Check and port TaskManagerFailsITCase to new code base if necessary

[GitHub] klion26 commented on a change in pull request #7612: [FLINK-11483][tests] Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized

2019-01-31 Thread GitBox
klion26 commented on a change in pull request #7612: [FLINK-11483][tests] Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized URL: https://github.com/apache/flink/pull/7612#discussion_r252599373 ## File path: flink-tests/src/test/java/org/apache/flink/test/state/op

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252587487 ## File path: flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252590091 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFu

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252586905 ## File path: flink-libraries/flink-table/src/main/java/org/apache/calcite/tools/RelBuilder.java ##

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252596804 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/batch/sql/SetOperato

[jira] [Commented] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

2019-01-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757095#comment-16757095 ] Hequn Cheng commented on FLINK-11447: - Hi all, thanks for the nice discussion! I wou

[jira] [Assigned] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11380: - Assignee: Till Rohrmann > YarnFlinkResourceManagerTest test case crashed > ---

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252587155 ## File path: flink-libraries/flink-table/pom.xml ## @@ -96,25 +96,12 @@ under the License.

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252602978 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/OverWin

[jira] [Commented] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757088#comment-16757088 ] Till Rohrmann commented on FLINK-11380: --- Another instance: https://api.travis-ci.o

[jira] [Commented] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces

2019-01-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757085#comment-16757085 ] Dawid Wysakowicz commented on FLINK-11409: -- I think the problem here is the des

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252595753 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/batch/sql/GroupWindo

[GitHub] twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
twalthr commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252593369 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TimeIndicato

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

2019-01-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757099#comment-16757099 ] Hequn Cheng commented on FLINK-11445: - [~dawidwys] Great to have your suggestions.(y

[jira] [Updated] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11380: --- Labels: pull-request-available test-stability (was: test-stability) > YarnFlinkResourceMana

[GitHub] tillrohrmann opened a new pull request #7617: [FLINK-11380][tests] Finish mocking of resourceManagerClient before using it

2019-01-31 Thread GitBox
tillrohrmann opened a new pull request #7617: [FLINK-11380][tests] Finish mocking of resourceManagerClient before using it URL: https://github.com/apache/flink/pull/7617 ## What is the purpose of the change The problem was that we started the ResourceManager before we finished the m

[jira] [Commented] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-01-31 Thread Yang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757108#comment-16757108 ] Yang Wang commented on FLINK-11484: --- [~pijing], thanks for your feedback. {code:java}

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757110#comment-16757110 ] Timo Walther commented on FLINK-11445: -- Thanks [~hequn8128]. We should also depreca

<    1   2   3   4   >