[jira] [Commented] (FLINK-10639) Fix java syntax error in document

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660154#comment-16660154 ] ASF GitHub Bot commented on FLINK-10639: asfgit closed pull request #6902: [FLINK-10639][docs]

[GitHub] asfgit closed pull request #6902: [FLINK-10639][docs] Fix java syntax error in document

2018-10-23 Thread GitBox
asfgit closed pull request #6902: [FLINK-10639][docs] Fix java syntax error in document URL: https://github.com/apache/flink/pull/6902 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a

[jira] [Closed] (FLINK-10639) Fix java syntax error in document

2018-10-23 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10639. --- Resolution: Fixed Fixed in master: 49d56c1d3da608325cc6a4c4796ae03ce305cb6a fixed in release-1.6:

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

2018-10-23 Thread GitBox
yanghua commented on issue #6807: [FLINK-10292] Generate JobGraph in StandaloneJobClusterEntrypoint only once URL: https://github.com/apache/flink/pull/6807#issuecomment-432118204 hi @tillrohrmann You know, we didn't remove the assertion when dealing with FLINK-10527. It caused the PR

[GitHub] yanghua commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor

2018-10-23 Thread GitBox
yanghua commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor URL: https://github.com/apache/flink/pull/6876#issuecomment-432118383 @tillrohrmann I have updated this PR, please review.

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660200#comment-16660200 ] ASF GitHub Bot commented on FLINK-9737: --- twalthr commented on a change in pull request #6897:

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660204#comment-16660204 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull request #6705:

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r227256594 ## File path:

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r227256749 ## File path:

[jira] [Commented] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660183#comment-16660183 ] ASF GitHub Bot commented on FLINK-10251: yanghua commented on issue #6876: [FLINK-10251] Handle

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

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660182#comment-16660182 ] ASF GitHub Bot commented on FLINK-10292: yanghua commented on issue #6807: [FLINK-10292]

[GitHub] twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files

2018-10-23 Thread GitBox
twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files URL: https://github.com/apache/flink/pull/6897#discussion_r227254032 ## File path: docs/dev/table/sqlClient.md ## @@ -503,7

[GitHub] TisonKun opened a new pull request #6903: [hotfix] [python] correct strict access

2018-10-23 Thread GitBox
TisonKun opened a new pull request #6903: [hotfix] [python] correct strict access URL: https://github.com/apache/flink/pull/6903 ## What is the purpose of the change `PythonPlanBinder#LOG` can/should be private. ## Verifying this change This change is a trivial rework

[GitHub] twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files

2018-10-23 Thread GitBox
twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files URL: https://github.com/apache/flink/pull/6897#discussion_r227255346 ## File path:

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660201#comment-16660201 ] ASF GitHub Bot commented on FLINK-9737: --- twalthr commented on a change in pull request #6897:

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660203#comment-16660203 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull request #6705:

[jira] [Commented] (FLINK-10637) Start MiniCluster with random REST port

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660218#comment-16660218 ] ASF GitHub Bot commented on FLINK-10637: tillrohrmann opened a new pull request #6904:

[GitHub] tillrohrmann opened a new pull request #6905: [BP-1.5][FLINK-10637] Start MiniCluster with random REST port

2018-10-23 Thread GitBox
tillrohrmann opened a new pull request #6905: [BP-1.5][FLINK-10637] Start MiniCluster with random REST port URL: https://github.com/apache/flink/pull/6905 ## What is the purpose of the change This commit starts the MiniCluster used in tests with a random REST port. This will fix

[GitHub] tillrohrmann opened a new pull request #6904: [FLINK-10637] Start MiniCluster with random REST port

2018-10-23 Thread GitBox
tillrohrmann opened a new pull request #6904: [FLINK-10637] Start MiniCluster with random REST port URL: https://github.com/apache/flink/pull/6904 ## What is the purpose of the change This commit starts the MiniCluster used in tests with a random REST port. This will fix the

[GitHub] pnowojski commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files

