[jira] [Closed] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects

2019-01-31 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-10698. Resolution: Duplicate > Create CatalogManager class manages all external catalogs and temporary meta >

[GitHub] zentol merged pull request #7535: [FLINK-11382] Disable MetricFetcher if interval is configured to 0 an…

2019-01-31 Thread GitBox
zentol merged pull request #7535: [FLINK-11382] Disable MetricFetcher if interval is configured to 0 an… URL: https://github.com/apache/flink/pull/7535 This is an automated message from the Apache Git Service. To respond to

[GitHub] jgrier commented on issue #7625: Backport [FLINK-10887] Add JobMaster RPC endpoint that is used to share information across source subtasks.

2019-01-31 Thread GitBox
jgrier commented on issue #7625: Backport [FLINK-10887] Add JobMaster RPC endpoint that is used to share information across source subtasks. URL: https://github.com/apache/flink/pull/7625#issuecomment-459500385 Mistake. This

[GitHub] jgrier closed pull request #7625: Backport [FLINK-10887] Add JobMaster RPC endpoint that is used to share information across source subtasks.

2019-01-31 Thread GitBox
jgrier closed pull request #7625: Backport [FLINK-10887] Add JobMaster RPC endpoint that is used to share information across source subtasks. URL: https://github.com/apache/flink/pull/7625 This is an automated message from

[GitHub] stevenzwu commented on issue #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
stevenzwu commented on issue #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7606#issuecomment-459455146 @tillrohrmann sorry for a late question. you mentioned `This implies that all users of this

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

2019-01-31 Thread GitBox
walterddr 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_r252765823 ## File path:

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

2019-01-31 Thread GitBox
walterddr 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_r252766675 ## File path:

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

2019-01-31 Thread GitBox
walterddr 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_r252766737 ## File path:

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

2019-01-31 Thread GitBox
bowenli86 commented on issue #7587: [FLINK-11064] [table] Setup a new flink-table module structure URL: https://github.com/apache/flink/pull/7587#issuecomment-459476927 nice work! This is an automated message from the Apache

[jira] [Created] (FLINK-11500) 1.8

2019-01-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11500: Summary: 1.8 Key: FLINK-11500 URL: https://issues.apache.org/jira/browse/FLINK-11500 Project: Flink Issue Type: Bug Reporter: Chesnay

[jira] [Updated] (FLINK-10887) Add source watermark tracking to the JobMaster

2019-01-31 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10887: - Fix Version/s: 1.8.0 > Add source watermark tracking to the JobMaster >

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

2019-01-31 Thread GitBox
walterddr 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_r252766531 ## File path: flink-libraries/flink-table/src/main/java/org/apache/calcite/tools/RelBuilder.java

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

2019-01-31 Thread GitBox
walterddr 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_r252780180 ## File path:

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

2019-01-31 Thread GitBox
walterddr 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_r252764493 ## File path: flink-libraries/flink-table/pom.xml ## @@ -96,25 +96,12 @@ under the License.

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

2019-01-31 Thread GitBox
walterddr 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_r252786140 ## File path:

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

2019-01-31 Thread GitBox
walterddr 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_r252764596 ## File path: flink-libraries/flink-table/pom.xml ## @@ -267,6 +250,8 @@ under the License.

[GitHub] bowenli86 edited a comment on issue #7587: [FLINK-11064] [table] Setup a new flink-table module structure

2019-01-31 Thread GitBox
bowenli86 edited a comment on issue #7587: [FLINK-11064] [table] Setup a new flink-table module structure URL: https://github.com/apache/flink/pull/7587#issuecomment-459476927 nice work! @twalthr This is an automated

[jira] [Closed] (FLINK-10768) Move external catalog related code from TableEnvironment to CatalogManager

2019-01-31 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-10768. Resolution: Duplicate > Move external catalog related code from TableEnvironment to CatalogManager >

[jira] [Closed] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

2019-01-31 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-10796. Resolution: Duplicate > Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager >

[GitHub] jgrier opened a new pull request #7625: Backport [FLINK-10887] Add JobMaster RPC endpoint that is used to share information across source subtasks.

2019-01-31 Thread GitBox
jgrier opened a new pull request #7625: Backport [FLINK-10887] Add JobMaster RPC endpoint that is used to share information across source subtasks. URL: https://github.com/apache/flink/pull/7625 Backporting this Flink PR to our Lyft internal branch:

