[jira] [Created] (FLINK-4779) Restoring from savepoint fails when BucketingSink has not yet created folder

static-max created FLINK-4779: - Summary: Restoring from savepoint fails when BucketingSink has not yet created folder Key: FLINK-4779 URL: https://issues.apache.org/jira/browse/FLINK-4779 Project: Flink

[GitHub] flink issue #2605: [FLINK-4764] [core] Introduce Config Options

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2605 Updated, see new description above. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-4764) Introduce config options

[ https://issues.apache.org/jira/browse/FLINK-4764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1083#comment-1083 ] ASF GitHub Bot commented on FLINK-4764: --- Github user StephanEwen commented on the issue:

[GitHub] flink pull request #2607: [FLINK-4768] [core] Migrate high-availability conf...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2607 [FLINK-4768] [core] Migrate high-availability configuration parameters to ConfigOptions This is based on #2605 - so only the later commit is relevant. This basically moves all High

[jira] [Commented] (FLINK-4768) Migrate High Availability configuration options

[ https://issues.apache.org/jira/browse/FLINK-4768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1090#comment-1090 ] ASF GitHub Bot commented on FLINK-4768: --- GitHub user StephanEwen opened a pull request:

[jira] [Commented] (FLINK-3988) Add data set connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1113#comment-1113 ] Khurrum Nasim commented on FLINK-3988: -- [~johnlon] I am actually working on adding connectors to

[jira] [Commented] (FLINK-3987) Add data stream connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1115#comment-1115 ] Khurrum Nasim commented on FLINK-3987: -- [~johnlon] I am actually working on adding connectors to

[jira] [Commented] (FLINK-3987) Add data stream connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1118#comment-1118 ] Khurrum Nasim commented on FLINK-3987: -- [~zhaijia] are you actively working on this and FLINK-3888?

[GitHub] flink issue #2607: [FLINK-4768] [core] Migrate high-availability configurati...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2607 Does moving the keys to another class break compatibility? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-4768) Migrate High Availability configuration options

[ https://issues.apache.org/jira/browse/FLINK-4768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1119#comment-1119 ] ASF GitHub Bot commented on FLINK-4768: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4760) Kafka 09 Consumer failed to initialize state because of corrupted operator state and not able to recover

[ https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1890#comment-1890 ] Stephan Ewen commented on FLINK-4760: - I think this is fixed in the latest version of the master. You

[jira] [Updated] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-4778: -- Description: According to FLINK-2021, ParameterTool was introduced hence all input

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556280#comment-15556280 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on the issue:

[GitHub] flink issue #757: [FLINK-2131][ml]: Initialization schemes for k-means clust...

Github user skonto commented on the issue: https://github.com/apache/flink/pull/757 @sachingoel0101 @tillrohrmann any plans for this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-4765) Migrate ConfigConstants to ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-4765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1782#comment-1782 ] Stephan Ewen commented on FLINK-4765: - Have a look at this pull request, which illustrates it:

[jira] [Closed] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job

[ https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2228. --- > Web frontend uses two different timezones when reporting the time for job >

[jira] [Created] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

Maximilian Michels created FLINK-4777: - Summary: ContinuousFileMonitoringFunction may throw IOException when files are moved Key: FLINK-4777 URL: https://issues.apache.org/jira/browse/FLINK-4777

[jira] [Updated] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

[ https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4777: -- Description: FileSystem.listStatus(path) may throw an IOException when it lists files

[jira] [Resolved] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job

[ https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2228. - Resolution: Done Validated fixed by [~heytitle] Thanks for checking this out! > Web frontend

[GitHub] flink pull request #2610: [FLINK-4777] catch IOException in ContinuousFileMo...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2610 [FLINK-4777] catch IOException in ContinuousFileMonitoringFunction FileSystem.listStatus(path) may throw an IOException when it lists files and then retrieves their file status. This is quite

[jira] [Commented] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

[ https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1822#comment-1822 ] ASF GitHub Bot commented on FLINK-4777: --- GitHub user mxm opened a pull request:

[jira] [Resolved] (FLINK-4318) Make master docs build target version-specific

[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4318. --- Resolution: Fixed Fix Version/s: 1.2.0 I've changed the code to include an

[jira] [Commented] (FLINK-4583) NullPointerException in CliFrontend

[ https://issues.apache.org/jira/browse/FLINK-4583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1268#comment-1268 ] Maximilian Michels commented on FLINK-4583: --- Thanks for marking as duplicate, didn't see your

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

Github user skrishnappa commented on a diff in the pull request: https://github.com/apache/flink/pull/2518#discussion_r82412822 --- Diff: docs/setup/security-ssl.md --- @@ -0,0 +1,139 @@ +--- +title: "SSL Setup" +nav-parent_id: setup +nav-pos: 8 +--- + +

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

Github user skrishnappa commented on a diff in the pull request: https://github.com/apache/flink/pull/2518#discussion_r82413936 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/files/StaticFileServerHandler.java --- @@ -304,8 +314,15 @@ private void

[jira] [Created] (FLINK-4776) Move ExecutionGraph initialization into a dedicated class

Stephan Ewen created FLINK-4776: --- Summary: Move ExecutionGraph initialization into a dedicated class Key: FLINK-4776 URL: https://issues.apache.org/jira/browse/FLINK-4776 Project: Flink Issue

[GitHub] flink pull request #2571: [FLINK-4348] Simplify logic of SlotManager

Github user mxm closed the pull request at: https://github.com/apache/flink/pull/2571 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #2571: [FLINK-4348] Simplify logic of SlotManager

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2571 Merged --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Created] (FLINK-4775) Simplify access to MetricStore

Chesnay Schepler created FLINK-4775: --- Summary: Simplify access to MetricStore Key: FLINK-4775 URL: https://issues.apache.org/jira/browse/FLINK-4775 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4768) Migrate High Availability configuration options

[ https://issues.apache.org/jira/browse/FLINK-4768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1179#comment-1179 ] ASF GitHub Bot commented on FLINK-4768: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2607: [FLINK-4768] [core] Migrate high-availability configurati...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2607 It does. I thought I would move only `PublicEvolving` (and since this is not really API it would be okay in my opinion), but some deprecated keys are actually "public", so we'd need to keep

[jira] [Created] (FLINK-4774) QueryScopeInfo scope concatenation broken

Chesnay Schepler created FLINK-4774: --- Summary: QueryScopeInfo scope concatenation broken Key: FLINK-4774 URL: https://issues.apache.org/jira/browse/FLINK-4774 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-3204) TaskManagers are not shutting down properly on YARN

[ https://issues.apache.org/jira/browse/FLINK-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3204. --- Resolution: Cannot Reproduce This doesn't seem to be relevant anymore. If the

[GitHub] flink issue #2518: [FLINK-3931] Implement Transport Encryption (SSL/TLS)

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2518 CC @StephanEwen You might want to take a look as well. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

Github user skrishnappa commented on a diff in the pull request: https://github.com/apache/flink/pull/2518#discussion_r82412499 --- Diff: docs/setup/config.md --- @@ -211,6 +214,19 @@ The following parameters configure Flink's JobManager and TaskManagers. - `akka.throughput`:

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

Github user skrishnappa commented on a diff in the pull request: https://github.com/apache/flink/pull/2518#discussion_r82412518 --- Diff: docs/setup/config.md --- @@ -222,6 +238,7 @@ The following parameters configure Flink's JobManager and TaskManagers. -

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

Github user skrishnappa commented on a diff in the pull request: https://github.com/apache/flink/pull/2518#discussion_r82412401 --- Diff: docs/setup/config.md --- @@ -140,6 +140,8 @@ will be used under the directory specified by jobmanager.web.tmpdir. -

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1411#comment-1411 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1215#comment-1215 ] Maximilian Michels commented on FLINK-4326: --- Maybe I'm missing the point here but wouldn't it

[jira] [Created] (FLINK-4773) Introduce an OperatorIOMetricGroup

Chesnay Schepler created FLINK-4773: --- Summary: Introduce an OperatorIOMetricGroup Key: FLINK-4773 URL: https://issues.apache.org/jira/browse/FLINK-4773 Project: Flink Issue Type:

[jira] [Closed] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4348. - Resolution: Fixed > Implement slot allocation protocol with TaskExecutor >

[jira] [Closed] (FLINK-4538) Implement slot allocation protocol with JobMaster

[ https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4538. - Resolution: Fixed > Implement slot allocation protocol with JobMaster >

[jira] [Created] (FLINK-4771) Compression for AvroOutputFormat

Lars Bachmann created FLINK-4771: Summary: Compression for AvroOutputFormat Key: FLINK-4771 URL: https://issues.apache.org/jira/browse/FLINK-4771 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4717) Naive version of atomic stop signal with savepoint

[ https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1461#comment-1461 ] ASF GitHub Bot commented on FLINK-4717: --- GitHub user uce opened a pull request:

[jira] [Resolved] (FLINK-4726) Quickstart: Java API - Broken

[ https://issues.apache.org/jira/browse/FLINK-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4726. --- Resolution: Not A Problem Fix Version/s: (was: 1.1.3) You are probably

[jira] [Commented] (FLINK-4765) Migrate ConfigConstants to ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-4765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1308#comment-1308 ] Maximilian Michels commented on FLINK-4765: --- +1 This will be a cleaner implementation of

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1450#comment-1450 ] ASF GitHub Bot commented on FLINK-4512: --- GitHub user uce opened a pull request:

[jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1173#comment-1173 ] ASF GitHub Bot commented on FLINK-4348: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1174#comment-1174 ] ASF GitHub Bot commented on FLINK-4348: --- Github user mxm closed the pull request at:

[jira] [Commented] (FLINK-4318) Make master docs build target version-specific

[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1187#comment-1187 ] Maximilian Michels commented on FLINK-4318: --- Also changed the links on the homepage to point to

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1345#comment-1345 ] ASF GitHub Bot commented on FLINK-3931: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1393#comment-1393 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[jira] [Commented] (FLINK-4318) Make master docs build target version-specific

[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1153#comment-1153 ] Ufuk Celebi commented on FLINK-4318: Thanks > Make master docs build target version-specific >

[jira] [Closed] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4606. - Resolution: Fixed > Integrate the new ResourceManager with the existing

[jira] [Closed] (FLINK-4442) Implement Standalone ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4442. - Resolution: Fixed > Implement Standalone ResourceManager >

[jira] [Commented] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend

[ https://issues.apache.org/jira/browse/FLINK-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1259#comment-1259 ] Maximilian Michels commented on FLINK-4667: --- Thank you for reporting. > Yarn Session CLI not

[jira] [Resolved] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are used

[ https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4724. --- Resolution: Not A Problem Thanks for reporting. I agree with [~eronwright], that this

[jira] [Created] (FLINK-4772) Store metrics in MetricStore as strings

Chesnay Schepler created FLINK-4772: --- Summary: Store metrics in MetricStore as strings Key: FLINK-4772 URL: https://issues.apache.org/jira/browse/FLINK-4772 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1386#comment-1386 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1387#comment-1387 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1383#comment-1383 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[GitHub] flink pull request #2609: [FLINK-4717] Add CancelJobWithSavepoint

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2609 [FLINK-4717] Add CancelJobWithSavepoint This builds on top of #2608. - Adds CancelJobWithSavepoint message, which triggers a savepoint before cancelling the respective job. The periodic

[jira] [Assigned] (FLINK-4318) Make master docs build target version-specific

[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4318: - Assignee: Maximilian Michels > Make master docs build target version-specific >

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

Github user skrishnappa commented on a diff in the pull request: https://github.com/apache/flink/pull/2518#discussion_r82412954 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java --- @@ -0,0 +1,284 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

Github user skrishnappa commented on a diff in the pull request: https://github.com/apache/flink/pull/2518#discussion_r82412891 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -544,6 +552,11 @@ public static final String

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1392#comment-1392 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1391#comment-1391 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2608 [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints ## Introduction This is the first part of

[jira] [Updated] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job

[ https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-2228: -- Attachment: Screenshot 2016-10-07 18.02.04.png Just want to confirm that the issue

[GitHub] flink pull request #2611: Update the way we call WordCount program in setup/...

GitHub user heytitle opened a pull request: https://github.com/apache/flink/pull/2611 Update the way we call WordCount program in setup/cli.md examples. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

[ https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1988#comment-1988 ] ASF GitHub Bot commented on FLINK-4777: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2610: [FLINK-4777] catch IOException in ContinuousFileMonitorin...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2610 Looks good to me... +1 to merge this --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Created] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

Pattarawat Chormai created FLINK-4778: - Summary: Update program example in /docs/setup/cli.md due to the change in FLINK-2021 Key: FLINK-4778 URL: https://issues.apache.org/jira/browse/FLINK-4778

[jira] [Updated] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-4778: -- Description: According to FLINK-2021, ParameterTool was introduced hence all input

[jira] [Updated] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-4778: -- Description: According to FLINK-2021, ParameterTool was introduced hence all input

[jira] [Commented] (FLINK-4760) Kafka 09 Consumer failed to initialize state because of corrupted operator state and not able to recover

[ https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556026#comment-15556026 ] Zhenzhong Xu commented on FLINK-4760: - We are using v1.2 Commit: f3d7fa7. Can you confirm this commit

[jira] [Updated] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-4778: -- Description: According to FLINK-2021, ParameterTool was introduced hence all input

[jira] [Updated] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-4778: -- Description: According to FLINK-2021, ParameterTool was introduced hence all input

[jira] [Updated] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-4778: -- Description: According to FLINK-2021, ParameterTool was introduced hence all input

[jira] [Updated] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai updated FLINK-4778: -- Description: According to FLINK-2021, ParameterTool was introduced hence all input

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556120#comment-15556120 ] Greg Hogan commented on FLINK-4326: --- There is a fair bit of code to handle the logging which will not be

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556922#comment-15556922 ] ASF GitHub Bot commented on FLINK-2131: --- Github user sachingoel0101 commented on the issue:

[GitHub] flink issue #757: [FLINK-2131][ml]: Initialization schemes for k-means clust...

Github user sachingoel0101 commented on the issue: https://github.com/apache/flink/pull/757 I'll update based on your comments in a few days. ^^ On Oct 8, 2016 06:21, "Stavros Kontopoulos" wrote: > @sachingoel0101

[GitHub] flink issue #2562: [FLINK-4691] [table] Add group-windows for streaming tabl...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2562 @fhueske I have implemented the window properties as an additional parameter instead of aggregation functions. What do you think? --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-4691) Add group-windows for streaming tables

[ https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556698#comment-15556698 ] ASF GitHub Bot commented on FLINK-4691: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556725#comment-15556725 ] Timo Walther commented on FLINK-4604: - I think a even nicer solution would be to check the aggregation

[jira] [Commented] (FLINK-4760) Kafka 09 Consumer failed to initialize state because of corrupted operator state and not able to recover

[ https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556655#comment-15556655 ] Stephan Ewen commented on FLINK-4760: - I cannot find commit {{f3d7fa7}} in the Flink git history. Is

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15554768#comment-15554768 ] Anton Mushin commented on FLINK-4604: - I changed method

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15554766#comment-15554766 ] Timo Walther commented on FLINK-4604: - Yes, you are right. We have to make the costs for STDDEV_POP,

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15554774#comment-15554774 ] Timo Walther commented on FLINK-4743: - Just a small hint on this: It seems that

[jira] [Commented] (FLINK-4759) Unclosed DataOutputViewStream in JavaSerializer

[ https://issues.apache.org/jira/browse/FLINK-4759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15554849#comment-15554849 ] Stephan Ewen commented on FLINK-4759: - I think that should not be changed. The `DataOutputViewStream`

[jira] [Closed] (FLINK-3553) Don't include watermarks in record count

[ https://issues.apache.org/jira/browse/FLINK-3553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3553. --- Resolution: Fixed This will be fixed as a side-effect of FLINK-4733. > Don't include

[jira] [Updated] (FLINK-4763) Documentation doesn't update nightly

[ https://issues.apache.org/jira/browse/FLINK-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4763: -- Description: Nightly documentation builds fail, e.g.

[jira] [Closed] (FLINK-4763) Documentation doesn't update nightly

[ https://issues.apache.org/jira/browse/FLINK-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4763. - Resolution: Fixed Turns out, using Bundler's {{--full-index}} method to fetch Gem

[jira] [Created] (FLINK-4765) Migrate ConfigConstants to ConfigOptions

Stephan Ewen created FLINK-4765: --- Summary: Migrate ConfigConstants to ConfigOptions Key: FLINK-4765 URL: https://issues.apache.org/jira/browse/FLINK-4765 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4764) Introduce config options

Stephan Ewen created FLINK-4764: --- Summary: Introduce config options Key: FLINK-4764 URL: https://issues.apache.org/jira/browse/FLINK-4764 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4768) Migrate High Availability configuration options

Stephan Ewen created FLINK-4768: --- Summary: Migrate High Availability configuration options Key: FLINK-4768 URL: https://issues.apache.org/jira/browse/FLINK-4768 Project: Flink Issue Type:

[GitHub] flink pull request #2606: Allow custom convergence criterion in delta iterat...

GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/2606 Allow custom convergence criterion in delta iterations As discussed in the Jira issue, this PR contains the following changes: 1. use `TaskConfig.setConvergenceCriterion()` to set the custom,

[jira] [Created] (FLINK-4763) Documentation doesn't update nightly

Maximilian Michels created FLINK-4763: - Summary: Documentation doesn't update nightly Key: FLINK-4763 URL: https://issues.apache.org/jira/browse/FLINK-4763 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4767) Migrate JobManager configuration options

Stephan Ewen created FLINK-4767: --- Summary: Migrate JobManager configuration options Key: FLINK-4767 URL: https://issues.apache.org/jira/browse/FLINK-4767 Project: Flink Issue Type: Sub-task

  1   2   >