[GitHub] [flink] flinkbot edited a comment on pull request #12600: [FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

flinkbot edited a comment on pull request #12600: URL: https://github.com/apache/flink/pull/12600#issuecomment-642557137 ## CI report: * b30ed347f6232e005ed27a039cd18408dad8a5a4 UNKNOWN * 160d7fc0995727aa03ac83231424513020b4dcf6 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

flinkbot edited a comment on pull request #12537: URL: https://github.com/apache/flink/pull/12537#issuecomment-641007085 ## CI report: * 7ff56f02d52ad06686ff3ef1cb3b1b00791c217e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * cd3fc98c034fdc61235d9109c05b4f55d7423746 UNKNOWN * d3f81cb67e5924bfc9d3e7bbba25af281e6b3102 Azure:

[GitHub] [flink] rmetzger commented on pull request #12562: [FLINK-18160][scripts] Do not log about HADOOP_CONF_DIR if HADOOP_CLA…

rmetzger commented on pull request #12562: URL: https://github.com/apache/flink/pull/12562#issuecomment-642565207 Thank you for your review! This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #12442: [FLINK-12428][docs-zh] Translate the "Event Time" page into Chinese

flinkbot edited a comment on pull request #12442: URL: https://github.com/apache/flink/pull/12442#issuecomment-637524638 ## CI report: * e7daada8999ed5e3abf16a329fea3c4b45d16b11 Azure:

[jira] [Assigned] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18137: -- Assignee: Till Rohrmann (was: Robert Metzger) >

[jira] [Commented] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133143#comment-17133143 ] Robert Metzger commented on FLINK-18137: [~trohrmann] told me offline that he has found the

[jira] [Reopened] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-13553: This run has a quite a lot of DEBUG output:

[jira] [Commented] (FLINK-18247) Unstable test: TableITCase.testCollectWithClose:122 expected: but was:

