[GitHub] flink issue #4459: [FLINK-7221] [jdbc] Throw exception if execution of last ...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4459 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-7362) CheckpointProperties are not correctly set when restoring savepoint with HA enabled

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

[GitHub] flink pull request #4491: [FLINK-7362] [checkpoints] Savepoint property is l...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/4491 [FLINK-7362] [checkpoints] Savepoint property is lost after de/serial… …ization of CheckpointProperties ## What is the purpose of the change This PR fixes lost

[GitHub] flink issue #4491: [FLINK-7362] [checkpoints] Savepoint property is lost aft...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4491 CC @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 and wishes so,

[jira] [Commented] (FLINK-7362) CheckpointProperties are not correctly set when restoring savepoint with HA enabled

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4492 [FLINK-7381] [web] Decouple WebRuntimeMonitor from ActorGateway ## What is the purpose of the change This PR decouples the `WebRuntimeMonitor` from the `ActorGateway` by introducing

[GitHub] flink issue #4470: [FLINK-7343] Simulate network failures in kafka at-least-...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4470 Yes I also didn't like adding this new flag, but didn't have enough motivation to change it. I have done some refactoring extracting those dynamically set in `prepare` method to some `Config`

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

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

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[jira] [Assigned] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7240: Assignee: Till Rohrmann > Externalized RocksDB can fail with stackoverflow >

[jira] [Updated] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7240: - Affects Version/s: 1.4.0 > Externalized RocksDB can fail with stackoverflow >

[GitHub] flink issue #4470: [FLINK-7343] Simulate network failures in kafka at-least-...

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

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

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

[GitHub] flink pull request #4481: [FLINK-7316][network] always use off-heap network ...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4481#discussion_r131672655 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java --- @@ -274,7 +260,7 @@ private void

[jira] [Commented] (FLINK-7316) always use off-heap network buffers

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

[GitHub] flink pull request #4481: [FLINK-7316][network] always use off-heap network ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4481#discussion_r131673257 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java --- @@ -274,7 +260,7 @@ private void

[jira] [Commented] (FLINK-7316) always use off-heap network buffers

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

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

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

[GitHub] flink issue #4367: [FLINK-4499] [build] Add spotbugs plugin

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4367 looks like the build times increase by 5-10 minutes but I'd say this is worth it +1 from my side --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Updated] (FLINK-7354) test instability in LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers

[ https://issues.apache.org/jira/browse/FLINK-7354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7354: --- Labels: test-stability (was: ) > test instability in >

[jira] [Commented] (FLINK-7300) End-to-end tests are instable on Travis

[ https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116353#comment-16116353 ] Till Rohrmann commented on FLINK-7300: -- This does not seem to fully solve the problem:

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

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

[jira] [Assigned] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-5509: - Assignee: Kostas Kloudas > Replace QueryableStateClient keyHashCode argument >

[GitHub] flink issue #4460: [FLINK-7349] [travis] Only execute checkstyle in misc pro...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4460 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-7349) Only execute checkstyle in one build profile

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

[jira] [Created] (FLINK-7379) Remove `HighAvailabilityServices` from client constructor.

Kostas Kloudas created FLINK-7379: - Summary: Remove `HighAvailabilityServices` from client constructor. Key: FLINK-7379 URL: https://issues.apache.org/jira/browse/FLINK-7379 Project: Flink

[GitHub] flink issue #4456: [FLINK-7343][kafka] Increase Xmx for tests

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4456 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-7343) Kafka010ProducerITCase instability

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

[GitHub] flink issue #4453: [FLINK-6982] [guava] Reduce guava dependency usages

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4453 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 pull request #4490: [FLINK-7382][docs] Fix some broken links in docs

GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4490 [FLINK-7382][docs] Fix some broken links in docs ## What is the purpose of the change Fix some broken links in docs. ## Brief change log ## Verifying this change

[jira] [Commented] (FLINK-7382) Broken links in `Apache Flink Documentation` page

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

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

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

[GitHub] flink issue #4456: [FLINK-7343][kafka] Increase Xmx for tests

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4456 Thanks :) --- 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 pull request #4470: [FLINK-7343] Simulate network failures in kafka at...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4470#discussion_r131648638 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailureHandler.java --- @@ -0,0 +1,176 @@ +/*