[jira] [Commented] (FLINK-11382) Disable MetricFetcher if interval is configured to 0

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757702#comment-16757702 ] Chesnay Schepler commented on FLINK-11382: -- [~xleesf] Could you open a follow-up to update the

[jira] [Closed] (FLINK-10696) Add APIs to ExternalCatalog for views and UDFs

2019-01-31 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-10696. Resolution: Won't Fix Release Note: existing catalog API will be replaced, thus no need to modify

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

2019-01-31 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-11501: Description: There are instances when a Flink job that reads from Kafka can read at a

[GitHub] leesf commented on issue #7555: [FLINK-11373] CliFrontend cuts off reason for error messages

2019-01-31 Thread GitBox
leesf commented on issue #7555: [FLINK-11373] CliFrontend cuts off reason for error messages URL: https://github.com/apache/flink/pull/7555#issuecomment-459555295 cc @zentol @dawidwys This is an automated message from the

[GitHub] ambition119 commented on issue #7618: [FLINK-11487] Support for writing data to Apache Flume

2019-01-31 Thread GitBox
ambition119 commented on issue #7618: [FLINK-11487] Support for writing data to Apache Flume URL: https://github.com/apache/flink/pull/7618#issuecomment-459574423 @sjwiesman Thank you for your comment, let me know Apache Bahir. At first I thought that the code I wrote was not very good,

[GitHub] ambition119 closed pull request #7618: [FLINK-11487] Support for writing data to Apache Flume

2019-01-31 Thread GitBox
ambition119 closed pull request #7618: [FLINK-11487] Support for writing data to Apache Flume URL: https://github.com/apache/flink/pull/7618 This is an automated message from the Apache Git Service. To respond to the

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

2019-01-31 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757871#comment-16757871 ] pj commented on FLINK-11484: Thanks for your response. I notice that the all tasks in my job hang a long

[GitHub] leesf commented on issue #7536: [hotfix][docs] Remove redundant symbols

2019-01-31 Thread GitBox
leesf commented on issue #7536: [hotfix][docs] Remove redundant symbols URL: https://github.com/apache/flink/pull/7536#issuecomment-459555384 cc @zentol This is an automated message from the Apache Git Service. To respond to

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

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

[GitHub] tzulitai commented on issue #7601: [FLINK-11164] Check for sentinel values when creating new Kinesis ShardIterator

2019-01-31 Thread GitBox
tzulitai commented on issue #7601: [FLINK-11164] Check for sentinel values when creating new Kinesis ShardIterator URL: https://github.com/apache/flink/pull/7601#issuecomment-459578559 @aljoscha LGTM  This is an automated

[jira] [Closed] (FLINK-11487) Support for writing data to Apache Flume

