GitHub user tedyu opened a pull request:
https://github.com/apache/flink/pull/1560
FLINK-3301 Ineffective synchronization in
MessageAcknowledgingSourceBase#restoreState
This PR changes synchronization on pendingCheckpoints to this
(MessageAcknowledgingSourceBase)
You can merge thi
[
https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122955#comment-15122955
]
ASF GitHub Bot commented on FLINK-3301:
---
GitHub user tedyu opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122945#comment-15122945
]
subhankar biswas commented on FLINK-3033:
-
i already finished writing the source.
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122946#comment-15122946
]
subhankar biswas commented on FLINK-3034:
-
i already finished the sink.
> Redis
Github user ChengXiangLi closed the pull request at:
https://github.com/apache/flink/pull/1556
---
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 i
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122651#comment-15122651
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1559#issuecomment-176501262
@ChengXiangLi, @twalthr: Please review and give feedback.
@ChengXiangLi, this PR contains stubs for the translation rules which are
quite similar to the rules in
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/1559
[FLINK-3225] Implemented optimization of Table API queries via Calcite
- added logical Flink nodes and translation rules
- added stubs for DataSet translation rules
- ported DataSetNodes to S
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122644#comment-15122644
]
ASF GitHub Bot commented on FLINK-3225:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johannes reassigned FLINK-3293:
---
Assignee: Johannes
> Custom Application Name on YARN is ignored in deploy jobmanager mode
> -
[
https://issues.apache.org/jira/browse/FLINK-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122571#comment-15122571
]
ASF GitHub Bot commented on FLINK-3293:
---
GitHub user jkirsch opened a pull request:
GitHub user jkirsch opened a pull request:
https://github.com/apache/flink/pull/1558
[FLINK-3293] Respect custom cli yarn name in jobmanager mode
Added a method to set a default application name for the flink yarn session
cli.
Switched the order, such that this name can now be o
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3210:
--
Description:
Here is related code:
{code}
byte[] valueBytes;
if (payload == null
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122563#comment-15122563
]
Subhobrata Dey commented on FLINK-3033:
---
Hello,
If nobody is working on this issue,
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122562#comment-15122562
]
Subhobrata Dey commented on FLINK-3034:
---
Hello,
if nobody is working on this issue,
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122486#comment-15122486
]
Subhobrata Dey commented on FLINK-2678:
---
Hello Till,
I was checking the implementat
Ted Yu created FLINK-3301:
-
Summary: Ineffective synchronization in
MessageAcknowledgingSourceBase#restoreState
Key: FLINK-3301
URL: https://issues.apache.org/jira/browse/FLINK-3301
Project: Flink
I
Stephan Ewen created FLINK-3300:
---
Summary: Concurrency Bug in Yarn JobManager
Key: FLINK-3300
URL: https://issues.apache.org/jira/browse/FLINK-3300
Project: Flink
Issue Type: Bug
Comp
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1557
[FLINK-3216] [FLINK-3217] [cep] Initial version of CEP library
This PR is the first version of Flink's CEP library.
The key components are the `NFA` which uses the `SharedBuffer` to
ef
[
https://issues.apache.org/jira/browse/FLINK-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122144#comment-15122144
]
ASF GitHub Bot commented on FLINK-3216:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121750#comment-15121750
]
Till Rohrmann commented on FLINK-2678:
--
Done. Great that you're picking this issue up
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2678:
-
Assignee: Subhobrata Dey
> DataSet API does not support multi-dimensional arrays as keys
> ---
[
https://issues.apache.org/jira/browse/FLINK-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3196.
-
Resolution: Fixed
Assignee: Suneel Marthi
Fix Version/s: 1.0.0
Fixed via f6d2ce91e
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3178.
---
> Make Closing Behavior of Window Operators Configurable
> ---
[
https://issues.apache.org/jira/browse/FLINK-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3196.
---
> InputStream should be closed in
> EnvironmentInformation#getRevisionInformation()
> ---
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3178.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via c4e5a55f027ed73ce557f10d5125a0b168832889
[
https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3242.
---
> User-specified StateBackend is not Respected if Checkpointing is Disabled
>
[
https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3242.
-
Resolution: Fixed
Fix Version/s: 0.10.2
1.0.0
Fixed in
- 0.10.2 via 2a
[
https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121737#comment-15121737
]
Gyula Fora commented on FLINK-3299:
---
I am not sure if I would rush to remove it in fact
[
https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3292.
---
> Bug in flink-jdbc. Not all JDBC drivers supported
> -
>
[
https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3292.
-
Resolution: Fixed
Fixed via d97fcda6635b6821ac3f61c39e0fa156bc7c7fd4
Thank you for the contributi
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3265.
---
> RabbitMQ Source not threadsafe: ConcurrentModificationException
> --
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3265.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via 6b01a89020f2de3f7710cf72336291b1e8ca8562
[
https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121709#comment-15121709
]
ASF GitHub Bot commented on FLINK-3242:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121712#comment-15121712
]
ASF GitHub Bot commented on FLINK-3292:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121710#comment-15121710
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121711#comment-15121711
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1552
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1551
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1542
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1534
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1516
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3294:
-
Assignee: Robert Metzger
> KafkaConsumer (0.8) commit offsets using SimpleConsumer.commit
[
https://issues.apache.org/jira/browse/FLINK-3295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121664#comment-15121664
]
ASF GitHub Bot commented on FLINK-3295:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1555#issuecomment-176230855
Yes, curator is retrying using an exponential backoff retry.
I've addressed your comments.
---
If your project is set up for it, you can reply to this email an
Ufuk Celebi created FLINK-3299:
--
Summary: Remove ApplicationID from Environment
Key: FLINK-3299
URL: https://issues.apache.org/jira/browse/FLINK-3299
Project: Flink
Issue Type: Improvement
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1556#discussion_r51125883
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/sql/calcite/flinkFunction/ProjectFunction.java
---
@@ -0,0 +1,49 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121516#comment-15121516
]
Subhobrata Dey commented on FLINK-2678:
---
Hello Till,
Please assign me the issue. I
[
https://issues.apache.org/jira/browse/FLINK-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3262.
-
Resolution: Fixed
Fixed via 1ea5e138793e343010f1cee07d8a0d88e67b6e51
Thank you for the contributi
[
https://issues.apache.org/jira/browse/FLINK-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3262.
---
> Remove fuzzy versioning from Bower dependencies
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121499#comment-15121499
]
ASF GitHub Bot commented on FLINK-3262:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1525
---
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 enab
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1524#discussion_r51123441
--- Diff:
flink-core/src/test/java/org/apache/flink/configuration/FilesystemSchemeConfigTest.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the A
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1524#issuecomment-176194702
Thanks for picking up this issue. This goes into a very good direction.
Few remaining points:
- There are a lot of unrelated reformattings. The general
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121495#comment-15121495
]
ASF GitHub Bot commented on FLINK-2380:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121490#comment-15121490
]
Till Rohrmann commented on FLINK-2678:
--
Hi [~sbcd90],
as far as I know, there is nob
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121485#comment-15121485
]
ASF GitHub Bot commented on FLINK-2380:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1524#discussion_r51123709
--- Diff: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java
---
@@ -159,56 +163,109 @@ public int hashCode() {
/**
* Retu
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121481#comment-15121481
]
ASF GitHub Bot commented on FLINK-2380:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1524#discussion_r51123237
--- Diff:
flink-core/src/test/java/org/apache/flink/configuration/GlobalConfigurationTest.java
---
@@ -19,13 +19,19 @@
package org.apache.flink.conf
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121477#comment-15121477
]
ASF GitHub Bot commented on FLINK-2380:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121467#comment-15121467
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1534#issuecomment-176189788
Will merge this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121470#comment-15121470
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1546#issuecomment-176189641
This is going into a good direction. Two suggestions:
- Since you already have the `ExecutionConfig` in the Task, I would put
it into the `Environment` fro
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121456#comment-15121456
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1546#discussion_r51122613
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java
---
@@ -93,24 +94,28 @@
private final Ser
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1551#issuecomment-176188709
Thank for the contribution and review!
Will merge this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121452#comment-15121452
]
ASF GitHub Bot commented on FLINK-3292:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121410#comment-15121410
]
ASF GitHub Bot commented on FLINK-3242:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1516#issuecomment-176184025
Merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this fe
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1552#issuecomment-176183398
Looks good, thanks, merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project d
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121401#comment-15121401
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1542#issuecomment-176181849
Merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this fe
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1555#issuecomment-176175300
I think we have to make this a bit more sophisticated and allow the user to
specify behavior when offsets cannot be fetched:
- FAIL (fail if any offset cou
[
https://issues.apache.org/jira/browse/FLINK-3295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121389#comment-15121389
]
ASF GitHub Bot commented on FLINK-3295:
---
Github user StephanEwen commented on the pu
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1544#issuecomment-176170046
Yes, I wanted to start a discussion about sticking with Scala as well.
I'll open a PR for FLINK-3225 very soon and can take care of translating
the nodes to Scala an
[
https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121374#comment-15121374
]
ASF GitHub Bot commented on FLINK-3282:
---
Github user fhueske commented on the pull r
Github user JonathanH5 commented on the pull request:
https://github.com/apache/flink/pull/1156#issuecomment-176168967
Ok, I think I incorporated everything that you asked for. I will squash all
of the commits and rebase everything when you give me the go for that :).
---
If your pro
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121371#comment-15121371
]
ASF GitHub Bot commented on FLINK-1719:
---
Github user JonathanH5 commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121366#comment-15121366
]
Subhobrata Dey commented on FLINK-2678:
---
Hello Till,
If no one is working on this i
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1556#issuecomment-176157407
As far as I know the `Expressions` are for the user-facing API only, right?
I think we won't need the `RexToExpr` class anymore, as I am currently writing
a rex to code
[
https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121338#comment-15121338
]
ASF GitHub Bot commented on FLINK-3292:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1551#issuecomment-176157025
looks good. +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 thi
[
https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121311#comment-15121311
]
ASF GitHub Bot commented on FLINK-3292:
---
Github user sbcd90 commented on the pull re
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1551#issuecomment-176153352
Hello zentol,
I dont see any updates from your side. Can you kindly let me know if this
PR is good to be merged so that I can close the issue?
---
If your proje
[
https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121300#comment-15121300
]
ASF GitHub Bot commented on FLINK-3282:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1544#issuecomment-176150700
When I wrote my SQL prototype I also thought about using Java because
Calcite is written in Java, but since it is easy to use Java classes from Scala
and Scala has a muc
[
https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121279#comment-15121279
]
ASF GitHub Bot commented on FLINK-3282:
---
Github user ChengXiangLi commented on the p
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1544#issuecomment-176144759
I didn't prefer Java or Scala, the reason why i writen this in Java is
that, this part logic would be translated from Calcite RelNodes(which is in
Java) and finally
GitHub user ChengXiangLi opened a pull request:
https://github.com/apache/flink/pull/1556
[Flink-3226] Implement project and filter translator.
This is just prototype implementation to translate Calcite Project and
Filter into Flink RelNode. It still miss several parts, which could
Mohit Sethi created FLINK-3297:
--
Summary: Streaming connector for ZeroMQ
Key: FLINK-3297
URL: https://issues.apache.org/jira/browse/FLINK-3297
Project: Flink
Issue Type: New Feature
Co
Mohit Sethi created FLINK-3298:
--
Summary: Streaming connector for ActiveMQ
Key: FLINK-3298
URL: https://issues.apache.org/jira/browse/FLINK-3298
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121252#comment-15121252
]
ASF GitHub Bot commented on FLINK-3282:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1544#issuecomment-176133567
@fhueske and @ChengXiangLi: Sorry but I have to discuss this PR again. Do
we really want to have parts of the Table API written in Java and some other
parts written in S
Robert Metzger created FLINK-3296:
-
Summary: DataStream.write*() methods are not flushing properly
Key: FLINK-3296
URL: https://issues.apache.org/jira/browse/FLINK-3296
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121237#comment-15121237
]
Robert Metzger commented on FLINK-3175:
---
Another case: https://api.travis-ci.org/job
[
https://issues.apache.org/jira/browse/FLINK-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3175:
-
Assignee: Robert Metzger
> KafkaITCase.testOffsetAutocommitTest
> ---
[
https://issues.apache.org/jira/browse/FLINK-3275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-3275.
---
Resolution: Fixed
Implemented in 40422d5057e5c1d7b75aec48bacbd7518cd7c9e1
> [py] Add support
1 - 100 of 113 matches
Mail list logo
