[GitHub] flink pull request #2956: [FLINK-5223] [doc] Add documentation of UDTF in Ta...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2956 --- 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-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=15745166#comment-15745166 ] ASF GitHub Bot commented on FLINK-5290: --- Github user aljoscha commented on a diff in the pull

[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_r92167823 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java --- @@ -0,0 +1,319 @@ +/* + * Licensed

[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_r92167706 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/api/graph/StreamGraphHasherV1.java --- @@ -0,0 +1,293 @@ +/* + *

[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=15745165#comment-15745165 ] ASF GitHub Bot commented on FLINK-5290: --- Github user aljoscha commented on a diff in the pull

[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=15745162#comment-15745162 ] ASF GitHub Bot commented on FLINK-5266: --- Github user fhueske commented on the issue:

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

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2961 Hi @KurtYoung, thanks for the update and the nice solution for the window aggregates. +1 to merge --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService

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

[GitHub] flink issue #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM Me...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2991 I can add a check for both the JM/TM to only start the service if the web UI is started as well. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink issue #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM Me...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2991 We only need it in that case, yes. --- 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-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=15745136#comment-15745136 ] ASF GitHub Bot commented on FLINK-5320: --- Github user ymarzougui commented on the issue:

[GitHub] flink issue #2995: [FLINK-5320] Fix result TypeInformation in WindowedStream...

Github user ymarzougui commented on the issue: https://github.com/apache/flink/pull/2995 Yes, I will see how to add a unit test and try to add a commit to this PR by the end of the day or tomorrow. Fortunately the fold in `AllWindowStream` is correct, the problem in `WindowStream` is

[jira] [Closed] (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 closed FLINK-5326. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed in 04db15a, 9ed7752

[GitHub] flink issue #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM Me...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2991 Do we want this in case the mini cluster starts the web UI? --- 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

[jira] [Commented] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService

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

[GitHub] flink issue #2995: [FLINK-5320] Fix result TypeInformation in WindowedStream...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2995 Thanks a lot, this looks like the correct fix. Usually, we add a small unit test to such fixes to guard the bugfix. Also, the same problem probably exists in the `AllWindowStream`.

[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=15745108#comment-15745108 ] ASF GitHub Bot commented on FLINK-5320: --- Github user StephanEwen commented on the issue:

[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=15745100#comment-15745100 ] 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 agreed @StephanEwen! I will do that. --- 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-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=15745097#comment-15745097 ] ASF GitHub Bot commented on FLINK-5326: --- Github user uce closed the pull request at:

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

Github user uce closed the pull request at: https://github.com/apache/flink/pull/2996 --- 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] [Closed] (FLINK-5145) WebInterface to aggressive in pulling metrics

[ https://issues.apache.org/jira/browse/FLINK-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5145. --- Resolution: Fixed Fixed in 1cc887e31f9c70070c3ea0107a5d1b1413dff828 > WebInterface to

[GitHub] flink pull request #2867: [FLINK-5145] WebInterface only polls selected metr...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2867 --- 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-5145) WebInterface to aggressive in pulling metrics

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

[jira] [Updated] (FLINK-5329) Metric list is being cut off in the WebFrontend

[ https://issues.apache.org/jira/browse/FLINK-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5329: Summary: Metric list is being cut off in the WebFrontend (was: MetricList is being cut

[jira] [Updated] (FLINK-5329) MetricList is being cut off

[ https://issues.apache.org/jira/browse/FLINK-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5329: Attachment: ss_metrics.png > MetricList is being cut off > --- > >

[jira] [Created] (FLINK-5329) MetricList is being cut off

Chesnay Schepler created FLINK-5329: --- Summary: MetricList is being cut off Key: FLINK-5329 URL: https://issues.apache.org/jira/browse/FLINK-5329 Project: Flink Issue Type: Bug

[GitHub] flink issue #2996: [FLINK-5326] [network] Check release flag of parent in re...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2996 Looks good, +1 for this fix --- 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

[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:

[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-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:

[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=15745071#comment-15745071 ] ASF GitHub Bot commented on FLINK-5163: --- Github user aljoscha commented on the issue:

[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-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] [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

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

Ufuk Celebi created FLINK-5328: -- Summary: ConnectedComponentsITCase testJobWithoutObjectReuse fails Key: FLINK-5328 URL: https://issues.apache.org/jira/browse/FLINK-5328 Project: Flink 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:

[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 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

[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

[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

[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-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-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:

[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-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-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 #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

[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

[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:

[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

[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

[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

[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 #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-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.

[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-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:

[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-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.

[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 #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-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:

[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:

[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-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

[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=15744742#comment-15744742 ] ASF GitHub Bot commented on FLINK-5327: --- Github user StephanEwen commented on the issue:

[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-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 >

[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] [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-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 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-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:

[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-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 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 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-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 #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-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

[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:

[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

[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-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:

[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] [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:

<    1   2   3   >