[GitHub] flink issue #2752: [FLINK-4814] [checkpointing] Use checkpoint directory for...

Github user uce commented on the issue: https://github.com/apache/flink/pull/2752 OK, I agree that it's better to leave it as is for the release. With the upcoming feature freeze, I don't think there is enough time to properly address this. I will cherry pick the docs changes for the

[jira] [Created] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality

Stefan Richter created FLINK-5325: - Summary: Introduce interface for CloseableRegistry to separate user from system-facing functionality Key: FLINK-5325 URL: https://issues.apache.org/jira/browse/FLINK-5325

[jira] [Created] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

Robert Metzger created FLINK-5326: - Summary: IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available Key: FLINK-5326 URL:

[jira] [Updated] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode

[ https://issues.apache.org/jira/browse/FLINK-5324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-5324: --- Attachment: 0001-FLINK-5324-yarn-JVM-Opitons-will-work-for-both-YarnA.patch > JVM Opitons will be work both

[GitHub] flink pull request #2750: [FLINK-5007] [checkpointing] Retain externalized c...

Github user uce closed the pull request at: https://github.com/apache/flink/pull/2750 --- 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

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

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

[jira] [Created] (FLINK-5327) Remove IOException from StateObject::getStateSize

Stefan Richter created FLINK-5327: - Summary: Remove IOException from StateObject::getStateSize Key: FLINK-5327 URL: https://issues.apache.org/jira/browse/FLINK-5327 Project: Flink Issue

[jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata

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

[jira] [Commented] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality

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

[jira] [Commented] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality

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

[GitHub] flink issue #2992: [FLINK-5325] Splitting user/system-facing API of Closeabl...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2992 CC @tillrohrmann @aljoscha --- 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

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744604#comment-15744604 ] Kurt Young commented on FLINK-3475: --- Hi [~fhueske], cool, will definitely let you know if we have some

[jira] [Commented] (FLINK-5007) Retain externalized checkpoint on suspension

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

[jira] [Closed] (FLINK-5007) Retain externalized checkpoint on suspension

[ https://issues.apache.org/jira/browse/FLINK-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5007. -- Resolution: Fixed Fixed in 38ab716 (master). > Retain externalized checkpoint on suspension >

[GitHub] flink issue #2961: [FLINK-5266] [table] eagerly project unused fields when s...

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/2961 Hi @fhueske , i have added the case of selecting from GroupWindowedTable. And have leave some test cases for EventTimeWindow in batch mode, since it supports using arbitrary field as the time

[GitHub] flink pull request #2992: [FLINK-5325] Splitting user/system-facing API of C...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2992 [FLINK-5325] Splitting user/system-facing API of CloseableRegistry Currently, the API of ``CloseableRegistry`` exposes the ``close`` method to all client code. This PR splits the API into a

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

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

[GitHub] flink issue #2982: [FLINK-4460] Side Outputs in Flink

Github user chenqin commented on the issue: https://github.com/apache/flink/pull/2982 @aljoscha Thanks for your time. We can chat more after 1.2 release! I think it makes sense to extends Collector, even though we may not remove collect(T obj) due to API compability issue in

[jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator

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

[GitHub] flink issue #2985: [FLINK-5104] Bipartite graph validation

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2985 Hi @greghogan , Thank you for your feedback. I've updated the PR accordingly. The only thing that I did differently is that I've replaced projections and two `count()` executions with

[GitHub] flink pull request #2985: [FLINK-5104] Bipartite graph validation

Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2985#discussion_r92276412 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidBipartiteVertexIdsValidator.java --- @@ -0,0 +1,85 @@ +/*

[jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator

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

[GitHub] flink pull request #3003: [Flink-5188] Create analog of RowCsvInputFormat in...

GitHub user tonycox opened a pull request: https://github.com/apache/flink/pull/3003 [Flink-5188] Create analog of RowCsvInputFormat in java and adjust all the imports of Row and RowTypeInfo Thanks for contributing to Apache Flink. Before you open your pull request, please take

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

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

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

GitHub user tony810430 opened a pull request: https://github.com/apache/flink/pull/3001 [FLINK-4821] [kinesis] Implement rescalable non-partitioned state for Kinesis Connector Implement ListCheckpointed interface on Kinesis Consumer As a reminder, I returned empty list

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r92314677 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java --- @@ -0,0 +1,58 @@ +/* + *

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r92315209 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java --- @@ -0,0 +1,58 @@ +/* + *

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

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

[GitHub] flink pull request #3002: Fix typo in variable name

GitHub user rboorgapally opened a pull request: https://github.com/apache/flink/pull/3002 Fix typo in variable name - Fixed a typo in the variable name - `mvn clean verify` has been executed successfully locally You can merge this pull request into a Git repository by

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

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

[GitHub] flink issue #2928: [FLINK-5108] Remove ClientShutdownHook during job executi...

Github user Renkai commented on the issue: https://github.com/apache/flink/pull/2928 That is ok to close this issue. Max 于2016年12月14日周三 02:31写道： > There is one problem we overlooked. In detached mode we ensure cluster >

[jira] [Commented] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode

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

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744745#comment-15744745 ] Fabian Hueske commented on FLINK-5255: -- Hmm, the Calcite documentation states that the rules are not

[GitHub] flink issue #2993: [FLINK-5327] Remove IOEXception from StateObject::getStat...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2993 Thanks for the blazing fast review and merge :) --- 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

[jira] [Updated] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

[ https://issues.apache.org/jira/browse/FLINK-5326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5326: --- Affects Version/s: 1.2.0 > IllegalStateException: Bug in Netty consumer logic: reader queue got

[jira] [Commented] (FLINK-5327) Remove IOException from StateObject::getStateSize

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

[jira] [Commented] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

[ https://issues.apache.org/jira/browse/FLINK-5326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744744#comment-15744744 ] Ufuk Celebi commented on FLINK-5326: No, 1.2.0 too. > IllegalStateException: Bug in Netty consumer

[jira] [Commented] (FLINK-5327) Remove IOException from StateObject::getStateSize

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

[jira] [Commented] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

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

[GitHub] flink pull request #2995: [FLINK-5320] Fix result TypeInformation in Windowe...

GitHub user ymarzougui opened a pull request: https://github.com/apache/flink/pull/2995 [FLINK-5320] Fix result TypeInformation in WindowedStream.fold The resultType of the WindowFunction in WindowedStream.fold(ACC, FoldFunction, WindowFunction) can not be inferred correctly

[GitHub] flink issue #2939: [FLINK-5113] Ports all functions in the tests to the new ...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2939 I think your argument is valid. This is how I had it before, but I changed it because it becomes too verbose, given that the `ListState.get()` just gives you an Iterable that you have to iterate over

[jira] [Commented] (FLINK-5113) Make all Testing Functions implement CheckpointedFunction Interface.

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

[GitHub] flink issue #2867: [FLINK-5145] WebInterface only polls selected metrics

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2867 +1 to merge --- 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

[GitHub] flink issue #2871: [FLINK-5163] Ports the production functions to the new st...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2871 I merged this, could you please close the PR and the issue? Thanks for your work. 👍 --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode

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

[GitHub] flink issue #2994: [FLINK-5324] [yarn] JVM Opitons will work for both YarnAp...

Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2994 @ChengXiangLi ,can u review 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 feature

[jira] [Commented] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

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

[jira] [Closed] (FLINK-5310) Harden the RocksDB JNI library loading

[ https://issues.apache.org/jira/browse/FLINK-5310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5310. --- Resolution: Fixed Implemented in 609c046dba20cd07d9480715cfd1a6d78ed3a611 > Harden the

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

[jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata

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

[GitHub] flink pull request #2752: [FLINK-4814] [checkpointing] Use checkpoint direct...

Github user uce closed the pull request at: https://github.com/apache/flink/pull/2752 --- 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

[jira] [Commented] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails

[ https://issues.apache.org/jira/browse/FLINK-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745056#comment-15745056 ] Ufuk Celebi commented on FLINK-5328: The attached logs also show this: {code} 12:00:31,315 ERROR

[jira] [Closed] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

[ https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5163. - Resolution: Fixed > Make the production functions rescalable (apart from the Rolling/Bucketing >

[GitHub] flink issue #2871: [FLINK-5163] Ports the production functions to the new st...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2871 @aljoscha Yes thanks a lot! --- 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

[jira] [Commented] (FLINK-5145) WebInterface to aggressive in pulling metrics

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

[jira] [Commented] (FLINK-5223) Add documentation of UDTF in Table API & SQL

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

[jira] [Commented] (FLINK-5304) Change method name from crossApply to join in Table API

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

[jira] [Commented] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

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

[GitHub] flink pull request #2966: [FLINK-5290] Ensure backwards compatibility of the...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2966#discussion_r92128811 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/DefaultStreamGraphHasher.java --- @@ -0,0 +1,313 @@ +/* + *

[jira] [Commented] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds

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

[GitHub] flink issue #2993: [FLINK-5327] Remove IOEXception from StateObject::getStat...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2993 Nice, that is an easy one to review ;-) +1, will 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

[jira] [Commented] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

[ https://issues.apache.org/jira/browse/FLINK-5326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744737#comment-15744737 ] Maximilian Michels commented on FLINK-5326: --- Is only 1.1.4 affected? > IllegalStateException:

[jira] [Commented] (FLINK-5145) WebInterface to aggressive in pulling metrics

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

[GitHub] flink issue #2867: [FLINK-5145] WebInterface only polls selected metrics

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2867 merging --- 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

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

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

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

Github user senorcarbone commented on the issue: https://github.com/apache/flink/pull/1668 These are some good points @StephanEwen, thanks for checking it. How about the following, regarding each issue: - `Concurrent Checkpoints`: Looks like an improvement but I can sure

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

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

[GitHub] flink issue #2756: [FLINK-4997] Extending Window Function Metadata

Github user VenturaDelMonte commented on the issue: https://github.com/apache/flink/pull/2756 @aljoscha ok, then let me know, please, if I can help somehow. --- 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

[jira] [Commented] (FLINK-5327) Remove IOException from StateObject::getStateSize

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

[jira] [Updated] (FLINK-5327) Remove IOException from StateObject::getStateSize

[ https://issues.apache.org/jira/browse/FLINK-5327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5327: -- Description: The signature of {{StateObject::getStateSize}} declares throwing of an

[GitHub] flink issue #2993: [FLINK-5327] Remove IOEXception from StateObject::getStat...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2993 CC @StephanEwen --- 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

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

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

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/1668 @senorcarbone I agree, let's fix the multiple checkpoints issue and do the rest in FLIP-15 The other operators have a pretty simply way of doing this: - for synchronous

[jira] [Commented] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744775#comment-15744775 ] Yassine Marzougui commented on FLINK-5320: -- [~aljoscha] I just opened a pull request for it.

[GitHub] flink pull request #2962: [FLINK-5051] Backwards compatibility for serialize...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2962#discussion_r92145625 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java --- @@ -228,6 +229,21 @@ public void testValueState() throws

[GitHub] flink pull request #2962: [FLINK-5051] Backwards compatibility for serialize...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2962#discussion_r92145660 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java --- @@ -1373,4 +1431,71 @@ private KeyGroupsStateHandle

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

[GitHub] flink pull request #2871: [FLINK-5163] Ports the production functions to the...

Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/2871 --- 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

[jira] [Commented] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

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

[jira] [Commented] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

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

[jira] [Updated] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5320: Priority: Blocker (was: Major) > Fix result TypeInformation in WindowedStream.fold(ACC,

[jira] [Commented] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot

[ https://issues.apache.org/jira/browse/FLINK-5034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744733#comment-15744733 ] Stefan Richter commented on FLINK-5034: --- Yes > Don't Write StateDescriptor to RocksDB Snapshot >

[GitHub] flink pull request #2990: Backport [FLINK-5071]

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2990 --- 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

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744952#comment-15744952 ] Fabian Hueske commented on FLINK-5280: -- Hi [~ivan.mushketyk], First of all, you are completely right

[jira] [Commented] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

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

[GitHub] flink pull request #2993: [FLINK-5327] Remove IOEXception from StateObject::...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2993 [FLINK-5327] Remove IOEXception from StateObject::getStateSize The signature of ``StateObject::getStateSize`` declares throwing of an ``IOException``. This is an artefact of the state handle

[jira] [Commented] (FLINK-5327) Remove IOException from StateObject::getStateSize

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

[jira] [Commented] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744706#comment-15744706 ] Aljoscha Krettek commented on FLINK-5320: - It should be {code} TypeInformation

[jira] [Commented] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

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

[GitHub] flink pull request #2996: [FLINK-5326] [network] Check release flag of paren...

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2996 [FLINK-5326] [network] Check release flag of parent in reader In `PipelinedSubpartitionView`, there is a possible race with releasing the parent subpartition and querying for a buffer in the view.

[GitHub] flink issue #2956: [FLINK-5223] [doc] Add documentation of UDTF in Table API...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2956 Merging --- 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

[GitHub] flink issue #2923: [FLINK-5220] [Table API & SQL] Flink SQL projection pushd...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2923 Merging --- 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

[GitHub] flink issue #2978: [FLINK-5304] [table] Change method name from crossApply t...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2978 Merging --- 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

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

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

[GitHub] flink pull request #2994: [FLINK-5324] [yarn] JVM Opitons will work for both...

GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/2994 [FLINK-5324] [yarn] JVM Opitons will work for both YarnApplicationMas… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink pull request #2962: [FLINK-5051] Backwards compatibility for serialize...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2962#discussion_r92144965 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedBackendSerializationProxy.java --- @@ -0,0 +1,219 @@ +/* + * Licensed to

[GitHub] flink issue #2966: [FLINK-5290] Ensure backwards compatibility of the hashes...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2966 @aljoscha I duplicated the code in different hasher versions and moved the old version to a migration package. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds

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

[jira] [Updated] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails

[ https://issues.apache.org/jira/browse/FLINK-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5328: --- Attachment: connectedComponentsFailure.txt > ConnectedComponentsITCase testJobWithoutObjectReuse

  1   2   3   >