[jira] [Commented] (FLINK-7376) Cleanup options class and test classes in flink-clients

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

[GitHub] flink issue #4484: [FLINK-7376][Client] Cleanup options class and test class...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4484 Yes! I hope I didn't discourage you from contributing. It's just that lately we have become careful with purely cosmetic changes because they can introduce subtle bugs and cause overhead when

[GitHub] flink issue #4489: [FLINK-7383] Remove ConfigurationUtil

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4489 👍 LGTM --- 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 pull request #4457: [hotfix] [gelly] Explicit type can be replaced wit...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4457 --- 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 #4367: [FLINK-4499] [build] Add spotbugs plugin

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4367 --- 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 #4461: [FLINK-7350] [travis] Only execute japicmp in misc...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4461 --- 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 #4452: [FLINK-7013] [shading] Introduce flink-shaded-nett...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4452 --- 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 #4456: [FLINK-7343][kafka] Increase Xmx for tests

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4456 --- 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 #4460: [FLINK-7349] [travis] Only execute checkstyle in m...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4460 --- 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-7348) Allow redundant modifiers on methods

[ https://issues.apache.org/jira/browse/FLINK-7348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7348. --- Resolution: Fixed 1.4: 614c18dcd9b6424d87ea836e08ddf5a84cc53894 > Allow redundant modifiers

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116568#comment-16116568 ] Chesnay Schepler commented on FLINK-7343: - Xmx increase in 1.4 in

[jira] [Closed] (FLINK-4499) Introduce findbugs maven plugin

[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4499. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: a1644076ee0b1771777ffc9e5634e5b2ece89d00

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

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

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

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

[jira] [Closed] (FLINK-7350) only execute japicmp in one build profile

[ https://issues.apache.org/jira/browse/FLINK-7350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7350. --- Resolution: Fixed 1.4: be8eb1a6000ad7fb97c254a1bd46f5b058e04d45 > only execute japicmp in

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[GitHub] flink pull request #4404: [FLINK-4565] [table] Support for SQL IN operator

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4404#discussion_r131655114 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala --- @@ -0,0 +1,95 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7316) always use off-heap network buffers

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

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116601#comment-16116601 ] Fabian Hueske commented on FLINK-7245: -- Hi [~xccui], I think this is a very good observation: bq.

[jira] [Resolved] (FLINK-6305) flink-ml tests are executed in all flink-fast-test profiles

[ https://issues.apache.org/jira/browse/FLINK-6305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-6305. Resolution: Fixed > flink-ml tests are executed in all flink-fast-test profiles >

[jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6571: --- Labels: test-stability (was: ) > InfiniteSource in SourceStreamOperatorTest should deal with >

[jira] [Updated] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI

[ https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6567: --- Labels: test-stability (was: ) > ExecutionGraphMetricsTest fails on Windows CI >

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

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

[jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch

[ https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6838: --- Labels: test-stability (was: ) > RescalingITCase fails in master branch >

[jira] [Commented] (FLINK-7383) Remove ConfigurationUtil

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

[jira] [Commented] (FLINK-7348) Allow redundant modifiers on methods

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

[jira] [Closed] (FLINK-7349) Only execute checkstyle in one build profile

[ https://issues.apache.org/jira/browse/FLINK-7349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7349. --- Resolution: Fixed 1.4: c4a5dd85a92fcc5d4561bada609e0385acde381f > Only execute checkstyle in

[jira] [Commented] (FLINK-7350) only execute japicmp in one build profile

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

[GitHub] flink pull request #4453: [FLINK-6982] [guava] Reduce guava dependency usage...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4453 --- 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 #4458: [FLINK-7348] [checkstyle] Allow redundant modifier...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4458 --- 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-6982) Replace guava dependencies

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

[jira] [Commented] (FLINK-7349) Only execute checkstyle in one build profile

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

[jira] [Commented] (FLINK-7013) Add shaded netty dependency

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

[jira] [Closed] (FLINK-7027) Replace netty dependencies

[ https://issues.apache.org/jira/browse/FLINK-7027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7027. --- Resolution: Fixed 1.4: 1ceb89a979d560944e1099fa4700e46c09a79484 > Replace netty dependencies

[jira] [Commented] (FLINK-6982) Replace guava dependencies

[ https://issues.apache.org/jira/browse/FLINK-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116573#comment-16116573 ] Chesnay Schepler commented on FLINK-6982: - Several guava dependencies were removed for 1.4 in

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[GitHub] flink pull request #4404: [FLINK-4565] [table] Support for SQL IN operator

Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4404#discussion_r131654308 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala --- @@ -0,0 +1,95 @@ +/* + * Licensed to the

[GitHub] flink pull request #4481: [FLINK-7316][network] always use off-heap network ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4481#discussion_r131648828 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java --- @@ -274,7 +260,7 @@ private void

[jira] [Commented] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116716#comment-16116716 ] Till Rohrmann commented on FLINK-7240: -- The underlying problem is the following: The

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

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

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

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

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 One other thing: Also need to add validation for these new configurations. That should be placed in `KinesisConfigUtil.validateProducerConfigs` --- If your project is set up for it, you can

[GitHub] flink pull request #4469: [hotfix][docs] Updated required Java version for s...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4469 --- 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-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

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

[jira] [Closed] (FLINK-7374) Type Erasure in GraphUtils$MapTo

[ https://issues.apache.org/jira/browse/FLINK-7374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Kricke closed FLINK-7374. -- Resolution: Fixed > Type Erasure in GraphUtils$MapTo > > >

[jira] [Commented] (FLINK-7374) Type Erasure in GraphUtils$MapTo

[ https://issues.apache.org/jira/browse/FLINK-7374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116197#comment-16116197 ] Matthias Kricke commented on FLINK-7374: Not sure what helped in the end. I enhanced version to

[GitHub] flink issue #4469: [hotfix][docs] Updated required Java version for standalo...

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4469 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-6995) Add a warning to outdated documentation

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

[GitHub] flink issue #4480: [FLINK-6995] [docs] Enable is_latest attribute to false

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4480 LGTM, I'll merge this to `release-1.2`. It seems like we need to add this true -> false toggle somewhere in our release procedure. --- If your project is set up for it, you can reply to this

[GitHub] flink issue #4480: [FLINK-6995] [docs] Enable is_latest attribute to false

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4480 If we release flink1.4, then we will mark true->false in flink1.3 release also. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

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

[GitHub] flink issue #4456: [FLINK-7343][kafka] Increase Xmx for tests

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4456 +1, LGTM. --- 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-7343) Kafka010ProducerITCase instability

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

[GitHub] flink pull request #4473: [FLINK-7367][kinesis connector] Parameterize more ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4473#discussion_r131578056 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java --- @@

[GitHub] flink pull request #4473: [FLINK-7367][kinesis connector] Parameterize more ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4473#discussion_r131577895 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -169,14

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

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

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

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

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4239 Now that the prerequisite PRs are merged, we can rebase this now :) --- 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

[GitHub] flink issue #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4368 Thanks! :) --- 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-7365) excessive warning logs of attempt to override final parameter: fs.s3.buffer.dir

[ https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116264#comment-16116264 ] Aljoscha Krettek commented on FLINK-7365: - I'm not sure we can change anything here, because that

[jira] [Commented] (FLINK-7284) Verify compile time and runtime version of Hadoop

[ https://issues.apache.org/jira/browse/FLINK-7284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116312#comment-16116312 ] Till Rohrmann commented on FLINK-7284: -- I think we have to use something similar to the

[jira] [Commented] (FLINK-7053) improve code quality in some tests

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

[GitHub] flink issue #4234: [FLINK-7053][blob] improve code quality in some tests

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4234 Changes look good to me. Thanks for the work @NicoK. Merging 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

[jira] [Closed] (FLINK-2759) TaskManagerProcessReapingTest fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-2759. -- Resolution: Fixed closing (fix version already set, issue is also quite old with no new content) >

[jira] [Commented] (FLINK-7013) Add shaded netty dependency

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

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

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

<    1   2   3   4   >