2018-10-23 Thread GitBox
pnowojski commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files URL: https://github.com/apache/flink/pull/6897#discussion_r227268384 ## File path: docs/dev/table/sqlClient.md ## @@ -503,7

[GitHub] pnowojski commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files

2018-10-23 Thread GitBox
pnowojski commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files URL: https://github.com/apache/flink/pull/6897#discussion_r227267053 ## File path: docs/dev/table/sqlClient.md ## @@ -503,7

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660228#comment-16660228 ] ASF GitHub Bot commented on FLINK-9737: --- pnowojski commented on a change in pull request #6897:

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660227#comment-16660227 ] ASF GitHub Bot commented on FLINK-9737: --- pnowojski commented on a change in pull request #6897:

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660226#comment-16660226 ] ASF GitHub Bot commented on FLINK-9737: --- pnowojski commented on a change in pull request #6897:

[GitHub] pnowojski commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files

2018-10-23 Thread GitBox
pnowojski commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files URL: https://github.com/apache/flink/pull/6897#discussion_r227267053 ## File path: docs/dev/table/sqlClient.md ## @@ -503,7

[GitHub] twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files

2018-10-23 Thread GitBox
twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files URL: https://github.com/apache/flink/pull/6897#discussion_r227270152 ## File path: docs/dev/table/sqlClient.md ## @@ -503,7

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660232#comment-16660232 ] ASF GitHub Bot commented on FLINK-9737: --- twalthr commented on a change in pull request #6897:

[jira] [Commented] (FLINK-10095) Change the serialisation order in TTL value wrapper

2018-10-23 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660258#comment-16660258 ] Andrey Zagrebin commented on FLINK-10095: - Hi [~aitozi], the options for timestamp positioning

[GitHub] beyond1920 opened a new pull request #6906: [Flink-6036][table]Let catalog support partition.

2018-10-23 Thread GitBox
beyond1920 opened a new pull request #6906: [Flink-6036][table]Let catalog support partition. URL: https://github.com/apache/flink/pull/6906 ## What is the purpose of the change This pull request supports partition in external catalog. ## Brief change log - * Introduces

[GitHub] NicoK closed pull request #6461: [FLINK-9975][hadoop] also shade Hadoop's io.netty dependency

2018-10-23 Thread GitBox
NicoK closed pull request #6461: [FLINK-9975][hadoop] also shade Hadoop's io.netty dependency URL: https://github.com/apache/flink/pull/6461 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[jira] [Commented] (FLINK-9975) Netty dependency of Hadoop >= 2.7 is not relocated

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660278#comment-16660278 ] ASF GitHub Bot commented on FLINK-9975: --- NicoK closed pull request #6461: [FLINK-9975][hadoop] also

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660282#comment-16660282 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull request #6705:

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r227286509 ## File path:

[jira] [Resolved] (FLINK-9975) Netty dependency of Hadoop >= 2.7 is not relocated

2018-10-23 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9975. Resolution: Fixed Release Note: We now also relocate Hadoop's Netty dependency from

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660283#comment-16660283 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull request #6705:

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r227287614 ## File path:

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r227286887 ## File path:

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660287#comment-16660287 ] ASF GitHub Bot commented on FLINK-9878: --- NicoK closed pull request #6838:

[GitHub] NicoK closed pull request #6838: [FLINK-9878][network][ssl] add more low-level ssl options

2018-10-23 Thread GitBox
NicoK closed pull request #6838: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6838 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660286#comment-16660286 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull request #6705:

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660304#comment-16660304 ] ASF GitHub Bot commented on FLINK-7811: --- aljoscha commented on issue #6894: [FLINK-7811] Add

[jira] [Created] (FLINK-10645) Update StatefulJobSavepointMigrationITCase for 1.6

2018-10-23 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10645: -- Summary: Update StatefulJobSavepointMigrationITCase for 1.6 Key: FLINK-10645 URL: https://issues.apache.org/jira/browse/FLINK-10645 Project: Flink Issue