2019-01-31 Thread ambition (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition closed FLINK-11487. Resolution: Fixed Release Note: [FLINK-4446] Remove Flume connector (now in Bahir) > Support for

[jira] [Assigned] (FLINK-11453) Support SliceStream with forwardable pane info

2019-01-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11453: - Assignee: Rong Rong > Support SliceStream with forwardable pane info >

[jira] [Assigned] (FLINK-11454) Support MergedStream operation

2019-01-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11454: - Assignee: Rong Rong > Support MergedStream operation > -- > >

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

2019-01-31 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-11501: Description: There are instances when a Flink job that reads from Kafka can read at a

[jira] [Created] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

2019-01-31 Thread Lakshmi Rao (JIRA)
Lakshmi Rao created FLINK-11501: --- Summary: Add a ratelimiting feature to the FlinkKafkaConsumer Key: FLINK-11501 URL: https://issues.apache.org/jira/browse/FLINK-11501 Project: Flink Issue

[jira] [Closed] (FLINK-11071) Dynamic proxy classes cannot be resolved when deserializing job graph

2019-01-31 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang closed FLINK-11071. -- > Dynamic proxy classes cannot be resolved when deserializing job graph >

[GitHub] jgrier closed pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

2019-01-31 Thread GitBox
jgrier closed pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099 This is an automated message from the Apache Git Service. To respond

[GitHub] jgrier opened a new pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

2019-01-31 Thread GitBox
jgrier opened a new pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099 ## What is the purpose of the change This commit adds a JobMaster RPC endpoint that is used to for global information

[jira] [Updated] (FLINK-11502) Remove invalid test FlinkActorTest

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

[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

[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

[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

[GitHub] dianfu opened a new pull request #7626: [FLINK-11450][table] Port and move TableSource and TableSink to flink-table-common

2019-01-31 Thread GitBox
dianfu opened a new pull request #7626: [FLINK-11450][table] Port and move TableSource and TableSink to flink-table-common URL: https://github.com/apache/flink/pull/7626 ## What is the purpose of the change *This pull request ported the following classes to flink-table-common:

[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:

[jira] [Commented] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

2019-01-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757923#comment-16757923 ] Hequn Cheng commented on FLINK-11451: - Hi, [~xueyu] I think [~twalthr]'s suggestion is good. I don't

[GitHub] TisonKun opened a new pull request #7627: [FLINK-11502] Remove invalid test FlinkActorTest

2019-01-31 Thread GitBox
TisonKun opened a new pull request #7627: [FLINK-11502] Remove invalid test FlinkActorTest URL: https://github.com/apache/flink/pull/7627 ## What is the purpose of the change `FlinkActorTest` test `FlinkActor` class, which is no longer used in FLIP-6 codebase. ## Brief

[jira] [Created] (FLINK-11502) Remove invalid test FlinkActorTest

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

[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=16758024#comment-16758024 ] Yang Wang commented on FLINK-11484: --- [~pijing] You do not need 200 slots because the slot sharing is

[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=16758054#comment-16758054 ] Dawid Wysakowicz commented on FLINK-11449: -- Ad.1 Here, I agree I think they should be in

[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

[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

[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] [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] [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

[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

[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:

[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

[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=16758030#comment-16758030 ] xueyu commented on FLINK-11506: --- Hi, [~chenzun], please update the issue title using English..Could you

[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:

[GitHub] liukaiyi commented on issue #7583: Blink init

2019-01-31 Thread GitBox
liukaiyi commented on issue #7583: Blink init URL: https://github.com/apache/flink/pull/7583#issuecomment-459601393 > @ajliualiyun @KurtYoung org.apache.flink.sql.parser.impl.FlinkSqlParserImpl is missing in blink branch I also have this problem. in blink branch

[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] [Updated] (FLINK-11450) Port and move TableSource and TableSink to flink-table-common

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

[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 >

[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

[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"

[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

[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]

[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

[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

[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:

[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=16757095#comment-16757095 ] Hequn Cheng commented on FLINK-11447: - Hi all, thanks for the nice discussion! I would like to share

[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=16757108#comment-16757108 ] Yang Wang commented on FLINK-11484: --- [~pijing], thanks for your feedback. {code:java} ./flink run -m

[jira] [Created] (FLINK-11487) Support for writing data to Apache Flume

2019-01-31 Thread ambition (JIRA)
ambition created FLINK-11487: Summary: Support for writing data to Apache Flume Key: FLINK-11487 URL: https://issues.apache.org/jira/browse/FLINK-11487 Project: Flink Issue Type: New Feature

[GitHub] asfgit merged pull request #7614: [BP-1.7][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
asfgit merged pull request #7614: [BP-1.7][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7614 This is an automated message from the

[GitHub] asfgit closed pull request #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
asfgit closed pull request #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7606 This is an automated message from the Apache Git

[jira] [Resolved] (FLINK-11412) Remove legacy MesosFlinkResourceManager

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

[jira] [Assigned] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10774: - Assignee: Till Rohrmann (was: Steven Zhen Wu) > connection leak when partition

[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

[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

[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 >

[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] [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) >

[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

[GitHub] asfgit merged pull request #7615: [BP-1.6][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
asfgit merged pull request #7615: [BP-1.6][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7615 This is an automated message from the

[jira] [Resolved] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

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

[jira] [Updated] (FLINK-11487) Support for writing data to Apache Flume

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11487: --- Labels: pull-request-available (was: ) > Support for writing data to Apache Flume >

[jira] [Commented] (FLINK-10569) Clean up uses of Scheduler and Instance in valid tests

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757136#comment-16757136 ] Chesnay Schepler commented on FLINK-10569: -- First batch: master:

[GitHub] mxm commented on issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTrigger

2019-01-31 Thread GitBox
mxm commented on issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTrigger URL: https://github.com/apache/flink/pull/2671#issuecomment-459312479 Thanks for writing down your findings! This is an automated

[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

[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 >

[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=16757035#comment-16757035 ] Hequn Cheng commented on FLINK-11445: - Hi [~twalthr] [~sunjincheng121], will implement this issue

[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=16757037#comment-16757037 ] Dawid Wysakowicz commented on FLINK-11445: -- Sounds good to me. > Deprecate static methods in

[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

  1   2   3   4   >