[
https://issues.apache.org/jira/browse/FLINK-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984281#comment-15984281
]
ASF GitHub Bot commented on FLINK-6386:
---
Github user zentol commented on a diff in the pull request:
shijinkui created FLINK-6387:
Summary: Flink UI support access log
Key: FLINK-6387
URL: https://issues.apache.org/jira/browse/FLINK-6387
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984278#comment-15984278
]
ASF GitHub Bot commented on FLINK-6356:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3761#discussion_r113377068
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
---
@@ -18,51 +18,83 @@
package
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3761#discussion_r113378455
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java
---
@@ -162,130 +186,114 @@ public int getTimes() {
}
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3775#discussion_r113378988
--- Diff: docs/dev/java8.md ---
@@ -104,7 +104,7 @@ input.filter(line -> !line.contains("not"))
Currently, Flink only supports jobs containing Lambda
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3761#discussion_r113377152
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
---
@@ -18,51 +18,83 @@
package
[
https://issues.apache.org/jira/browse/FLINK-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984279#comment-15984279
]
ASF GitHub Bot commented on FLINK-6356:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984280#comment-15984280
]
ASF GitHub Bot commented on FLINK-6356:
---
Github user dawidwys commented on a diff in the pull
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3692
Sounds good.
I can do a final pass and merge this later this week...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3248
Hi @sunjincheng121, can you close this PR as well? 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
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984516#comment-15984516
]
ASF GitHub Bot commented on FLINK-5695:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984308#comment-15984308
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user hequn8128 commented on the issue:
Github user stefanobortoli commented on the issue:
https://github.com/apache/flink/pull/3732
@fhueske @sunjincheng121 @shijinkui @hongyuhong I have created a PR with
the latest master with the code generated distinct, #3771 please have a look.
If we it is fine, we can basically
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984392#comment-15984392
]
ASF GitHub Bot commented on FLINK-6250:
---
Github user stefanobortoli commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984505#comment-15984505
]
ASF GitHub Bot commented on FLINK-5969:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3778
[FLINK-5969] Add savepoint backwards compatibility tests from 1.2 to 1.3
The binary savepoints and snapshots in the tests were created on the commit
of the Flink 1.2.0 release, so we test
[
https://issues.apache.org/jira/browse/FLINK-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984512#comment-15984512
]
ASF GitHub Bot commented on FLINK-6356:
---
Github user dawidwys commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984523#comment-15984523
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984522#comment-15984522
]
ASF GitHub Bot commented on FLINK-6387:
---
Github user StephanEwen commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3733
Thanks for the update @hequn8128. The PR looks really good, IMO.
Will do a couple of minor refactorings and merge it to `table-retraction`
branch.
Best, Fabian
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984524#comment-15984524
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3736
+1 from my side
@zentol any further comments/concerns?
---
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
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984387#comment-15984387
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984396#comment-15984396
]
ASF GitHub Bot commented on FLINK-5869:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3772#discussion_r113399653
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java
---
@@ -72,6 +72,13 @@
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984464#comment-15984464
]
ASF GitHub Bot commented on FLINK-6387:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984465#comment-15984465
]
ASF GitHub Bot commented on FLINK-6387:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984463#comment-15984463
]
ASF GitHub Bot commented on FLINK-6387:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984466#comment-15984466
]
ASF GitHub Bot commented on FLINK-6387:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984491#comment-15984491
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984500#comment-15984500
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984501#comment-15984501
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984499#comment-15984499
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984492#comment-15984492
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984528#comment-15984528
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user fanyon commented on the issue:
Github user fanyon commented on the issue:
https://github.com/apache/flink/pull/3766
The new API should in a new class, such as FlinkKafkaPartitioner. For the
older KafkaPartitioner implementation, it will be delegated by
FlinkKafkaAdpterPartitioner extends FlinkKafkaPartitioner, in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3663#discussion_r113415863
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowSerializationSchema.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984537#comment-15984537
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user twalthr commented on a diff in the pull
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3777
I think this is a good issue.
I am wondering if we may want to approach this a bit broader even and
define certain "access levels" to the UI:
- view jobs only
- view jobs and
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984391#comment-15984391
]
ASF GitHub Bot commented on FLINK-6387:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984441#comment-15984441
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user gyfora commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984517#comment-15984517
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user zentol commented on a diff in the pull request:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3777
@zentol @shijinkui Ah, forget what I said, I only read the description and
thought it was something different ;-)
I thought this was about forbidding UI users to access the logs (which
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3567
---
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
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984520#comment-15984520
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984519#comment-15984519
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984364#comment-15984364
]
ASF GitHub Bot commented on FLINK-6356:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3761
Thanks for the review @dawidwys ! Thanks a lot for the review.
I integrated your comments. Let me know when you are done so that I can
merge this.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984362#comment-15984362
]
Stephen Gran commented on FLINK-6336:
-
Hi,
Any chance this can make the 1.3.0 release?
Thanks!
>
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984402#comment-15984402
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user fanyon commented on the issue:
Github user fanyon commented on the issue:
https://github.com/apache/flink/pull/3766
@gyfora Thanks for your comment. And right, your question is very good. I
originally thought that the user must be sure to know all the output topic when
the job is submitted, but in the real
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984497#comment-15984497
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984496#comment-15984496
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984494#comment-15984494
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984495#comment-15984495
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984493#comment-15984493
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410291
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410371
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410392
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410244
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410447
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410023
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113408171
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,10 @@ under the License.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113409930
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0 +1,83
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410687
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984498#comment-15984498
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410046
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113409179
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0 +1,83
GitHub user shijinkui opened a pull request:
https://github.com/apache/flink/pull/3777
[FLINK-6387] [webfrontend]Flink UI support access log
Record the use request to the access log. Append use access to the log file.
- [X] General
- The pull request references the
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984332#comment-15984332
]
ASF GitHub Bot commented on FLINK-6387:
---
GitHub user shijinkui opened a pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r113405541
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
---
@@ -0,0 +1,199 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984448#comment-15984448
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984447#comment-15984447
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r113405034
--- Diff: flink-metrics/flink-metrics-datadog/pom.xml ---
@@ -0,0 +1,109 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3777#discussion_r113406843
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/HttpRequestHandler.java
---
@@ -183,4 +194,28 @@ else if (currentDecoder !=
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3777#discussion_r113406502
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/HttpRequestHandler.java
---
@@ -183,4 +194,28 @@ else if (currentDecoder !=
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3777#discussion_r113406464
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -645,6 +645,10 @@
@Deprecated
public static
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3777#discussion_r113406982
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -645,6 +645,10 @@
@Deprecated
public static
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3712#discussion_r113411053
--- Diff:
flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCTableSinkTest.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3712#discussion_r113412806
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTableSink.java
---
@@ -0,0 +1,91 @@
+/*
+ * Licensed to
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3712#discussion_r113410993
--- Diff:
flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCTableSinkTest.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3712#discussion_r113410894
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTableSink.java
---
@@ -0,0 +1,91 @@
+/*
+ * Licensed to
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3712#discussion_r113412006
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTableSink.java
---
@@ -0,0 +1,91 @@
+/*
+ * Licensed to
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3780
[FLINK-6274] Replaces usages of org.codehaus.jackson
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984659#comment-15984659
]
Andrey commented on FLINK-4973:
---
Here is more logs. Job was executed for some time and then was cancelled
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3769
Looks good, +1.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-6093:
--
Assignee: Hequn Cheng (was: Shaoxuan Wang)
> Implement and turn on retraction for table sink
[
https://issues.apache.org/jira/browse/FLINK-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-6248.
-
Resolution: Fixed
Merged at b3de48d0e2c1fec6ccab3a8dd0f02b711dc0ae0a
> Make the optional()
[
https://issues.apache.org/jira/browse/FLINK-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-6356.
-
Resolution: Fixed
Merged at 0d856b34f90c0775b7c9d5e88f5ed6cdf6090851
> Make times() eager and
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984700#comment-15984700
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984544#comment-15984544
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user twalthr commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3663#discussion_r113416754
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowSerializationSchema.java
---
@@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3663#discussion_r113416949
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowSerializationSchema.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984626#comment-15984626
]
Greg Hogan commented on FLINK-6382:
---
Hi [~heytitle], it would be great if you could review the PR. I
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984638#comment-15984638
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-6093:
---
Description: Add needsUpdatesAsRetraction property to TableSink, and take
TableSink into
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984722#comment-15984722
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984542#comment-15984542
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3779
[FLINK-6382] [gelly] Support all numeric types for generated graphs in
Gelly examples
The Gelly examples current support IntValue, LongValue, and StringValue for
RMatGraph. Allow transformations
1 - 100 of 348 matches
Mail list logo