[jira] [Assigned] (FLINK-10630) Update migration tests for Flink 1.6

2018-10-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10630: -- Assignee: Stefan Richter (was: vinoyang) > Update migration tests for Flink 1.6 >

[jira] [Commented] (FLINK-10637) Start MiniCluster with random REST port

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660361#comment-16660361 ] ASF GitHub Bot commented on FLINK-10637: tillrohrmann commented on a change in pull request

[jira] [Created] (FLINK-10649) Update FlinkKafkaConsumerBaseMigrationTest for 1.6

2018-10-23 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10649: -- Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.6 Key: FLINK-10649 URL: https://issues.apache.org/jira/browse/FLINK-10649 Project: Flink Issue

[jira] [Created] (FLINK-10650) Update BucketingSinkMigrationTest for 1.6

2018-10-23 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10650: -- Summary: Update BucketingSinkMigrationTest for 1.6 Key: FLINK-10650 URL: https://issues.apache.org/jira/browse/FLINK-10650 Project: Flink Issue Type:

[jira] [Created] (FLINK-10648) Update ContinuousFileProcessingMigrationTest for 1.6

2018-10-23 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10648: -- Summary: Update ContinuousFileProcessingMigrationTest for 1.6 Key: FLINK-10648 URL: https://issues.apache.org/jira/browse/FLINK-10648 Project: Flink

[GitHub] TisonKun commented on issue #6849: [FLINK-10555] [test] Port AkkaSslITCase to new code base

2018-10-23 Thread GitBox
TisonKun commented on issue #6849: [FLINK-10555] [test] Port AkkaSslITCase to new code base URL: https://github.com/apache/flink/pull/6849#issuecomment-432200466 ping @tillrohrmann :-) FYI travis fails on ``` Results : Tests in error:

[jira] [Commented] (FLINK-10555) Port AkkaSslITCase to new code base

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660434#comment-16660434 ] ASF GitHub Bot commented on FLINK-10555: TisonKun commented on issue #6849: [FLINK-10555] [test]

[jira] [Commented] (FLINK-10610) Port slot sharing cases to new codebase

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660432#comment-16660432 ] ASF GitHub Bot commented on FLINK-10610: TisonKun commented on issue #6883: [FLINK-10610]

[jira] [Commented] (FLINK-6036) Let catalog support partition

2018-10-23 Thread jingzhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660447#comment-16660447 ] jingzhang commented on FLINK-6036: -- Hi, [~xuefuz], I just submit a pr:

[GitHub] zentol commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-23 Thread GitBox
zentol commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r227351375 ## File path: docs/dev/connectors/kafka.md ## @@ -100,6 +108,30 @@

[jira] [Created] (FLINK-10654) AllowNonRestoredState should skip state that cannot be restored

2018-10-23 Thread Jiayi Liao (JIRA)
Jiayi Liao created FLINK-10654: -- Summary: AllowNonRestoredState should skip state that cannot be restored Key: FLINK-10654 URL: https://issues.apache.org/jira/browse/FLINK-10654 Project: Flink

[jira] [Commented] (FLINK-10637) Start MiniCluster with random REST port

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660352#comment-16660352 ] ASF GitHub Bot commented on FLINK-10637: tillrohrmann commented on a change in pull request

[jira] [Assigned] (FLINK-10627) Extend test_streaming_file_sink to test S3 writer

2018-10-23 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10627: --- Assignee: Andrey Zagrebin > Extend test_streaming_file_sink to test S3 writer >

[GitHub] NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#issuecomment-432180676 thanks again @zhijiangW - I updated the tests accordingly. Regarding performance: there may be

[GitHub] zentol commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-23 Thread GitBox
zentol commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r227351575 ## File path: docs/dev/connectors/kafka.md ## @@ -100,6 +108,30 @@

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660477#comment-16660477 ] ASF GitHub Bot commented on FLINK-10599: zentol commented on a change in pull request #6889:

[jira] [Commented] (FLINK-10637) Start MiniCluster with random REST port

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660538#comment-16660538 ] ASF GitHub Bot commented on FLINK-10637: tillrohrmann commented on issue #6899: [FLINK-10637]

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660371#comment-16660371 ] ASF GitHub Bot commented on FLINK-10356: NicoK commented on issue #6705: [FLINK-10356][network]

[GitHub] tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime

2018-10-23 Thread GitBox
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime URL: https://github.com/apache/flink/pull/6899#discussion_r227316017 ## File path:

[jira] [Closed] (FLINK-10630) Update migration tests for Flink 1.6

2018-10-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10630. -- Resolution: Duplicate > Update migration tests for Flink 1.6 >

[jira] [Commented] (FLINK-10637) Start MiniCluster with random REST port

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660372#comment-16660372 ] ASF GitHub Bot commented on FLINK-10637: tillrohrmann commented on a change in pull request

[jira] [Comment Edited] (FLINK-6036) Let catalog support partition

2018-10-23 Thread jingzhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660447#comment-16660447 ] jingzhang edited comment on FLINK-6036 at 10/23/18 11:12 AM: - Hi, [~xuefuz],

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660489#comment-16660489 ] ASF GitHub Bot commented on FLINK-10252: yanghua commented on issue #6850: [FLINK-10252] Handle

[GitHub] yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges

2018-10-23 Thread GitBox
yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#issuecomment-432215589 In fact, Travis has been built successfully. This is an automated message

[jira] [Updated] (FLINK-10425) taskmanager.host is not respected

2018-10-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10425: - Summary: taskmanager.host is not respected (was: taskmaster.host is not respected) > taskmanager.host

[GitHub] aljoscha commented on issue #6894: [FLINK-7811] Add support for Scala 2.12

2018-10-23 Thread GitBox
aljoscha commented on issue #6894: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6894#issuecomment-432160532 @zentol I think I addressed all your comments except the json, avro, and sql-client comments.

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660300#comment-16660300 ] Timo Walther commented on FLINK-9737: - Fixed in 1.7.0: 6c9193ff288919a7ac8dfdb5773b92d84f843a4c,

[GitHub] NicoK commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
NicoK commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r227307487 ## File path:

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660342#comment-16660342 ] ASF GitHub Bot commented on FLINK-10356: NicoK commented on a change in pull request #6705:

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660485#comment-16660485 ] ASF GitHub Bot commented on FLINK-10599: yanghua commented on issue #6889:

[GitHub] twalthr commented on issue #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files

2018-10-23 Thread GitBox
twalthr commented on issue #6897: [FLINK-9737] [FLINK-8880] [sql-client] Support defining temporal tables in environment files URL: https://github.com/apache/flink/pull/6897#issuecomment-432158343 Thanks for the feedback @dawidwys and @pnowojski. I addressed your comments and will merge

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660292#comment-16660292 ] ASF GitHub Bot commented on FLINK-7811: --- aljoscha commented on a change in pull request #6894:

[jira] [Commented] (FLINK-10637) Start MiniCluster with random REST port

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660335#comment-16660335 ] ASF GitHub Bot commented on FLINK-10637: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime

2018-10-23 Thread GitBox
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime URL: https://github.com/apache/flink/pull/6899#discussion_r227308881 ## File path:

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660295#comment-16660295 ] ASF GitHub Bot commented on FLINK-7811: --- aljoscha commented on a change in pull request #6894:

[jira] [Commented] (FLINK-10601) Make user home dir consistent with Flink default filesystem

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660294#comment-16660294 ] ASF GitHub Bot commented on FLINK-10601: link3280 commented on issue #6887: [FLINK-10601] [YARN]

[GitHub] aljoscha commented on a change in pull request #6894: [FLINK-7811] Add support for Scala 2.12

2018-10-23 Thread GitBox
aljoscha commented on a change in pull request #6894: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6894#discussion_r227290801 ## File path: pom.xml ## @@ -613,6 +619,61 @@ under the License. + +

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660296#comment-16660296 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull request #6705:

[GitHub] tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime

2018-10-23 Thread GitBox
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime URL: https://github.com/apache/flink/pull/6899#discussion_r227303857 ## File path:

[jira] [Commented] (FLINK-10637) Start MiniCluster with random REST port

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660332#comment-16660332 ] ASF GitHub Bot commented on FLINK-10637: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime

2018-10-23 Thread GitBox
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime URL: https://github.com/apache/flink/pull/6899#discussion_r227303748 ## File path:

[jira] [Created] (FLINK-10651) Update CEPMigrationTest for 1.6

2018-10-23 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10651: -- Summary: Update CEPMigrationTest for 1.6 Key: FLINK-10651 URL: https://issues.apache.org/jira/browse/FLINK-10651 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10652) Update StatefulJobWBroadcastStateMigrationITCase for 1.6

2018-10-23 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10652: -- Summary: Update StatefulJobWBroadcastStateMigrationITCase for 1.6 Key: FLINK-10652 URL: https://issues.apache.org/jira/browse/FLINK-10652 Project: Flink

[jira] [Updated] (FLINK-10653) Propose of external shuffle service for batch jobs

2018-10-23 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10653: - Description: The network shuffle behavior for batch jobs in Flink can be improved in two dimensions:  

[GitHub] yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-23 Thread GitBox
yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#issuecomment-432206118 Hi @eliaslevy Thank you for reviewing it, I have adopted most of your suggestions.

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660451#comment-16660451 ] ASF GitHub Bot commented on FLINK-10599: yanghua commented on issue #6889:

[GitHub] tillrohrmann commented on issue #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime

2018-10-23 Thread GitBox
tillrohrmann commented on issue #6899: [FLINK-10637] Use MiniClusterResource for tests in flink-runtime URL: https://github.com/apache/flink/pull/6899#issuecomment-432220862 Thanks for the review @zentol. I've addressed all your comments.

[GitHub] pnowojski closed pull request #6891: [FLINK-10606][network][test] Construct NetworkEnvironment simple for tests

2018-10-23 Thread GitBox
pnowojski closed pull request #6891: [FLINK-10606][network][test] Construct NetworkEnvironment simple for tests URL: https://github.com/apache/flink/pull/6891 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Commented] (FLINK-10606) Construct NetworkEnvironment simple for tests

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660639#comment-16660639 ] ASF GitHub Bot commented on FLINK-10606: pnowojski closed pull request #6891:

[GitHub] link3280 commented on issue #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem

2018-10-23 Thread GitBox
link3280 commented on issue #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem URL: https://github.com/apache/flink/pull/6887#issuecomment-432158551 @StefanRRichter would you please have a look at this PR? Should be a quick one. Thanks!

[GitHub] aljoscha commented on a change in pull request #6894: [FLINK-7811] Add support for Scala 2.12

2018-10-23 Thread GitBox
aljoscha commented on a change in pull request #6894: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6894#discussion_r227290425 ## File path: tools/releasing/deploy_staging_jars.sh ## @@ -41,5 +41,10 @@ cd .. echo "Deploying to

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-23 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r227290793 ## File path:

[jira] [Resolved] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-9737. - Resolution: Fixed Fix Version/s: 1.7.0 > Allow to define Table Version Functions from SQL

[jira] [Updated] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9737: Affects Version/s: (was: 1.7.0) > Allow to define Table Version Functions from SQL environment

[jira] [Updated] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9737: Affects Version/s: 1.7.0 > Allow to define Table Version Functions from SQL environment file >

[GitHub] yanghua commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor

2018-10-23 Thread GitBox
yanghua commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor URL: https://github.com/apache/flink/pull/6876#issuecomment-432206417 @zentol Any suggestion? This is an automated message

[jira] [Commented] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660454#comment-16660454 ] ASF GitHub Bot commented on FLINK-10251: yanghua commented on issue #6876: [FLINK-10251] Handle

[GitHub] yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-23 Thread GitBox
yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#issuecomment-432214452 @zentol updated. This is an automated

  1   2   3   >