[ https://issues.apache.org/jira/browse/FLINK-18247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133141#comment-17133141 ] Robert Metzger commented on FLINK-18247:

[GitHub] [flink-web] morsapaes edited a comment on pull request #349: [blog] Flink Community Update - June'20

morsapaes edited a comment on pull request #349: URL: https://github.com/apache/flink-web/pull/349#issuecomment-642561529 I refrained from repeating what had already been written about the release in the previous update, but plan to start including feature discussions moving forward.

[GitHub] [flink] flinkbot commented on pull request #12603: [1.11][FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

flinkbot commented on pull request #12603: URL: https://github.com/apache/flink/pull/12603#issuecomment-642561880 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #12602: [FLINK-18140][doc][orc] Add documentation for ORC format

flinkbot commented on pull request #12602: URL: https://github.com/apache/flink/pull/12602#issuecomment-642561113 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink-web] morsapaes commented on pull request #349: [blog] Flink Community Update - June'20

morsapaes commented on pull request #349: URL: https://github.com/apache/flink-web/pull/349#issuecomment-642561529 I refrained from repeating what had already been written about the release, but plan to start including feature discussions moving forward.

[GitHub] [flink] KurtYoung opened a new pull request #12603: [1.11][FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

KurtYoung opened a new pull request #12603: URL: https://github.com/apache/flink/pull/12603 ## What is the purpose of the change Since we don't have a good alternative solution for easily register user defined source/sink/factory, we need these methods back, for now.

[jira] [Updated] (FLINK-18140) Add documentation for ORC format

[ https://issues.apache.org/jira/browse/FLINK-18140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18140: --- Labels: pull-request-available (was: ) > Add documentation for ORC format >

[GitHub] [flink] JingsongLi opened a new pull request #12602: [FLINK-18140][doc][orc] Add documentation for ORC format

JingsongLi opened a new pull request #12602: URL: https://github.com/apache/flink/pull/12602 ## What is the purpose of the change Add documentation for ORC format for filesystem connector. ## Verifying this change

[GitHub] [flink] leonardBang commented on a change in pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

leonardBang commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r438660767 ## File path: docs/dev/table/common.zh.md ## @@ -828,18 +830,16 @@ Table API 和 SQL 查询会被翻译成 [DataStream]({{ site.baseurl }}/zh/dev/d 1. 优化逻辑执行计划 2.

[jira] [Commented] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133139#comment-17133139 ] Kurt Young commented on FLINK-16375: BTW, how about we only revert this in 1.11 branch? I don't see

[GitHub] [flink] aljoscha commented on a change in pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

aljoscha commented on a change in pull request #12589: URL: https://github.com/apache/flink/pull/12589#discussion_r438691884 ## File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java ## @@

[GitHub] [flink] aljoscha commented on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

aljoscha commented on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642559128 @becketqin I pushed changes, please take another look. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16375: --- Labels: pull-request-available (was: ) > Reintroduce registerTableSource/Sink methods for

[GitHub] [flink] flinkbot commented on pull request #12600: [FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

flinkbot commented on pull request #12600: URL: https://github.com/apache/flink/pull/12600#issuecomment-642557137 ## CI report: * b30ed347f6232e005ed27a039cd18408dad8a5a4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12599: [FLINK-18253][doc][avro] Add filesystem option documentation for Avro

flinkbot edited a comment on pull request #12599: URL: https://github.com/apache/flink/pull/12599#issuecomment-642546114 ## CI report: * 8b70cb96566c8e71418a49462ecda2a17b092fd2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

flinkbot edited a comment on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642078835 ## CI report: * d94219e43b9ec7087a1d87aae6cbef395fa9862c Azure:

[GitHub] [flink] flinkbot commented on pull request #12601: [FLINK-18241] Use correct user class loader in OptimizerPlaneEnvironment & StreamPlanEnvironment

flinkbot commented on pull request #12601: URL: https://github.com/apache/flink/pull/12601#issuecomment-642557238 ## CI report: * 306dc21418f239ff2e109e025c9e11db1a41bd6d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12442: [FLINK-12428][docs-zh] Translate the "Event Time" page into Chinese

flinkbot edited a comment on pull request #12442: URL: https://github.com/apache/flink/pull/12442#issuecomment-637524638 ## CI report: * e7daada8999ed5e3abf16a329fea3c4b45d16b11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

flinkbot edited a comment on pull request #12537: URL: https://github.com/apache/flink/pull/12537#issuecomment-641007085 ## CI report: * 7ff56f02d52ad06686ff3ef1cb3b1b00791c217e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12510: [FLINK-18039]

flinkbot edited a comment on pull request #12510: URL: https://github.com/apache/flink/pull/12510#issuecomment-640199489 ## CI report: * f0b2f727fb5a23b466328167cfce898829dc3e13 Azure:

[jira] [Commented] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133134#comment-17133134 ] Nico Kruber commented on FLINK-18242: - Thanks for the analysis - after changing to the new

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * cd3fc98c034fdc61235d9109c05b4f55d7423746 UNKNOWN * d3f81cb67e5924bfc9d3e7bbba25af281e6b3102 Azure:

[jira] [Commented] (FLINK-6757) Investigate Apache Atlas integration

[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133130#comment-17133130 ] Márton Balassi commented on FLINK-6757: --- I am happy to take this, in fact we have an implementation

[jira] [Assigned] (FLINK-6757) Investigate Apache Atlas integration

[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-6757: - Assignee: Márton Balassi > Investigate Apache Atlas integration >

[GitHub] [flink] flinkbot commented on pull request #12601: [FLINK-18241] Use correct user class loader in OptimizerPlaneEnvironment & StreamPlanEnvironment

flinkbot commented on pull request #12601: URL: https://github.com/apache/flink/pull/12601#issuecomment-642549922 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18241: --- Labels: pull-request-available (was: ) > Custom OptionsFactory in user code not working

[GitHub] [flink] flinkbot commented on pull request #12600: [FLINK-16376][table] Reintroduce registerTable[Source/Sink] methods for table env

flinkbot commented on pull request #12600: URL: https://github.com/apache/flink/pull/12600#issuecomment-642549107 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] dawidwys opened a new pull request #12601: [FLINK-18241] Use correct user class loader in OptimizerPlaneEnvironment & StreamPlanEnvironment

dawidwys opened a new pull request #12601: URL: https://github.com/apache/flink/pull/12601 ## What is the purpose of the change Use the user classloader when creating `StreamPlanEnvironment` and `OptimizerPlanEnvironment` ## Verifying this change Added test in

[jira] [Comment Edited] (FLINK-17977) Check log sanity

[ https://issues.apache.org/jira/browse/FLINK-17977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130620#comment-17130620 ] Robert Metzger edited comment on FLINK-17977 at 6/11/20, 10:07 AM: ---

[GitHub] [flink] KurtYoung opened a new pull request #12600: [FLINK-16376][table] Reintroduce registerTable[Source/Sink] methods for table env

KurtYoung opened a new pull request #12600: URL: https://github.com/apache/flink/pull/12600 ## What is the purpose of the change Since we don't have a good alternative solution for easily register user defined source/sink/factory, we need these methods back, for now.

[GitHub] [flink] flinkbot edited a comment on pull request #12597: [FLINK-18141][doc][parquet] Add documentation for Parquet format

flinkbot edited a comment on pull request #12597: URL: https://github.com/apache/flink/pull/12597#issuecomment-642529852 ## CI report: * 0310550dbaa4b060c3029e6e3f01308652d9faab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

flinkbot edited a comment on pull request #12537: URL: https://github.com/apache/flink/pull/12537#issuecomment-641007085 ## CI report: * 3ba10216ffe653c8e3fb0aa4d2e7278652471b1e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12598: [FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.

flinkbot edited a comment on pull request #12598: URL: https://github.com/apache/flink/pull/12598#issuecomment-642529967 ## CI report: * 3f78cec4c88d1b0e2f0bb11e003a0b2f3f48f969 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

flinkbot edited a comment on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642078835 ## CI report: * d94219e43b9ec7087a1d87aae6cbef395fa9862c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12510: [FLINK-18039]

flinkbot edited a comment on pull request #12510: URL: https://github.com/apache/flink/pull/12510#issuecomment-640199489 ## CI report: * f0b2f727fb5a23b466328167cfce898829dc3e13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12595: [FLINK-18247][table-planner-blink] Fix unstable test: TableITCase.testCollectWithClose

flinkbot edited a comment on pull request #12595: URL: https://github.com/apache/flink/pull/12595#issuecomment-642491750 ## CI report: * e32a32bc7e248905728924a976f35d3c21cb41cf UNKNOWN * c44353ad87a53a67c16d1bacd94e06c2b1d91d25 Azure:

[GitHub] [flink] flinkbot commented on pull request #12599: [FLINK-18253][doc][avro] Add filesystem option documentation for Avro

flinkbot commented on pull request #12599: URL: https://github.com/apache/flink/pull/12599#issuecomment-642546114 ## CI report: * 8b70cb96566c8e71418a49462ecda2a17b092fd2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * cd3fc98c034fdc61235d9109c05b4f55d7423746 UNKNOWN * d3f81cb67e5924bfc9d3e7bbba25af281e6b3102 Azure:

[GitHub] [flink] becketqin commented on a change in pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

becketqin commented on a change in pull request #12589: URL: https://github.com/apache/flink/pull/12589#discussion_r438671644 ## File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java ## @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

rkhachatryan commented on a change in pull request #12525: URL: https://github.com/apache/flink/pull/12525#discussion_r438652781 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -613,25 +614,31 @@ protected void

[GitHub] [flink] liyubin117 edited a comment on pull request #12442: [FLINK-12428][docs-zh] Translate the "Event Time" page into Chinese

liyubin117 edited a comment on pull request #12442: URL: https://github.com/apache/flink/pull/12442#issuecomment-642539549 > @liyubin117 thanks for your contribution. > The English version has been updated in

[GitHub] [flink] zhuzhurk commented on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-642539851 Thanks for the reviewing! @azagrebin Will squash the fix commits and rebase onto latest master for a final pass of CI.

[GitHub] [flink] liyubin117 commented on pull request #12442: [FLINK-12428][docs-zh] Translate the "Event Time" page into Chinese

liyubin117 commented on pull request #12442: URL: https://github.com/apache/flink/pull/12442#issuecomment-642539549 > @liyubin117 thanks for your contribution. > The English version has been updated in

[jira] [Updated] (FLINK-15950) Remove registration of TableSource/TableSink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15950: --- Description: This ticket would track the removal of direct TableSource/TableSink registration to

[jira] [Updated] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16375: --- Component/s: (was: Documentation) > Reintroduce registerTableSource/Sink methods for table env

[jira] [Assigned] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16375: -- Assignee: Kurt Young > Reintroduce registerTableSource/Sink methods for table env >

[GitHub] [flink] zhuzhurk commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438668891 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTrackerTest.java ## @@ -0,0 +1,224 @@ +/*

[jira] [Updated] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16375: --- Summary: Reintroduce registerTableSource/Sink methods for table env (was: Remove references to

[jira] [Comment Edited] (FLINK-17978) Test Hadoop dependency change

[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133104#comment-17133104 ] Yang Wang edited comment on FLINK-17978 at 6/11/20, 9:46 AM: - cc [~rmetzger] 

[jira] [Updated] (FLINK-15950) Remove registration of TableSource/TableSink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15950: --- Summary: Remove registration of TableSource/TableSink in ConnectTableDescriptor (was: Remove

[jira] [Commented] (FLINK-16375) Remove references to registerTableSource/Sink methods from documentation

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133108#comment-17133108 ] Kurt Young commented on FLINK-16375: I'm also ok for reintroduce them, dropping a method without

[jira] [Updated] (FLINK-17521) Remove `com.ibm.icu` dependency from table-common

[ https://issues.apache.org/jira/browse/FLINK-17521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17521: --- Parent: (was: FLINK-16361) Issue Type: Improvement (was: Sub-task) > Remove

[jira] [Commented] (FLINK-18021) [Umbrella] Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133106#comment-17133106 ] Kurt Young commented on FLINK-18021: Closing this since all planned tests are finished, thanks all!

[jira] [Closed] (FLINK-18021) [Umbrella] Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-18021. -- Resolution: Fixed > [Umbrella] Manually tests for 1.11 SQL features >

[jira] [Commented] (FLINK-18254) Add documentation for primary key syntax

[ https://issues.apache.org/jira/browse/FLINK-18254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133105#comment-17133105 ] Jark Wu commented on FLINK-18254: - cc [~danny0405] > Add documentation for primary key syntax >

[jira] [Created] (FLINK-18254) Add documentation for primary key syntax

Jark Wu created FLINK-18254: --- Summary: Add documentation for primary key syntax Key: FLINK-18254 URL: https://issues.apache.org/jira/browse/FLINK-18254 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-17105) FLIP-71: E2E view support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17105. -- Release Note: Support view operations in both table env and sql client, including: 1. create / drop

[GitHub] [flink] zhuzhurk commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438664517 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTrackerTest.java ## @@ -0,0 +1,224 @@ +/*

[jira] [Commented] (FLINK-17978) Test Hadoop dependency change

[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133104#comment-17133104 ] Yang Wang commented on FLINK-17978: --- cc [~rmetzger] could you have a look on this? Maybe we also need

[jira] [Updated] (FLINK-17105) FLIP-71: E2E view support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17105: --- Component/s: (was: Table SQL / Legacy Planner) > FLIP-71: E2E view support for Flink SQL >

[jira] [Commented] (FLINK-17424) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to download error

[ https://issues.apache.org/jira/browse/FLINK-17424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133100#comment-17133100 ] Aljoscha Krettek commented on FLINK-17424: -- Another failure (different ES version, though):

[jira] [Commented] (FLINK-17978) Test Hadoop dependency change

[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133097#comment-17133097 ] Jingsong Lee commented on FLINK-17978: -- In flink-orc, I think we should let flink-orc depends on 

[GitHub] [flink] zhuzhurk commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438660533 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImplTest.java ## @@ -0,0 +1,245 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #12599: [FLINK-18253][doc][avro] Add filesystem option documentation for Avro

flinkbot commented on pull request #12599: URL: https://github.com/apache/flink/pull/12599#issuecomment-642530880 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Assigned] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

[ https://issues.apache.org/jira/browse/FLINK-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18246: --- Assignee: Wei Zhong > PyFlink e2e fails with java version mismatch on JDK11 nightly build >

[jira] [Updated] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

[ https://issues.apache.org/jira/browse/FLINK-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18246: Fix Version/s: 1.12.0 > PyFlink e2e fails with java version mismatch on JDK11 nightly build >

[GitHub] [flink] flinkbot commented on pull request #12597: [FLINK-18141][doc][parquet] Add documentation for Parquet format

flinkbot commented on pull request #12597: URL: https://github.com/apache/flink/pull/12597#issuecomment-642529852 ## CI report: * 0310550dbaa4b060c3029e6e3f01308652d9faab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-18253) Add filesystem documentation for Avro

[ https://issues.apache.org/jira/browse/FLINK-18253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18253: --- Labels: pull-request-available (was: ) > Add filesystem documentation for Avro >

[GitHub] [flink] flinkbot commented on pull request #12598: [FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.

flinkbot commented on pull request #12598: URL: https://github.com/apache/flink/pull/12598#issuecomment-642529967 ## CI report: * 3f78cec4c88d1b0e2f0bb11e003a0b2f3f48f969 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12596: [FLINK-18250] Enrich OOM error messages with more details in ClusterEntrypoint

flinkbot edited a comment on pull request #12596: URL: https://github.com/apache/flink/pull/12596#issuecomment-642518065 ## CI report: * 561630ec0c557fd12b4c094ce5289008e6dfdeac Azure:

[jira] [Closed] (FLINK-18251) Cannot create index by time field？

[ https://issues.apache.org/jira/browse/FLINK-18251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-18251. -- Resolution: Duplicate > Cannot create index by time field？ > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #12482: [FLINK-17831][doc] Add documentation for the new Kafka connector

flinkbot edited a comment on pull request #12482: URL: https://github.com/apache/flink/pull/12482#issuecomment-638825868 ## CI report: * 8239743b2ef52522bcd5cc12b578baa864d12fde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

flinkbot edited a comment on pull request #12537: URL: https://github.com/apache/flink/pull/12537#issuecomment-641007085 ## CI report: * 3ba10216ffe653c8e3fb0aa4d2e7278652471b1e Azure:

[GitHub] [flink] JingsongLi opened a new pull request #12599: [FLINK-18253][doc][avro] Add filesystem option documentation for Avro

JingsongLi opened a new pull request #12599: URL: https://github.com/apache/flink/pull/12599 ## What is the purpose of the change Add filesystem option documentation for Avro ## Verifying this change

[GitHub] [flink] zhuzhurk commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438657256 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTracker.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #12598: [FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.

flinkbot commented on pull request #12598: URL: https://github.com/apache/flink/pull/12598#issuecomment-642526187 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #12597: [FLINK-18141][doc][parquet] Add documentation for Parquet format

flinkbot commented on pull request #12597: URL: https://github.com/apache/flink/pull/12597#issuecomment-642526206 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438647311 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImplTest.java ## @@ -0,0 +1,245 @@ +/* + *

[GitHub] [flink] WeiZhong94 opened a new pull request #12598: [FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.

WeiZhong94 opened a new pull request #12598: URL: https://github.com/apache/flink/pull/12598 ## What is the purpose of the change *This pull request disables PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.* ## Brief change log -

[jira] [Updated] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

[ https://issues.apache.org/jira/browse/FLINK-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18246: --- Labels: pull-request-available test-stability (was: test-stability) > PyFlink e2e fails

[jira] [Updated] (FLINK-18141) Add documentation for Parquet format

[ https://issues.apache.org/jira/browse/FLINK-18141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18141: --- Labels: pull-request-available (was: ) > Add documentation for Parquet format >

[GitHub] [flink] zhuzhurk commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438653169 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTracker.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] JingsongLi opened a new pull request #12597: [FLINK-18141][doc][parquet] Add documentation for Parquet format

JingsongLi opened a new pull request #12597: URL: https://github.com/apache/flink/pull/12597 ## What is the purpose of the change Add documentation for Parquet format for table file system connector. ## Verifying this change

[GitHub] [flink] zhuzhurk commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438652945 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,204 @@ +/* + * Licensed

[jira] [Updated] (FLINK-18253) Add filesystem documentation for Avro

[ https://issues.apache.org/jira/browse/FLINK-18253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18253: - Description: We should add avro.codec documentation to avro page. > Add filesystem

[jira] [Commented] (FLINK-17978) Test Hadoop dependency change

[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133080#comment-17133080 ] Yang Wang commented on FLINK-17978: --- [~trohrmann] Thanks for the explanation. When i am testing the

[jira] [Closed] (FLINK-17832) Add documentation for the new Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-17832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17832. --- Resolution: Fixed - master (1.12.0): 21067b38fa2b9f97ed419586dda78841336dfd92 - 1.11.0:

[jira] [Commented] (FLINK-18249) Cannot create index by time field？

[ https://issues.apache.org/jira/browse/FLINK-18249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133078#comment-17133078 ] Yangze Guo commented on FLINK-18249: Hi. I think this feature is for ESTableSink instead of

[jira] [Commented] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

[ https://issues.apache.org/jira/browse/FLINK-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133076#comment-17133076 ] Wei Zhong commented on FLINK-18246: --- Hi [~rmetzger]. The cause of the test failure is that the docker

[jira] [Created] (FLINK-18253) Add filesystem documentation for Avro

Jingsong Lee created FLINK-18253: Summary: Add filesystem documentation for Avro Key: FLINK-18253 URL: https://issues.apache.org/jira/browse/FLINK-18253 Project: Flink Issue Type: Sub-task

[GitHub] [flink-web] morsapaes commented on a change in pull request #349: [blog] Flink Community Update - June'20

morsapaes commented on a change in pull request #349: URL: https://github.com/apache/flink-web/pull/349#discussion_r438648924 ## File path: _posts/2020-06-10-community-update.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink Community Update - June'20" +date:

[GitHub] [flink-web] morsapaes commented on a change in pull request #349: [blog] Flink Community Update - June'20

morsapaes commented on a change in pull request #349: URL: https://github.com/apache/flink-web/pull/349#discussion_r438648924 ## File path: _posts/2020-06-10-community-update.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink Community Update - June'20" +date:

<    1   2   3   4   5   6   7   8   >