[jira] [Commented] (FLINK-7453) FlinkKinesisProducer logs empty aws region

[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128371#comment-16128371 ] Tzu-Li (Gordon) Tai commented on FLINK-7453: Ah, alright :) I missed it also in the review.

[jira] [Commented] (FLINK-7453) FlinkKinesisProducer logs empty aws region

[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128366#comment-16128366 ] Bowen Li commented on FLINK-7453: - ohho, my bad in https://github.com/apache/flink/pull/4473, I

[jira] [Commented] (FLINK-7453) FlinkKinesisProducer logs empty aws region

[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128364#comment-16128364 ] Tzu-Li (Gordon) Tai commented on FLINK-7453: Could work, but it's still curious why

[jira] [Commented] (FLINK-7453) FlinkKinesisProducer logs empty aws region

[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128359#comment-16128359 ] Bowen Li commented on FLINK-7453: - Is it returning 'null' or just an empty string? So looks like it still

[jira] [Commented] (FLINK-7453) FlinkKinesisProducer logs empty aws region

[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128354#comment-16128354 ] Tzu-Li (Gordon) Tai commented on FLINK-7453: {{open}} is called for each subtask instance. So

[jira] [Commented] (FLINK-7453) FlinkKinesisProducer logs empty aws region

[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128353#comment-16128353 ] Tzu-Li (Gordon) Tai commented on FLINK-7453: This seems a bit odd ... because there is a

[jira] [Commented] (FLINK-7366) Upgrade kinesis producer library in flink-connector-kinesis

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

[GitHub] flink issue #4522: [FLINK-7366][kinesis connector] Upgrade kinesis producer ...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4522 @bowenli86 thanks for confirming! Merging this also then .. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

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

[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128317#comment-16128317 ] 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 Hi @zhangminglei, I merged this to `release-1.2`. Could you close the PR, thanks! The git bot doesn't close PRs automatically if it's not merged to `master`. --- If your project is set up for

[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=16128311#comment-16128311 ] 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 @greghogan ah .. sorry my fault. This isn't merged to `release-1.2` yet. Merging now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink issue #4535: Eventhubs-support read from and write to Azure eventhubs

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4535 @zhuganghuaonnet please let me know when you've opened the JIRA, and rebased this pull request onto the latest `master`. Also please remember to rename the pull request title (you can take a look

[GitHub] flink issue #4535: Eventhubs-support read from and write to Azure eventhubs

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4535 @greghogan yes, a separate `flink-connectors` idea has always been a possible approach in the community, but AFAIK we haven't fully committed to it yet. I can continue to shepherd this contribution

[jira] [Commented] (FLINK-7453) FlinkKinesisProducer logs empty aws region

[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128301#comment-16128301 ] Bowen Li commented on FLINK-7453: - There are lots of this line in my taskmanager.log. Looks like

[jira] [Created] (FLINK-7453) FlinkKinesisProducer logs empty aws region

Bowen Li created FLINK-7453: --- Summary: FlinkKinesisProducer logs empty aws region Key: FLINK-7453 URL: https://issues.apache.org/jira/browse/FLINK-7453 Project: Flink Issue Type: Bug Affects

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

[GitHub] flink issue #4530: [FLINK-7245] [stream] Support holding back watermarks wit...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4530 I'm fine with the changes. +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

[jira] [Commented] (FLINK-7428) avoid one additional buffer copy when receiving messages

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

[GitHub] flink issue #4529: [FLINK-7428][network] avoid buffer copies when receiving ...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4529 @NicoK what do you think of creating a parent issue for your collection of network improvements? --- If your project is set up for it, you can reply to this email and have your reply appear on

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

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

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4480 @tzulitai has this been merged? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] flink issue #4535: Eventhubs-support read from and write to Azure eventhubs

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4535 @tzulitai this does sound like a good candidate for inclusion in Flink. Perhaps a separate `flink-connectors` repo would work better than Apache Bahir. --- If your project is set up for it, you

[jira] [Commented] (FLINK-7447) Hope add more committer information to "Community & Project Info" page.

[ https://issues.apache.org/jira/browse/FLINK-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127565#comment-16127565 ] Greg Hogan commented on FLINK-7447: --- I can see that listing organizations may be beneficial but this

[jira] [Updated] (FLINK-7447) Hope add more committer information to "Community & Project Info" page.

[ https://issues.apache.org/jira/browse/FLINK-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-7447: -- Component/s: (was: Documentation) Project Website > Hope add more committer

[jira] [Updated] (FLINK-7366) Upgrade kinesis producer library in flink-connector-kinesis

[ https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7366: Summary: Upgrade kinesis producer library in flink-connector-kinesis (was: Upgrade kinesis producer

[jira] [Commented] (FLINK-7366) Upgrade kinesis producer library, kinesis client library, and AWS SDK in flink-connector-kinesis

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

[GitHub] flink issue #4522: [FLINK-7366][kinesis connector] Upgrade kinesis producer ...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4522 yeah, we ran our job with this change on Flink 1.3.0 on EMR and didn't have issues. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink pull request #4515: Logging improvements in NetworkFailuresProxy

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4515#discussion_r133231386 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailureHandler.java --- @@ -92,7 +92,14 @@ public

[jira] [Commented] (FLINK-5905) Add user-defined aggregation functions to documentation.

[ https://issues.apache.org/jira/browse/FLINK-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127439#comment-16127439 ] Shaoxuan Wang commented on FLINK-5905: -- This issue will be solved once FLINK-6751 is merged > Add

[jira] [Commented] (FLINK-6751) Table API / SQL Docs: UDFs Page

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

[GitHub] flink pull request #4546: [FLINK-6751] [docs] Add missing documentation for ...

GitHub user shaoxuan-wang opened a pull request: https://github.com/apache/flink/pull/4546 [FLINK-6751] [docs] Add missing documentation for User-Defined Functions Page *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

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

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

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

[GitHub] flink pull request #4545: [FLINK-6805] [Cassandra-Connector] Shade indirect ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4545#discussion_r133218223 --- Diff: flink-connectors/flink-connector-cassandra/pom.xml --- @@ -83,6 +85,10 @@ under the License.

[GitHub] flink pull request #4545: [FLINK-6805] [Cassandra-Connector] Shade indirect ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4545#discussion_r133215094 --- Diff: flink-connectors/flink-connector-cassandra/pom.xml --- @@ -39,6 +39,7 @@ under the License. 2.2.5 3.0.0

[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager

[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127281#comment-16127281 ] Charith Dhanushka Wickramarachchi commented on FLINK-4650: -- I am seeing the

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

Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2992 --- 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-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=16127265#comment-16127265 ] ASF GitHub Bot commented on FLINK-5325: --- Github user StefanRRichter closed the pull request at:

[jira] [Closed] (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:all-tabpanel ] Stefan Richter closed FLINK-7362. - Resolution: Fixed Assignee: Stefan Richter Merged in 843f0cbc10 . > CheckpointProperties

[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=16127264#comment-16127264 ] 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 I will drop this PR. I think the rebase is worse than a redo in case we want this at some point. --- If your project is set up for it, you can reply to this email and have your reply appear

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

[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=16127258#comment-16127258 ] ASF GitHub Bot commented on FLINK-7362: --- Github user StefanRRichter closed the pull request at:

[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 Merged in 843f0cbc10 --- 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

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

Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/4491 --- 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=16127246#comment-16127246 ] ASF GitHub Bot commented on FLINK-7362: --- Github user StefanRRichter commented on the issue:

[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 Thanks for the review @aljoscha ! I addressed your comment and will merge now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r133192783 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/PythonCollector.java --- @@ -0,0 +1,47 @@

[jira] [Commented] (FLINK-7451) Query fails when non-ascii characters are used in string literals

[ https://issues.apache.org/jira/browse/FLINK-7451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127223#comment-16127223 ] Jark Wu commented on FLINK-7451: [~twalthr], is it CALCITE-1903? It seems that Calcite didn't want to fix

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127200#comment-16127200 ] Michael Fong commented on FLINK-6805: - Hi, [~Zentol], Thanks for your reply. I have created a PR

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

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

[GitHub] flink pull request #4545: [FLINK-6805] [Cassandra-Connector] Shade indirect ...

GitHub user mcfongtw opened a pull request: https://github.com/apache/flink/pull/4545 [FLINK-6805] [Cassandra-Connector] Shade indirect netty4 dep in pom.xml ## Brief change log - To relocate various *indirect* netty4 dep of ver 4.0.33.Final to classpath of Flink's flavor using

[jira] [Closed] (FLINK-7268) Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles

[ https://issues.apache.org/jira/browse/FLINK-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7268. - Resolution: Fixed Merged in 91a4b27617 (1.4) and 09caa9ffdc (1.3) > Zookeeper Checkpoint Store

[jira] [Commented] (FLINK-7213) Introduce state management by OperatorID in TaskManager

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

[jira] [Closed] (FLINK-7213) Introduce state management by OperatorID in TaskManager

[ https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7213. - Resolution: Fixed Fix Version/s: 1.4.0 Merged in b71154a734 . > Introduce state

[jira] [Commented] (FLINK-7213) Introduce state management by OperatorID in TaskManager

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

[GitHub] flink issue #4353: [FLINK-7213] Introduce state management by OperatorID in ...

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

[GitHub] flink pull request #4353: [FLINK-7213] Introduce state management by Operato...

Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/4353 --- 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-7268) Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles

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

[GitHub] flink pull request #4410: [FLINK-7268] [checkpoints] Scope SharedStateRegist...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4410 --- 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-7405) Reduce spamming warning logging from DatadogHttpReporter

[ https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7405. --- Resolution: Fixed 1.3: 0aa710a2d11a1c892cd233ffe487439e7fe915ba > Reduce spamming warning

[jira] [Commented] (FLINK-7405) Reduce spamming warning logging from DatadogHttpReporter

[ https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127122#comment-16127122 ] Chesnay Schepler commented on FLINK-7405: - 1.4: 3b0321aee4a409658399b53d8ff77b872e61e42c > Reduce

[jira] [Closed] (FLINK-7415) Include instructions for creating the keyspace in cassandra examples

[ https://issues.apache.org/jira/browse/FLINK-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7415. --- Resolution: Fixed 1.4: 5f97ac9281a443cd72b374c293e525ee5e9b4149 > Include instructions for

[GitHub] flink pull request #4519: [FLINK-7415][Cassandra Connector] Add comments for...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4519 --- 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] [Updated] (FLINK-7415) Add comments for cassandra test class `BatchExample`

[ https://issues.apache.org/jira/browse/FLINK-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7415: Affects Version/s: 1.4.0 1.3.2 > Add comments for cassandra test

[jira] [Updated] (FLINK-7415) Add comments for cassandra test class `BatchExample`

[ https://issues.apache.org/jira/browse/FLINK-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7415: Fix Version/s: 1.4.0 > Add comments for cassandra test class `BatchExample` >

[jira] [Updated] (FLINK-7415) Include instructions for creating the keyspace in cassandra examples

[ https://issues.apache.org/jira/browse/FLINK-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7415: Summary: Include instructions for creating the keyspace in cassandra examples (was: Add

[jira] [Commented] (FLINK-7405) Reduce spamming warning logging from DatadogHttpReporter

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

[GitHub] flink pull request #4508: [FLINK-7405][metrics] Reduce spamming warning logg...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4508 --- 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] [Updated] (FLINK-7415) Add comments for cassandra test class `BatchExample`

[ https://issues.apache.org/jira/browse/FLINK-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7415: Priority: Minor (was: Major) > Add comments for cassandra test class `BatchExample` >

[GitHub] flink pull request #4515: Logging improvements in NetworkFailuresProxy

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4515 --- 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-7415) Add comments for cassandra test class `BatchExample`

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

[jira] [Updated] (FLINK-7415) Add comments for cassandra test class `BatchExample`

[ https://issues.apache.org/jira/browse/FLINK-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7415: Issue Type: Improvement (was: Test) > Add comments for cassandra test class `BatchExample`

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r133171218 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/serialization/PyObjectSerializer.java --- @@ -0,0

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r133170150 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/functions/PythonOutputSelector.java --- @@ -0,0

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r133169625 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/serialization/PyObjectSerializer.java --- @@

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r133169331 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/util/serialization/PyObjectSerializer.java --- @@

[jira] [Commented] (FLINK-7451) Query fails when non-ascii characters are used in string literals

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

[GitHub] flink pull request #4544: [FLINK-7451] [table] Support non-ascii character l...

GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/4544 [FLINK-7451] [table] Support non-ascii character literals in Table API and SQL ## What is the purpose of the change The non-ascii characters in string literals causes calcite planner to

[jira] [Assigned] (FLINK-7450) Bounded generic POJO field is identified as Object by TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-7450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-7450: --- Assignee: Timo Walther > Bounded generic POJO field is identified as Object by TypeExtractor

[jira] [Created] (FLINK-7452) Add helper methods for all built-in Flink types to Types

Timo Walther created FLINK-7452: --- Summary: Add helper methods for all built-in Flink types to Types Key: FLINK-7452 URL: https://issues.apache.org/jira/browse/FLINK-7452 Project: Flink Issue

[jira] [Comment Edited] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126895#comment-16126895 ] Xingcan Cui edited comment on FLINK-6233 at 8/15/17 10:48 AM: -- Hi [~fhueske],

[jira] [Commented] (FLINK-7405) Reduce spamming warning logging from DatadogHttpReporter

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

[GitHub] flink issue #4508: [FLINK-7405][metrics] Reduce spamming warning logging fro...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4508 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 #4535: Eventhubs-support read from and write to Azure eventhubs

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4535 @greghogan I don't think there's actually a consensus that all new connectors should strictly go to Apache Bahir. It still depends case by case, and brought to discussion in the mailing lists if

[jira] [Commented] (FLINK-7415) Add comments for cassandra test class `BatchExample`

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

[GitHub] flink issue #4515: Logging improvements in NetworkFailuresProxy

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4515 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 #4519: [FLINK-7415][Cassandra Connector] Add comments for cassan...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4519 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-5886) Python API for streaming applications

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

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r133159049 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/functions/PythonOutputSelector.java --- @@ -0,0 +1,62

[jira] [Commented] (FLINK-7451) Query fails when non-ascii characters are used in string literals

[ https://issues.apache.org/jira/browse/FLINK-7451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127040#comment-16127040 ] Timo Walther commented on FLINK-7451: - We had this issue recently on the ML. This should be fixed in

[jira] [Created] (FLINK-7451) Query fails when non-ascii characters are used in string literals

Jark Wu created FLINK-7451: -- Summary: Query fails when non-ascii characters are used in string literals Key: FLINK-7451 URL: https://issues.apache.org/jira/browse/FLINK-7451 Project: Flink Issue

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r133156452 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/functions/PythonOutputSelector.java --- @@ -0,0

  1   2   >