[GitHub] TisonKun opened a new pull request #6818: [hotfix] [tests] JobManager -> Dispatcher in DispatcherProcess

TisonKun opened a new pull request #6818: [hotfix] [tests] JobManager -> Dispatcher in DispatcherProcess URL: https://github.com/apache/flink/pull/6818 ## What is the purpose of the change Fix typo in `DispatcherProcess.java`. In fact I find it when trying to remove dependen

[jira] [Commented] (FLINK-10526) Hadoop FileSystem not initialized properly on Yarn

[ https://issues.apache.org/jira/browse/FLINK-10526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16646024#comment-16646024 ] Aljoscha Krettek commented on FLINK-10526: -- For posterity, this is the duplicat

[jira] [Commented] (FLINK-10426) Port TaskTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16646022#comment-16646022 ] ASF GitHub Bot commented on FLINK-10426: TisonKun commented on issue #6778: [FLI

[GitHub] TisonKun commented on issue #6778: [FLINK-10426] [tests] Port TaskTest to new code base

TisonKun commented on issue #6778: [FLINK-10426] [tests] Port TaskTest to new code base URL: https://github.com/apache/flink/pull/6778#issuecomment-428834204 After a rebase on #6729 and its followings, I think this pull request is ready to be reviewed. cc @tillrohrmann and @uce . -

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645998#comment-16645998 ] ASF GitHub Bot commented on FLINK-9697: --- aljoscha commented on issue #6703: [FLINK-

[GitHub] aljoscha commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

aljoscha commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#issuecomment-428828451 @yanghua According to the slf4j doc `Level` is only available since version `1.7.15` while Flink uses `1.7.7`: https://www.slf4j.org/api/

[jira] [Updated] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10527: - Issue Type: Sub-task (was: Bug) Parent: FLINK-10392 > Cleanup constant isNewMode in YarnTestBas

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645970#comment-16645970 ] ASF GitHub Bot commented on FLINK-10527: yanghua commented on issue #6816: [FLIN

[GitHub] yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase

yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase URL: https://github.com/apache/flink/pull/6816#issuecomment-428818907 I try to remove these test methods. This is an automated message

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645967#comment-16645967 ] ASF GitHub Bot commented on FLINK-10527: yanghua commented on issue #6816: [FLIN

[GitHub] yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase

yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase URL: https://github.com/apache/flink/pull/6816#issuecomment-428818387 @TisonKun it seems it is not been ignored, it causes my PR failed, see [here](https://travis-ci.org/apache/flink/jobs/439612829).

[jira] [Closed] (FLINK-7999) Variable Join Window Boundaries

[ https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-7999. -- Resolution: Won't Fix > Variable Join Window Boundaries > --- > >

[jira] [Commented] (FLINK-7999) Variable Join Window Boundaries

[ https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645931#comment-16645931 ] Hequn Cheng commented on FLINK-7999: I think [FLINK-8478|https://issues.apache.org/ji

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645927#comment-16645927 ] TisonKun commented on FLINK-10527: -- How about adding this issue as a subtask of FLINK-1

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645924#comment-16645924 ] ASF GitHub Bot commented on FLINK-10527: TisonKun commented on issue #6816: [FLI

[GitHub] TisonKun commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase

TisonKun commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase URL: https://github.com/apache/flink/pull/6816#issuecomment-428811431 @yanghua thanks for raising this thread! I think `YARNHighAvailabilityITCase`, `YARNSessionCapacitySchedulerITCase#testClientSt

[jira] [Updated] (FLINK-10298) Batch Job Failover Strategy

[ https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10298: --- Labels: pull-request-available (was: ) > Batch Job Failover Strategy >

[jira] [Commented] (FLINK-10298) Batch Job Failover Strategy

[ https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645920#comment-16645920 ] ASF GitHub Bot commented on FLINK-10298: isunjin opened a new pull request #6817

[GitHub] isunjin opened a new pull request #6817: [FLINK-10298] [JobManager] Batch Job Failover Strategy

isunjin opened a new pull request #6817: [FLINK-10298] [JobManager] Batch Job Failover Strategy URL: https://github.com/apache/flink/pull/6817 ## What is the purpose of the change The new failover strategy needs to consider handling failures according to different failure types. It

[jira] [Closed] (FLINK-5584) Support Sliding-count row-window on streaming sql

[ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-5584. -- Resolution: Duplicate > Support Sliding-count row-window on streaming sql > ---

[jira] [Commented] (FLINK-5584) Support Sliding-count row-window on streaming sql

[ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645907#comment-16645907 ] Hequn Cheng commented on FLINK-5584: I think this has been solved by [FLINK-4557|htt

[GitHub] yanghua commented on issue #6807: [FLINK-10292] Generate JobGraph in StandaloneJobClusterEntrypoint only once

yanghua commented on issue #6807: [FLINK-10292] Generate JobGraph in StandaloneJobClusterEntrypoint only once URL: https://github.com/apache/flink/pull/6807#issuecomment-428806504 @tillrohrmann This is very strange, why this PR change causes the yarn test to time out, and some applications

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645901#comment-16645901 ] ASF GitHub Bot commented on FLINK-10292: yanghua commented on issue #6807: [FLIN

[GitHub] yanghua opened a new pull request #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase

yanghua opened a new pull request #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase URL: https://github.com/apache/flink/pull/6816 ## What is the purpose of the change *This pull request cleanups constant isNewMode in YarnTestBase* ## Brief change log -

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645890#comment-16645890 ] ASF GitHub Bot commented on FLINK-10527: yanghua opened a new pull request #6816

[jira] [Updated] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10527: --- Labels: pull-request-available (was: ) > Cleanup constant isNewMode in YarnTestBase > -

[jira] [Closed] (FLINK-9200) SQL E2E test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-9200. -- Resolution: Duplicate > SQL E2E test failed on travis > - > >

[jira] [Comment Edited] (FLINK-9200) SQL E2E test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645879#comment-16645879 ] Hequn Cheng edited comment on FLINK-9200 at 10/11/18 3:02 AM: -

[jira] [Assigned] (FLINK-10220) StreamSQL E2E test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10220: --- Assignee: Hequn Cheng > StreamSQL E2E test fails on travis > --

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645881#comment-16645881 ] vinoyang commented on FLINK-10527: -- cc [~till.rohrmann] and [~Tison] > Cleanup constan

[jira] [Commented] (FLINK-9200) SQL E2E test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645879#comment-16645879 ] Hequn Cheng commented on FLINK-9200: Do we still have this problem? Should I close it

[jira] [Created] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

vinoyang created FLINK-10527: Summary: Cleanup constant isNewMode in YarnTestBase Key: FLINK-10527 URL: https://issues.apache.org/jira/browse/FLINK-10527 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-5077) testStreamTableSink fails unstable

[ https://issues.apache.org/jira/browse/FLINK-5077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-5077. -- Resolution: Won't Fix > testStreamTableSink fails unstable > -- > >

[jira] [Commented] (FLINK-5077) testStreamTableSink fails unstable

[ https://issues.apache.org/jira/browse/FLINK-5077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645872#comment-16645872 ] Hequn Cheng commented on FLINK-5077: I think we can close this issue now. I will clos

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645813#comment-16645813 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645811#comment-16645811 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645816#comment-16645816 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645814#comment-16645814 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645812#comment-16645812 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645815#comment-16645815 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224289531 ## File path: docs/dev/table/connect.md ## @@ -1108,8 +1127,15 @@ val sink: JDBCAppendTableSi

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224288252 ## File path: docs/dev/table/common.md ## @@ -540,22 +536,17 @@ result.insertInto("CsvSinkTab

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224288732 ## File path: docs/dev/table/common.md ## @@ -540,22 +536,17 @@ result.insertInto("CsvSinkTab

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224289837 ## File path: docs/dev/table/streaming.md ## @@ -516,7 +516,7 @@ Table result = ... TableSin

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224289223 ## File path: docs/dev/table/connect.md ## @@ -1047,30 +1047,42 @@ The sink only supports app

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224289776 ## File path: docs/dev/table/streaming.md ## @@ -540,7 +540,7 @@ val result: Table = ??? val

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645785#comment-16645785 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645781#comment-16645781 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645784#comment-16645784 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645786#comment-16645786 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645789#comment-16645789 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645787#comment-16645787 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645782#comment-16645782 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645788#comment-16645788 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645783#comment-16645783 ] ASF GitHub Bot commented on FLINK-10156: sunjincheng121 commented on a change in

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224282676 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/A

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224279958 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala #

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224282913 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/J

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224281405 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala #

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224276816 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/valid

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224276866 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/validation/TableSi

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224283829 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/T

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224281005 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala #

[GitHub] sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink()

sunjincheng121 commented on a change in pull request #6805: [FLINK-10156][table] Deprecate Table.writeToSink() URL: https://github.com/apache/flink/pull/6805#discussion_r224276845 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/valid

[jira] [Closed] (FLINK-10526) Hadoop FileSystem not initialized properly on Yarn

[ https://issues.apache.org/jira/browse/FLINK-10526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yan Yan closed FLINK-10526. --- Resolution: Duplicate > Hadoop FileSystem not initialized properly on Yarn > ---

[jira] [Created] (FLINK-10526) Hadoop FileSystem not initialized properly on Yarn

Yan Yan created FLINK-10526: --- Summary: Hadoop FileSystem not initialized properly on Yarn Key: FLINK-10526 URL: https://issues.apache.org/jira/browse/FLINK-10526 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645678#comment-16645678 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645670#comment-16645670 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645674#comment-16645674 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645673#comment-16645673 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645677#comment-16645677 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645665#comment-16645665 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645664#comment-16645664 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645666#comment-16645666 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645667#comment-16645667 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645668#comment-16645668 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645679#comment-16645679 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645661#comment-16645661 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645676#comment-16645676 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645669#comment-16645669 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645675#comment-16645675 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645654#comment-16645654 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645657#comment-16645657 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645662#comment-16645662 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645658#comment-16645658 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645660#comment-16645660 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645672#comment-16645672 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645659#comment-16645659 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645663#comment-16645663 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645671#comment-16645671 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645655#comment-16645655 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645656#comment-16645656 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on a change in pull requ

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224262756 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecor

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224255261 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecor

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224230977 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224255589 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecor

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224259148 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224252224 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecor

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224249073 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecor

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r224232330 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat

  1   2   3   4   >