[GitHub] flink pull request #5814: [FLINK-9045][REST] Add logging message for web UI ...

2018-04-04 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5814 [FLINK-9045][REST] Add logging message for web UI address ## What is the purpose of the change Adds a logging message explicitly saying on which address and port the web UI is listening on.

[jira] [Commented] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425531#comment-16425531 ] ASF GitHub Bot commented on FLINK-9128: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5812: [FLINK-9128] [flip6] Add support for scheduleRunAsync for...

2018-04-04 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5812 Travis passed. Merging. ---

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425524#comment-16425524 ] ASF GitHub Bot commented on FLINK-8704: --- Github user zentol closed the pull request at:

[GitHub] flink pull request #5695: [FLINK-8704][tests] Port PartialConsumerPipelinedR...

2018-04-04 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/5695 ---

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425522#comment-16425522 ] Chesnay Schepler commented on FLINK-8703: - Partially addressed in: master:

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425521#comment-16425521 ] Chesnay Schepler commented on FLINK-8704: - Partially addressed in: master:

[jira] [Updated] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8697: Fix Version/s: (was: 1.6.0) > Rename DummyFlinkKafkaConsumer in Kinesis tests >

[jira] [Closed] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8697. --- Resolution: Fixed > Rename DummyFlinkKafkaConsumer in Kinesis tests >

[jira] [Closed] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8771. --- Resolution: Fixed Fix Version/s: (was: 1.6.0) master:

[jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425519#comment-16425519 ] ASF GitHub Bot commented on FLINK-9113: --- Github user twalthr commented on the issue:

[jira] [Reopened] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8697: - > Rename DummyFlinkKafkaConsumer in Kinesis tests >

[GitHub] flink issue #5811: [FLINK-9113] [connectors] Fix flushing behavior of bucket...

2018-04-04 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5811 @kl0u do you have an idea why `BucketingSinkTest` is failing? It seems that the written data parts are always empty. ---

[jira] [Updated] (FLINK-8804) Bump flink-shaded-jackson dependency to 3.0

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8804: Summary: Bump flink-shaded-jackson dependency to 3.0 (was: Bump flink-shaded dependency to

[jira] [Closed] (FLINK-8804) Bump flink-shaded-jackson dependency to 3.0

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8804. --- Resolution: Fixed master: 1.5: d7b1257ce6b5c7a3d999acb69d5a6a5ff749425a > Bump

[jira] [Closed] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8697. --- Resolution: Fixed Fix Version/s: (was: 1.4.3) master:

[jira] [Closed] (FLINK-9104) Re-generate REST API documentation for FLIP-6

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9104. --- Resolution: Fixed master: 83fffdf3ab044ef770f9c97f8fa60b782a9e9f78 1.5:

[jira] [Closed] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8966. --- Resolution: Fixed master: f1a8dd0654030d6b4bd79732ef1d0f32c5f6820e 1.5:

[jira] [Closed] (FLINK-9069) Fix some double semicolons to single semicolons, and update checkstyle

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9069. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Closed] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8963. --- Resolution: Fixed master: 576ba1d79c0d6f4daf648bf51df6af0b94845e7d 1.5:

[jira] [Closed] (FLINK-9042) Port ResumeCheckpointManuallyITCase to flip6

2018-04-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9042. --- Resolution: Fixed master: 7c553ba45b44145ea09e4d9ccb0bdf64df7ee076 1.5:

[jira] [Commented] (FLINK-8980) End-to-end test: BucketingSink

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425450#comment-16425450 ] ASF GitHub Bot commented on FLINK-8980: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #5813: [FLINK-8980] [e2e] Add a BucketingSink end-to-end ...

2018-04-04 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5813 [FLINK-8980] [e2e] Add a BucketingSink end-to-end test ## What is the purpose of the change This PR adds a end-to-end test for the BucketingSink. The job contains stateful functions and

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-04 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r179123350 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheDirectoriesTest.java --- @@ -164,16 +165,13 @@ public void

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425439#comment-16425439 ] ASF GitHub Bot commented on FLINK-8620: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-9031) DataSet Job result changes when adding rebalance after union

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425437#comment-16425437 ] Fabian Hueske commented on FLINK-9031: -- Yes, that should be easy. The optimizer didn't change (much)

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425432#comment-16425432 ] Fabian Hueske commented on FLINK-6895: -- Thank you [~wind_ljy]! > Add STR_TO_DATE supported in SQL >

[jira] [Commented] (FLINK-9055) WebUI shows job as Running although not enough resources are available

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425422#comment-16425422 ] Fabian Hueske commented on FLINK-9055: -- Hi [~sihuazhou], thanks for taking care of this issue. No, I

[jira] [Commented] (FLINK-9069) Fix some double semicolons to single semicolons, and update checkstyle

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425409#comment-16425409 ] ASF GitHub Bot commented on FLINK-9069: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425419#comment-16425419 ] ASF GitHub Bot commented on FLINK-8771: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9104) Re-generate REST API documentation for FLIP-6

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425414#comment-16425414 ] ASF GitHub Bot commented on FLINK-9104: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9042) Port ResumeCheckpointManuallyITCase to flip6

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425408#comment-16425408 ] ASF GitHub Bot commented on FLINK-9042: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5763: [hotfix][tests] Hide output from config.sh

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5763 ---

[jira] [Commented] (FLINK-8804) Bump flink-shaded dependency to 3.0

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425417#comment-16425417 ] ASF GitHub Bot commented on FLINK-8804: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5702: [FLINK-8771] [Checkstyle/Scalastyle] [Build System...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5702 ---

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425412#comment-16425412 ] ASF GitHub Bot commented on FLINK-8703: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5766 ---

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425416#comment-16425416 ] ASF GitHub Bot commented on FLINK-8966: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425411#comment-16425411 ] ASF GitHub Bot commented on FLINK-8704: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425413#comment-16425413 ] ASF GitHub Bot commented on FLINK-8704: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5736: [FLINK-9042][tests] Port ResumeCheckpointManuallyI...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5736 ---

[GitHub] flink pull request #5797: [FLINK-9104][doc]Re-generate REST API documentatio...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5797 ---

[GitHub] flink pull request #5772: [FLINK-8963][tests] Port BigUserProgramJobSubmitIT...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5772 ---

[GitHub] flink pull request #5664: [FLINK-8703][tests] Port CancelingTestBase to Mini...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5664 ---

[jira] [Commented] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425415#comment-16425415 ] ASF GitHub Bot commented on FLINK-8697: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425410#comment-16425410 ] ASF GitHub Bot commented on FLINK-8963: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9108) invalid ProcessWindowFunction link in Document

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425418#comment-16425418 ] ASF GitHub Bot commented on FLINK-9108: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5596: [FLINK-8804][Build] Integrate flink-shaded 3.0

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5596 ---

[GitHub] flink pull request #5769: [FLINK-9069] Add checkstyle rule to detect multipl...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5769 ---

[GitHub] flink pull request #5809: [FLINK-8697] [Kinesis Connector] Rename DummyFlink...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5809 ---

[GitHub] flink pull request #5785: [FLINK-9108][docs] Fix invalid link

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5785 ---

[GitHub] flink pull request #5795: [hotfix] [docs] fix typos in Table API & SQL

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5795 ---

[GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5697 ---

[GitHub] flink pull request #5694: [FLINK-8704][tests] Port SlotCountExceedingParalle...

2018-04-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5694 ---

[jira] [Commented] (FLINK-9119) example code error in Concepts & Common API

2018-04-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425402#comment-16425402 ] vinoyang commented on FLINK-9119: - [~fhueske] Yes, I will. > example code error in Concepts & Common API

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425398#comment-16425398 ] ASF GitHub Bot commented on FLINK-8620: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425395#comment-16425395 ] ASF GitHub Bot commented on FLINK-8620: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-04 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r179116502 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -262,106 +216,120 @@ private static Thread

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-04 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r179116344 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheDirectoriesTest.java --- @@ -0,0 +1,182 @@ +/* + * Licensed to

[GitHub] flink issue #5787: Release 1.5

2018-04-04 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5787 @386587793 I guess this PR happened by accident. Please close it. Thank you. ---

[jira] [Commented] (FLINK-9068) Website documentation issue - html tag visible on screen

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425375#comment-16425375 ] Fabian Hueske commented on FLINK-9068: -- Hi [~shankarganesh1234], I gave you contributor permissions

[jira] [Assigned] (FLINK-9068) Website documentation issue - html tag visible on screen

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9068: Assignee: SHANKAR GANESH > Website documentation issue - html tag visible on screen >

[jira] [Updated] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9066: - Issue Type: New Feature (was: Improvement) > Add 'HOTSPOTS' function to Flink SQL >

[jira] [Commented] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425369#comment-16425369 ] Fabian Hueske commented on FLINK-9066: -- This definitely looks interesting! We'd have to check what

[jira] [Updated] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9066: - Priority: Minor (was: Major) > Add 'HOTSPOTS' function to Flink SQL >

[jira] [Commented] (FLINK-9119) example code error in Concepts & Common API

2018-04-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425352#comment-16425352 ] Fabian Hueske commented on FLINK-9119: -- Good catch [~chillon_m]! {{project(...)}}should be

[jira] [Closed] (FLINK-9129) Support nested KafkaJsonTableSource

2018-04-04 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9129. --- Resolution: Duplicate This issue has been fixed as part of FLINK-8630. It will be included in Flink

[GitHub] flink issue #5795: [hotfix] [docs] fix typos in Table API & SQL

2018-04-04 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5795 Thanks for the fixes @mayyamus! ---

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425276#comment-16425276 ] ASF GitHub Bot commented on FLINK-8620: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-04 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r179087145 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheReadsFromBlobTest.java --- @@ -33,16 +38,16 @@ import

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-04-04 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425271#comment-16425271 ] yuqi commented on FLINK-9056: - Hi, [~mingleizhang], The following are detailed log {code:java}

[jira] [Created] (FLINK-9129) Support nested KafkaJsonTableSource

2018-04-04 Thread samar (JIRA)
samar created FLINK-9129: Summary: Support nested KafkaJsonTableSource Key: FLINK-9129 URL: https://issues.apache.org/jira/browse/FLINK-9129 Project: Flink Issue Type: Improvement

[jira] [Reopened] (FLINK-9120) Task Manager Fault Tolerance issue

2018-04-04 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dhiraj prajapati reopened FLINK-9120: - As suggested by [~sihuazhou], reopening the issue till [~till.rohrmann] comments. Please

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

2018-04-04 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425258#comment-16425258 ] Sihua Zhou commented on FLINK-9120: --- Hi [~dhirajpraj] I think maybe we should leave this issue opening

[jira] [Closed] (FLINK-9120) Task Manager Fault Tolerance issue

2018-04-04 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dhiraj prajapati closed FLINK-9120. --- Resolution: Invalid > Task Manager Fault Tolerance issue > --

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

2018-04-04 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425256#comment-16425256 ] dhiraj prajapati commented on FLINK-9120: - HI [~till.rohrmann]/[~sihuazhou], it works perfectly

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425247#comment-16425247 ] ASF GitHub Bot commented on FLINK-8620: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-04 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r179079963 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheReadsFromBlobTest.java --- @@ -33,16 +38,16 @@ import

[jira] [Commented] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425242#comment-16425242 ] ASF GitHub Bot commented on FLINK-9128: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5812: [FLINK-9128] [flip6] Add support for scheduleRunAs...

2018-04-04 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5812 [FLINK-9128] [flip6] Add support for scheduleRunAsync for FencedRpcEndpoints ## What is the purpose of the change Wrap self messages in the FencedRpcEndpoints in a LocalFencedMessage

[jira] [Created] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints

2018-04-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9128: Summary: Add support for scheduleRunAsync for FencedRpcEndpoints Key: FLINK-9128 URL: https://issues.apache.org/jira/browse/FLINK-9128 Project: Flink Issue

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425233#comment-16425233 ] ASF GitHub Bot commented on FLINK-8620: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-04 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r179075409 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheReadsFromBlobTest.java --- @@ -33,16 +38,16 @@ import

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425224#comment-16425224 ] ASF GitHub Bot commented on FLINK-8835: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #5808: [FLINK-8835] [taskmanager] Fix TaskManager config keys

2018-04-04 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5808 Hi, @zentol I have updated the code based on your suggestions. Could you can take another look when available ? ---

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-04 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r179071066 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheReadsFromBlobTest.java --- @@ -33,16 +38,16 @@ import

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425217#comment-16425217 ] ASF GitHub Bot commented on FLINK-8620: --- Github user dawidwys commented on a diff in the pull

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-04-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9010: - Priority: Critical (was: Blocker) > NoResourceAvailableException with FLIP-6 >

[jira] [Commented] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-04-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425207#comment-16425207 ] Till Rohrmann commented on FLINK-9010: -- Alright, then this issue is about improving the error

[jira] [Commented] (FLINK-8971) Create general purpose testing job

2018-04-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425205#comment-16425205 ] Till Rohrmann commented on FLINK-8971: -- Hi [~mingleizhang], I think the problem is that the code is

[jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425196#comment-16425196 ] ASF GitHub Bot commented on FLINK-9113: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #5811: [FLINK-9113] [connectors] Fix flushing behavior of...

2018-04-04 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5811 [FLINK-9113] [connectors] Fix flushing behavior of bucketing sink for local filesystems ## What is the purpose of the change This PR changes the flushing behavior for HDFS' local

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425189#comment-16425189 ] ASF GitHub Bot commented on FLINK-8835: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...

2018-04-04 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5808#discussion_r179062944 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -104,40 +104,40 @@ "

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425188#comment-16425188 ] ASF GitHub Bot commented on FLINK-8835: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...

2018-04-04 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5808#discussion_r179062712 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -104,40 +104,40 @@ "

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425186#comment-16425186 ] ASF GitHub Bot commented on FLINK-8835: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...

2018-04-04 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5808#discussion_r179062374 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -321,8 +321,8 @@ * credit-based flow

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

2018-04-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425182#comment-16425182 ] ASF GitHub Bot commented on FLINK-8835: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...

2018-04-04 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5808#discussion_r179061417 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -104,40 +104,40 @@ " global

<    1   2   3   >